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

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.