org.codehaus.gpars

groovyx.gpars.dataflow
[Java] Class DataflowExpression.WaitingThread

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

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 WaitingThread previous

private static long serialVersionUID

private java.lang.Thread thread

 
Constructor Summary
private DataflowExpression.WaitingThread(java.lang.Thread thread, 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
java.util.concurrent.atomic.AtomicBoolean#get(), java.util.concurrent.atomic.AtomicBoolean#toString(), java.util.concurrent.atomic.AtomicBoolean#set(boolean), java.util.concurrent.atomic.AtomicBoolean#compareAndSet(boolean, boolean), java.util.concurrent.atomic.AtomicBoolean#getAndSet(boolean), java.util.concurrent.atomic.AtomicBoolean#lazySet(boolean), java.util.concurrent.atomic.AtomicBoolean#weakCompareAndSet(boolean, boolean), java.util.concurrent.atomic.AtomicBoolean#wait(long), java.util.concurrent.atomic.AtomicBoolean#wait(), java.util.concurrent.atomic.AtomicBoolean#wait(long, int), java.util.concurrent.atomic.AtomicBoolean#equals(java.lang.Object), java.util.concurrent.atomic.AtomicBoolean#hashCode(), java.util.concurrent.atomic.AtomicBoolean#getClass(), java.util.concurrent.atomic.AtomicBoolean#notify(), java.util.concurrent.atomic.AtomicBoolean#notifyAll()
 
Methods inherited from class java.lang.Object
java.lang.Object#wait(long), java.lang.Object#wait(), java.lang.Object#wait(long, int), java.lang.Object#equals(java.lang.Object), java.lang.Object#toString(), java.lang.Object#hashCode(), java.lang.Object#getClass(), java.lang.Object#notify(), java.lang.Object#notifyAll()
 

Field Detail

attachment

private final java.lang.Object attachment


callback

private final MessageStream callback


previous

private WaitingThread previous


serialVersionUID

private static final long serialVersionUID


thread

private final java.lang.Thread thread


 
Constructor Detail

DataflowExpression.WaitingThread

private DataflowExpression.WaitingThread(java.lang.Thread thread, 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–2010 Václav Pech. All Rights Reserved.