Groovy Documentation

gpars.dataflow
Class DataFlowExpression.WaitingThread

java.lang.Object
  java.util.concurrent.atomic.AtomicBoolean
      gpars.dataflow.DataFlowExpression.WaitingThread

class DataFlowExpression.WaitingThread
extends AtomicBoolean

A logical representation of a synchronous or asynchronous request to read the value once it is bound.


Constructor Summary
private DataFlowExpression.WaitingThread(Thread thread, WaitingThread previous, Object attachment, MessageStream callback)

Creates a representation of the request to read the value once it is bound

 
Method Summary
 
Methods inherited from class AtomicBoolean
get, toString, set, lazySet, getAndSet, compareAndSet, weakCompareAndSet, wait, wait, wait, equals, hashCode, getClass, notify, notifyAll
 
Methods inherited from class Object
wait, wait, wait, equals, toString, hashCode, getClass, notify, notifyAll
 

Constructor Detail

DataFlowExpression.WaitingThread

private DataFlowExpression.WaitingThread(Thread thread, WaitingThread previous, Object attachment, MessageStream callback)
Creates a representation of the request to read the value once it is bound
param:
thread The physical thread of the request, which will be suspended
param:
previous The previous request in the chain of requests
param:
attachment An arbitrary object closely identifying the request for the caller
param:
callback An actor or operator to send a message to once a value is bound


 

Groovy Documentation