boolean stoppedFlag
boolean terminatedFlag
boolean terminatingFlag
ActorTimerTask currentTimerTask
int timeoutCounter
MessageStream currentSender
AsyncMessagingCore core
DataflowExpression<T> joinLatch
PGroup parallelGroup
groovy.lang.Closure<V> onStop
java.lang.Thread currentThread
DataflowExpression<T> joinLatch
RemoteHost remoteHost
Actor actor
Actor actor
java.lang.Object payLoad
MessageStream sender
groovy.lang.Closure<V> nextContinuation
groovy.lang.Closure<V> loopClosure
java.lang.Runnable loopCode
java.util.concurrent.Callable<V> loopCondition
groovy.lang.Closure<V> afterLoopCode
boolean started
DefaultActor myActor
RemoteHost remoteHost
MessageStream to
ActorMessage message
MessageStream sender
SequentialProcessingActor.Node inputQueue
SequentialProcessingActor.Node outputQueue
java.util.concurrent.atomic.AtomicBoolean ongoingThreadTermination
java.lang.Thread waitingThread
int stopFlag
groovy.lang.Closure<V> code
PGroup parallelGroup
groovy.lang.Closure<V> code
Pool pool
RemoteHost remoteHost
boolean disconnected
groovy.lang.Closure<V> initializer
java.util.concurrent.atomic.AtomicBoolean initializationStarted
PGroup group
ResizeableCountDownLatch parties
groovy.lang.MetaClass metaClass
java.lang.Object value
java.lang.Throwable error
java.util.concurrent.atomic.AtomicInteger state
java.util.concurrent.atomic.AtomicReference<V> waiting
DataflowChannelEventOrchestrator<T> eventManager
DataflowExpression<T> expr
java.lang.Object message
DataflowExpression<T> receiver
java.lang.String name
RemoteHost remoteHost
int index
SelectableChannel<T> channel
DataflowVariable<T> result
groovy.lang.Closure<V> closure
groovy.lang.Closure<V> errorHandler
private void readObject(java.io.ObjectInputStream s) throws java.io.IOException, java.lang.ClassNotFoundException
java.io.IOException
java.lang.ClassNotFoundException
private void writeObject(java.io.ObjectOutputStream s) throws java.io.IOException
java.io.IOException
CustomConcurrentHashMap.NodeFactory factory
CustomConcurrentHashMap.Equivalence<K> keyEquivalence
CustomConcurrentHashMap.Equivalence<K> valueEquivalence
int initialSegmentCapacity
CustomConcurrentHashMap<K,V> cchm
java.util.UUID nodeId
Actor mainActor
SerialHandle serialHandle