groovyx.gpars.dataflow
Class DataflowExpression.WaitingThread

java.lang.Object
  java.util.concurrent.atomic.AtomicBoolean
      groovyx.gpars.dataflow.DataflowExpression.WaitingThread

All Implemented Interfaces:

java.io.Serializable

Enclosing class:

DataflowExpression<T>

private static final class DataflowExpression.WaitingThread
extends java.util.concurrent.atomic.AtomicBoolean

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

Field Summary

private java.lang.Object	attachment
private MessageStream	callback
private DataflowExpression.WaitingThread	previous
private static long	serialVersionUID
private java.lang.Thread	thread

Constructor Summary

private

DataflowExpression.WaitingThread(java.lang.Thread thread, DataflowExpression.WaitingThread previous, java.lang.Object attachment, MessageStream callback) Creates a representation of the request to read the value once it is bound

Method Summary

Methods inherited from class java.util.concurrent.atomic.AtomicBoolean

compareAndSet, get, getAndSet, lazySet, set, toString, weakCompareAndSet

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

serialVersionUID

private static final long serialVersionUID

See Also:

Constant Field Values

thread

private final java.lang.Thread thread

previous

private volatile DataflowExpression.WaitingThread previous

callback

private final MessageStream callback

attachment

private final java.lang.Object attachment

Constructor Detail

DataflowExpression.WaitingThread

private DataflowExpression.WaitingThread(java.lang.Thread thread,
                                         DataflowExpression.WaitingThread previous,
                                         java.lang.Object attachment,
                                         MessageStream callback)

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

Parameters:

thread - The physical thread of the request, which will be suspended

previous - The previous request in the chain of requests

attachment - An arbitrary object closely identifying the request for the caller

callback - An actor or operator to send a message to once a value is bound