java.util.List<E> concurrentExceptions
java.lang.Class<T>[] defaultParamTypes
int numberOfParameters
groovy.lang.Closure<V> code
java.lang.Thread myThread
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
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
java.util.List<E> issues
RemoteHost remoteHost
MessageStream to
ActorMessage message
MessageStream sender
java.lang.Runnable action
SequentialProcessingActor.Node inputQueue
SequentialProcessingActor.Node outputQueue
java.util.concurrent.atomic.AtomicBoolean ongoingThreadTermination
java.lang.Thread waitingThread
int stopFlag
RemoteHost remoteHost
DataflowExpression<T> joinLatch
Actor actor
Actor actor
AsyncMessagingCore core
java.lang.Thread currentThread
java.util.List<E> errors
DataflowVariable<T> oldValueVariable
DataflowVariable<T> newValueVariable
RemoteHost remoteHost
AgentClosureExecutionPolicy executionPolicy
groovy.lang.Closure<V> code
PGroup parallelGroup
groovy.lang.Closure<V> code
Pool pool
java.lang.Object queueLock
java.util.concurrent.LinkedBlockingQueue<E> queue
java.util.Queue<E> requests
java.util.Collection<E> wheneverBoundListeners
DataflowChannelEventOrchestrator<T> eventManager
groovy.lang.Closure<V> initializer
java.util.concurrent.atomic.AtomicBoolean initializationStarted
PGroup group
ResizeableCountDownLatch parties
java.lang.Object[] args
groovy.lang.MetaClass metaClass
java.lang.Object value
java.lang.Throwable error
int state
DataflowExpression.WaitingThread waiting
DataflowChannelEventOrchestrator<T> eventManager
DataflowExpression<T> expr
java.lang.Object message
DataflowExpression<T> receiver
java.lang.String name
java.lang.Object receiver
java.lang.String methodName
RemoteHost remoteHost
int index
SelectableChannel<T> channel
DataflowVariable<T> result
groovy.lang.Closure<V> closure
groovy.lang.Closure<V> errorHandler
groovy.lang.Closure<V> code
groovy.lang.Closure<V> code
groovy.lang.Closure<V> code
groovy.lang.Closure<V> wiseMan
groovy.lang.Closure<V> code
RemoteHost remoteHost
RemoteHost remoteHost
StreamCore<T> head
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.List<E> children
int maxSize
groovy.lang.Closure<V> code
groovy.lang.Closure<V> target
java.lang.String name
Actor actor
java.lang.String actorName
AgentCore agent
DataflowVariable<T> valueVariable
java.lang.String name
AgentCore agent
java.lang.String name
AgentCore agent
DataflowVariable<T> oldValueVariable
DataflowVariable<T> newValueVariable
AgentCore agent
java.lang.Object message
java.lang.String name
DataflowStreamWriteAdapter<T> stream
java.lang.String name
DataflowChannel<T> queue
java.lang.Object value
java.lang.String name
DataflowChannel<T> queue
java.lang.String name
DataflowVariable<T> value
DataflowChannel<T> queue
java.lang.String name
DataflowVariable<T> variable
boolean bound
java.lang.Object value
java.lang.String name
java.lang.Class<T> klazz
protected java.lang.Object readResolve()
java.util.UUID id
protected final java.lang.Object readResolve() throws java.io.ObjectStreamException
java.io.ObjectStreamException
java.util.UUID serialId
java.util.UUID hostId
java.util.UUID serialId
java.util.UUID hostId
protected final java.lang.Object writeReplace() throws java.io.ObjectStreamException
java.io.ObjectStreamException
- If the object cannot be serializedSerialHandle serialHandle