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.GParsPool.MyCancellableRecursiveTask extends jsr166y.RecursiveTask implements Serializable

Serialized Fields

code

java.lang.Object code

myThread

java.lang.Thread myThread

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.activeobject

Class groovyx.gpars.activeobject.InternalActor extends AbstractLoopingActor implements Serializable

serialVersionUID: 6700367864074699984L

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.Actor extends MessageStream implements Serializable

serialVersionUID: -3491276479442857422L

Serialized Fields

joinLatch

DataflowExpression<T> joinLatch

parallelGroup

PGroup parallelGroup

The parallel group to which the message stream belongs

onStop

groovy.lang.Closure<V> 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.BlockingActor extends SequentialProcessingActor implements Serializable

serialVersionUID: -6232655362494852540L

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

serialVersionUID: -439517926332934061L

Serialized Fields

nextContinuation

groovy.lang.Closure<V> nextContinuation

loopClosure

groovy.lang.Closure<V> 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<V> 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.DynamicDispatchActor extends AbstractLoopingActor implements Serializable

serialVersionUID: 2709208258556647529L

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

serialVersionUID: 2709208258556647528L

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

serialVersionUID: 2709208258556647529L

Package groovyx.gpars.actor.impl

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.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

sender

MessageStream sender

A list of senders for the currently processed messages

Class groovyx.gpars.actor.impl.RunnableBackedBlockingActor extends BlockingActor implements Serializable

serialVersionUID: 8992135845484038961L

Serialized Fields

action

java.lang.Runnable action

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

serialVersionUID: 6479220959200502418L

Serialized Fields

inputQueue

SequentialProcessingActor.Node inputQueue

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

outputQueue

SequentialProcessingActor.Node outputQueue

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

waitingThread

java.lang.Thread waitingThread

stopFlag

int stopFlag

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<V> code

parallelGroup

PGroup parallelGroup

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

serialVersionUID: 6512046150477794254L

Serialized Fields

code

groovy.lang.Closure<V> code

pool

Pool pool

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.SyncDataflowVariable extends DataflowVariable<T> implements Serializable

Serialized Fields

parties

ResizeableCountDownLatch parties

Package groovyx.gpars.dataflow.expression

Class groovyx.gpars.dataflow.expression.DataflowComplexExpression extends DataflowExpression<T> implements Serializable

serialVersionUID: 1527021112173826064L

Serialized Fields

args

java.lang.Object[] args

Class groovyx.gpars.dataflow.expression.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.

error

java.lang.Throwable error

state

java.util.concurrent.atomic.AtomicInteger state

Holds the current state of the variable

waiting

java.util.concurrent.atomic.AtomicReference<V> waiting

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

eventManager

DataflowChannelEventOrchestrator<T> eventManager

Class groovyx.gpars.dataflow.expression.DataflowExpression.BindDataflow extends SerialMsg implements Serializable

serialVersionUID: -8674023870562062769L

Serialized Fields

expr

DataflowExpression<T> expr

message

java.lang.Object message

Class groovyx.gpars.dataflow.expression.DataflowGetPropertyExpression extends DataflowExpression<T> implements Serializable

serialVersionUID: 2984824057556784227L

Serialized Fields

receiver

DataflowExpression<T> receiver

name

java.lang.String name

Class groovyx.gpars.dataflow.expression.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.expression.RemoteDataflowExpression extends DataflowExpression<T> implements Serializable

serialVersionUID: -3166182949181062129L

Serialized Fields

remoteHost

RemoteHost remoteHost

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

Class groovyx.gpars.dataflow.impl.ThenMessagingRunnable extends MessagingRunnable<T> implements Serializable

Serialized Fields

result

DataflowVariable<T> result

closure

groovy.lang.Closure<V> closure

errorHandler

groovy.lang.Closure<V> errorHandler

Package groovyx.gpars.dataflow.operator

Class groovyx.gpars.dataflow.operator.BinaryChoiceClosure extends groovy.lang.Closure<java.lang.Void> implements Serializable

Serialized Fields

code

groovy.lang.Closure<V> code

Class groovyx.gpars.dataflow.operator.CopyChannelsClosure extends groovy.lang.Closure implements Serializable

Class groovyx.gpars.dataflow.operator.DataflowProcessorAtomicBoundAllClosure extends groovy.lang.Closure implements Serializable

Class groovyx.gpars.dataflow.operator.FilterClosure extends groovy.lang.Closure implements Serializable

Serialized Fields

wiseMan

groovy.lang.Closure<V> wiseMan

Class groovyx.gpars.dataflow.operator.ChainWithClosure extends groovy.lang.Closure implements Serializable

Serialized Fields

code

groovy.lang.Closure<V> code

Class groovyx.gpars.dataflow.operator.ChoiceClosure extends groovy.lang.Closure<java.lang.Void> implements Serializable

Serialized Fields

code

groovy.lang.Closure<V> code

Class groovyx.gpars.dataflow.operator.SeparationClosure extends groovy.lang.Closure<java.lang.Void> implements Serializable

Serialized Fields

code

groovy.lang.Closure<V> code

Package groovyx.gpars.extra166y

Class groovyx.gpars.extra166y.CustomConcurrentHashMap extends java.util.AbstractMap<K,V> implements Serializable

serialVersionUID: 7249069246764182397L

Serialization Methods

readObject

private void readObject(java.io.ObjectInputStream s)
                 throws java.io.IOException,
                        java.lang.ClassNotFoundException

Reconstitutes the instance from a stream (that is, deserializes it).

Throws:

java.io.IOException

java.lang.ClassNotFoundException

writeObject

private void writeObject(java.io.ObjectOutputStream s)
                  throws java.io.IOException

Saves the state of the instance to a stream (i.e., serializes it).

Serial Data:

the key (Object) and value (Object) for each key-value mapping, followed by a null pair. The key-value mappings are emitted in no particular order.

Throws:

java.io.IOException

Serialized Fields

factory

CustomConcurrentHashMap.NodeFactory factory

The factory for this map

keyEquivalence

CustomConcurrentHashMap.Equivalence<K> keyEquivalence

Equivalence object for keys

valueEquivalence

CustomConcurrentHashMap.Equivalence<K> valueEquivalence

Equivalence object for values

initialSegmentCapacity

int initialSegmentCapacity

The initial size of Segment tables when they are first constructed

Class groovyx.gpars.extra166y.CustomConcurrentHashMap.KeySet extends java.util.AbstractSet<K> implements Serializable

Serialized Fields

cchm

CustomConcurrentHashMap<K,V> cchm

Package groovyx.gpars.forkjoin

Class groovyx.gpars.forkjoin.AbstractForkJoinWorker extends jsr166y.RecursiveTask<T> implements Serializable

Serialized Fields

children

java.util.List<E> children

Stores the child workers

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.CallAsyncTask extends jsr166y.RecursiveTask<V> implements Serializable

Serialized Fields

code

groovy.lang.Closure<V> code

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

serialVersionUID: 209099114666842715L

Serialized Fields

target

groovy.lang.Closure<V> target

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

serialVersionUID: 209099114666842715L

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