Serialized Form

Package groovyx.gpars

Class groovyx.gpars.AsyncException extends java.lang.RuntimeException implements Serializable

serialVersionUID: 1573135643731810717L

Serialized Fields

concurrentExceptions

java.util.List<E> concurrentExceptions

Class groovyx.gpars.DataFlowMessagingRunnable extends groovy.lang.Closure implements Serializable

serialVersionUID: 4796783310470426395L

Serialized Fields

defaultParamTypes

java.lang.Class<T>[] defaultParamTypes

numberOfParameters

int numberOfParameters

Class groovyx.gpars.MessagingRunnable extends groovy.lang.Closure implements Serializable

serialVersionUID: 4796783310470426395L

Class groovyx.gpars.ReactorMessagingRunnable extends groovy.lang.Closure implements Serializable

serialVersionUID: 4796783310470426395L

Package groovyx.gpars.actor

Class groovyx.gpars.actor.AbstractLoopingActor extends Actor implements Serializable

serialVersionUID: -7638132628355085829L

Serialized Fields

stoppedFlag

boolean stoppedFlag

terminatedFlag

boolean terminatedFlag

terminatingFlag

boolean terminatingFlag

currentTimerTask

ActorTimerTask currentTimerTask

timeoutCounter

int timeoutCounter

currentSender

MessageStream currentSender

core

AsyncMessagingCore core

Holds the particular instance of async messaging core to use

Class groovyx.gpars.actor.AbstractPooledActor extends SequentialProcessingActor implements Serializable

serialVersionUID: -6232655362494852540L

Class groovyx.gpars.actor.Actor extends MessageStream implements Serializable

serialVersionUID: -3491276479442857422L

Serialized Fields

joinLatch

DataFlowExpression<T> joinLatch

parallelGroup

groovyx.gpars.group.PGroup parallelGroup

The parallel group to which the message stream belongs

onStop

groovy.lang.Closure onStop

currentThread

java.lang.Thread currentThread

Class groovyx.gpars.actor.Actor.MyRemoteHandle extends DefaultRemoteHandle implements Serializable

serialVersionUID: 3721849638877039035L

Serialized Fields

joinLatch

DataFlowExpression<T> joinLatch

Class groovyx.gpars.actor.Actor.RemoteActor extends Actor implements Serializable

serialVersionUID: -1375776678860848278L

Serialized Fields

remoteHost

RemoteHost remoteHost

Class groovyx.gpars.actor.Actor.RemoteActor.StopActorMsg extends SerialMsg implements Serializable

serialVersionUID: -927785591952534581L

Serialized Fields

actor

Actor actor

Class groovyx.gpars.actor.Actor.RemoteActor.TerminateActorMsg extends SerialMsg implements Serializable

serialVersionUID: -839334644951906974L

Serialized Fields

actor

Actor actor

Class groovyx.gpars.actor.ActorMessage extends java.lang.Object implements Serializable

serialVersionUID: -2925547808451571430L

Serialized Fields

payLoad

java.lang.Object payLoad

sender

MessageStream sender

Class groovyx.gpars.actor.DefaultActor extends AbstractLoopingActor implements Serializable

serialVersionUID: -439517926332934061L

Serialized Fields

nextContinuation

groovy.lang.Closure nextContinuation

loopClosure

groovy.lang.Closure loopClosure

loopCode

java.lang.Runnable loopCode

Misused also for the code to run at start-up

loopCondition

java.util.concurrent.Callable<V> loopCondition

afterLoopCode

groovy.lang.Closure afterLoopCode

started

boolean started

Class groovyx.gpars.actor.DefaultActorClosure extends groovy.lang.Closure implements Serializable

serialVersionUID: 3009666814957486672L

Serialized Fields

myActor

DefaultActor myActor

Class groovyx.gpars.actor.DefaultPooledActor extends AbstractPooledActor implements Serializable

Class groovyx.gpars.actor.DynamicDispatchActor extends AbstractLoopingActor implements Serializable

serialVersionUID: 2709208258556647529L

Class groovyx.gpars.actor.ReactiveActor extends AbstractLoopingActor implements Serializable

serialVersionUID: 2709208258556647528L

Package groovyx.gpars.actor.impl

Class groovyx.gpars.actor.impl.ActorContinuationException extends ActorException implements Serializable

serialVersionUID: -4978264308794524512L

Class groovyx.gpars.actor.impl.ActorException extends java.lang.RuntimeException implements Serializable

serialVersionUID: 1L

Class groovyx.gpars.actor.impl.ActorReplyException extends java.lang.RuntimeException implements Serializable

serialVersionUID: -3877063222143535104L

Serialized Fields

issues

java.util.List<E> issues

Class groovyx.gpars.actor.impl.ActorStopException extends ActorException implements Serializable

serialVersionUID: 6718779462386378739L

Class groovyx.gpars.actor.impl.ActorTerminationException extends ActorException implements Serializable

serialVersionUID: -1525695043073635315L

Class groovyx.gpars.actor.impl.ActorTimeoutException extends ActorException implements Serializable

serialVersionUID: 240177592831181888L

Class groovyx.gpars.actor.impl.MessageStream extends WithSerialId implements Serializable

serialVersionUID: 7644465423857532477L

Class groovyx.gpars.actor.impl.MessageStream.RemoteMessageStream extends MessageStream implements Serializable

serialVersionUID: 3936054469565089659L

Serialized Fields

remoteHost

RemoteHost remoteHost

Class groovyx.gpars.actor.impl.MessageStream.SendTo extends SerialMsg implements Serializable

serialVersionUID: 1989120447646342520L

Serialized Fields

to

MessageStream to

message

ActorMessage message

Class groovyx.gpars.actor.impl.ReplyingMessageStream extends Actor implements Serializable

serialVersionUID: -4660316352077009411L

Serialized Fields

senders

java.util.List<E> senders

A list of senders for the currently processed messages

obj2Sender

java.util.WeakHashMap<K,V> obj2Sender

Class groovyx.gpars.actor.impl.RunnableBackedPooledActor extends AbstractPooledActor implements Serializable

serialVersionUID: 8992135845484038961L

Serialized Fields

action

java.lang.Runnable action

Deprecated.

Class groovyx.gpars.actor.impl.SequentialProcessingActor extends ReplyingMessageStream implements Serializable

serialVersionUID: 6479220959200502418L

Serialized Fields

loopCode

java.lang.Runnable loopCode

Deprecated.

Code for the loop, if any

afterLoopCode

groovy.lang.Closure afterLoopCode

Deprecated.

loopCondition

java.util.concurrent.Callable<V> loopCondition

Deprecated.

reaction

SequentialProcessingActor.Reaction reaction

Deprecated.

Code for the next action

inputQueue

SequentialProcessingActor.Node inputQueue

Deprecated.

Stored incoming messages. The most recently received message is in the head of the list.

outputQueue

SequentialProcessingActor.Node outputQueue

Deprecated.

Stores messages ready for processing by the actor. The oldest message is in the head of the list. Messages are transferred from the inputQueue into the output queue in the transferQueues() method.

ongoingThreadTermination

java.util.concurrent.atomic.AtomicBoolean ongoingThreadTermination

Deprecated.

count

int count

Deprecated.

Counter of messages in the queues

waitingThread

java.lang.Thread waitingThread

Deprecated.

stopFlag

int stopFlag

Deprecated.

Indicates whether the actor should terminate

Package groovyx.gpars.dataflow

Class groovyx.gpars.dataflow.DataCallback extends MessageStream implements Serializable

serialVersionUID: 6512046150477794254L

Serialized Fields

code

groovy.lang.Closure code

parallelGroup

groovyx.gpars.group.PGroup parallelGroup

Class groovyx.gpars.dataflow.DataFlowComplexExpression extends DataFlowExpression<T> implements Serializable

serialVersionUID: 1527021112173826064L

Serialized Fields

args

java.lang.Object[] args

Class groovyx.gpars.dataflow.DataFlowExpression extends WithSerialId implements Serializable

serialVersionUID: 8961916630562820109L

Serialized Fields

metaClass

groovy.lang.MetaClass metaClass

The current metaclass

value

java.lang.Object value

Holds the actual value. Is null before a concrete value is bound to it.

state

int state

Holds the current state of the variable

waiting

DataFlowExpression.WaitingThread waiting

Points to the head of the chain of requests waiting for a value to be bound

Class groovyx.gpars.dataflow.DataFlowExpression.BindDataFlow extends SerialMsg implements Serializable

serialVersionUID: -8674023870562062769L

Serialized Fields

expr

DataFlowExpression<T> expr

message

java.lang.Object message

Class groovyx.gpars.dataflow.DataFlowGetPropertyExpression extends DataFlowExpression<T> implements Serializable

serialVersionUID: 2984824057556784227L

Serialized Fields

receiver

DataFlowExpression<T> receiver

name

java.lang.String name

Class groovyx.gpars.dataflow.DataFlowInvocationExpression extends DataFlowComplexExpression<java.lang.Object> implements Serializable

serialVersionUID: -678669663648650627L

Serialized Fields

receiver

java.lang.Object receiver

methodName

java.lang.String methodName

Class groovyx.gpars.dataflow.DataFlowVariable extends DataFlowExpression<T> implements Serializable

serialVersionUID: 1340439210749936258L

Class groovyx.gpars.dataflow.DataFlowVariable.RemoteDataFlowVariable extends DataFlowVariable<T> implements Serializable

serialVersionUID: -420013188758006693L

Serialized Fields

remoteHost

RemoteHost remoteHost

disconnected

boolean disconnected

Class groovyx.gpars.dataflow.RemoteDataFlowExpression extends DataFlowExpression<T> implements Serializable

serialVersionUID: -3166182949181062129L

Serialized Fields

remoteHost

RemoteHost remoteHost

Class groovyx.gpars.dataflow.SingleRunActor extends AbstractPooledActor implements Serializable

serialVersionUID: 516126583515361939L

Serialized Fields

body

groovy.lang.Closure body

Package groovyx.gpars.dataflow.impl

Class groovyx.gpars.dataflow.impl.SelectCallback extends groovy.lang.Closure implements Serializable

serialVersionUID: 5953873495199115151L

Serialized Fields

index

int index

channel

DataFlowReadChannel<T> channel

Package groovyx.gpars.memoize

Class groovyx.gpars.memoize.LRUProtectionStorage extends java.util.LinkedHashMap<java.lang.Object,java.lang.Object> implements Serializable

serialVersionUID: 1L

Serialized Fields

maxSize

int maxSize

Package groovyx.gpars.pa

Class groovyx.gpars.pa.CallClosure extends groovy.lang.Closure implements Serializable

serialVersionUID: 209099114666842715L

Serialized Fields

target

groovy.lang.Closure target

Class groovyx.gpars.pa.SumClosure extends groovy.lang.Closure implements Serializable

Package groovyx.gpars.remote.message

Class groovyx.gpars.remote.message.HostIdMsg extends SerialMsg implements Serializable

serialVersionUID: -7805772642034504624L

Class groovyx.gpars.remote.message.NodeConnectedMsg extends SerialMsg implements Serializable

serialVersionUID: -2198640646677794254L

Serialized Fields

nodeId

java.util.UUID nodeId

Id of node connected

mainActor

Actor mainActor

Class groovyx.gpars.remote.message.NodeDisconnectedMsg extends SerialMsg implements Serializable

serialVersionUID: 8082827710656359290L

Serialized Fields

nodeId

java.util.UUID nodeId

Id of node disconnected

Package groovyx.gpars.serial

Class groovyx.gpars.serial.DefaultRemoteHandle extends RemoteHandle implements Serializable

serialVersionUID: 3543416239144672233L

Serialized Fields

klazz

java.lang.Class<T> klazz

Class groovyx.gpars.serial.LocalHandle extends java.lang.Object implements Serializable

serialVersionUID: -8206894167996286304L

Serialization Methods

readResolve

protected java.lang.Object readResolve()

Serialized Fields

id

java.util.UUID id

Class groovyx.gpars.serial.RemoteHandle extends java.lang.Object implements Serializable

serialVersionUID: 1L

Serialization Methods

readResolve

protected final java.lang.Object readResolve()
                                      throws java.io.ObjectStreamException

Throws:

java.io.ObjectStreamException

Serialized Fields

serialId

java.util.UUID serialId

hostId

java.util.UUID hostId

Class groovyx.gpars.serial.SerialHandle.RemoteSerialHandle.ReleaseHandle extends SerialMsg implements Serializable

serialVersionUID: -951052191389868427L

Serialized Fields

serialId

java.util.UUID serialId

Class groovyx.gpars.serial.SerialMsg extends java.lang.Object implements Serializable

serialVersionUID: 1L

Serialized Fields

hostId

java.util.UUID hostId

Class groovyx.gpars.serial.WithSerialId extends java.lang.Object implements Serializable

serialVersionUID: 75514416530973469L

Serialization Methods

writeReplace

protected final java.lang.Object writeReplace()
                                       throws java.io.ObjectStreamException

Replace object by handle for serialization

Throws:

java.io.ObjectStreamException - If the object cannot be serialized

Serialized Fields

serialHandle

SerialHandle serialHandle

See SerialHandle class for details

Package groovyx.gpars.util

Class groovyx.gpars.util.EnhancedRWLock extends java.util.concurrent.locks.ReentrantReadWriteLock implements Serializable

serialVersionUID: 4598708242656870566L

Class groovyx.gpars.util.EnhancedSemaphore extends java.util.concurrent.Semaphore implements Serializable

serialVersionUID: 7582324169075000859L