raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 10

Optimization of DataFlow + bugfix

Browse source
This commit is contained in:
Viktor Klang 2010-08-24 13:11:41 +02:00
parent 30b3627899
commit 4b7bf0ded0
1 changed files with 20 additions and 7 deletions
Download patch file Download diff file Expand all files Collapse all files

27
akka-core/src/main/scala/dataflow/DataFlowVariable.scala
View file

@ -85,13 +85,19 @@ object DataFlow {
/** Sets the value of this variable (if unset) with the value of the supplied variable
*/
def <<(ref: DataFlowVariable[T]): Unit =
if(this.value.get.isEmpty) in ! Set(ref())
def <<(ref: DataFlowVariable[T]) {
if (this.value.get.isEmpty) in ! Set(ref())
else throw new DataFlowVariableException(
"Attempt to change data flow variable (from [" + this.value.get + "] to [" + ref() + "])")
}
/** Sets the value of this variable (if unset)
*/
def <<(value: T): Unit =
if(this.value.get.isEmpty) in ! Set(value)
def <<(value: T) {
if (this.value.get.isEmpty) in ! Set(value)
else throw new DataFlowVariableException(
"Attempt to change data flow variable (from [" + this.value.get + "] to [" + value + "])")
}
/** Retrieves the value of variable
* throws a DataFlowVariableException if it times out
@ -99,9 +105,16 @@ object DataFlow {
def apply(): T = {
value.get getOrElse {
val out = actorOf(new Out(this)).start
blockedReaders offer out
val result = (out !! Get).as[T]
out ! Exit
val result = try {
blockedReaders offer out
(out !! Get).as[T]
} catch {
case e: Exception =>
out ! Exit
throw e
}
result.getOrElse(throw new DataFlowVariableException("Timed out (after " + timeoutMs + " milliseconds) while waiting for result"))
}
}