org.codehaus.gpars

groovyx.gpars.dataflow.expression
[Java] Class DataflowExpression.DataflowExpressionsCollector

java.lang.Object
  groovyx.gpars.serial.WithSerialId
      groovyx.gpars.actor.impl.MessageStream
          groovyx.gpars.dataflow.expression.DataflowExpression.DataflowExpressionsCollector

final class DataflowExpression.DataflowExpressionsCollector
extends MessageStream

Listener for availability of data flow expressions we depend on. Keeps a counter of monitored dataflow expressions. The counter gets decreased with each expression becoming available. Once the counter reaches 0, the Collector evaluates itself and becomes bound to the resulting value.


Field Summary
private java.util.concurrent.atomic.AtomicInteger count

private static long serialVersionUID

 
Fields inherited from class MessageStream
serialVersionUID
 
Fields inherited from class WithSerialId
serialHandle, serialVersionUID
 
Constructor Summary
DataflowExpression.DataflowExpressionsCollector()

 
Method Summary
MessageStream send(java.lang.Object message)

void start()

java.lang.Object subscribe(java.lang.Object element)

 
Methods inherited from class MessageStream
call, getRemoteClass, leftShift, reInterrupt, send, send, send, sendAndWait, sendAndWait, sendAndWait
 
Methods inherited from class WithSerialId
createRemoteHandle, getOrCreateSerialHandle, getRemoteClass, writeReplace
 

Field Detail

count

private final java.util.concurrent.atomic.AtomicInteger count


serialVersionUID

private static final long serialVersionUID


 
Constructor Detail

DataflowExpression.DataflowExpressionsCollector

DataflowExpression.DataflowExpressionsCollector()


 
Method Detail

send

@Override
public MessageStream send(java.lang.Object message)


start

void start()


subscribe

java.lang.Object subscribe(java.lang.Object element)


 

Copyright © 2008–2012 Václav Pech. All Rights Reserved.