Overview  Package   Class  Deprecated  Index  Help 
org.codehaus.gpars
FRAMES    NO FRAMES    
SUMMARY: NESTED | FIELD | CONSTR | METHOD DETAIL: FIELD | CONSTR | METHOD

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.