groovyx.gpars.dataflow.expression
Class DataflowExpression.WaitingThread

java.lang.Object
  extended by java.util.concurrent.atomic.AtomicBoolean
      extended by groovyx.gpars.dataflow.expression.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

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