Serialized Form

Package groovyx.gpars

Class groovyx.gpars.AbstractPAWrapper$_combine_closure4 extends java.lang.Object implements Serializable

Class groovyx.gpars.AbstractPAWrapper$_combine_closure5 extends java.lang.Object implements Serializable

Class groovyx.gpars.AbstractPAWrapper$_combineImpl_closure8 extends java.lang.Object implements Serializable

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.GParsExecutorsPool$_executeAsync_closure3 extends java.lang.Object implements Serializable

Class groovyx.gpars.GParsExecutorsPool$_executeAsync_closure3_closure5 extends java.lang.Object implements Serializable

Class groovyx.gpars.GParsExecutorsPool$_speculate_closure4 extends java.lang.Object implements Serializable

Class groovyx.gpars.GParsExecutorsPool$_speculate_closure4_closure6 extends java.lang.Object implements Serializable

Class groovyx.gpars.GParsExecutorsPool$_withExistingPool_closure2 extends java.lang.Object implements Serializable

Class groovyx.gpars.GParsExecutorsPoolEnhancer$_anyParallel_closure8 extends java.lang.Object implements Serializable

Class groovyx.gpars.GParsExecutorsPoolEnhancer$_collectParallel_closure3 extends java.lang.Object implements Serializable

Class groovyx.gpars.GParsExecutorsPoolEnhancer$_eachParallel_closure1 extends java.lang.Object implements Serializable

Class groovyx.gpars.GParsExecutorsPoolEnhancer$_eachWithIndexParallel_closure2 extends java.lang.Object implements Serializable

Class groovyx.gpars.GParsExecutorsPoolEnhancer$_everyParallel_closure7 extends java.lang.Object implements Serializable

Class groovyx.gpars.GParsExecutorsPoolEnhancer$_findAllParallel_closure4 extends java.lang.Object implements Serializable

Class groovyx.gpars.GParsExecutorsPoolEnhancer$_findParallel_closure6 extends java.lang.Object implements Serializable

Class groovyx.gpars.GParsExecutorsPoolEnhancer$_grepParallel_closure5 extends java.lang.Object implements Serializable

Class groovyx.gpars.GParsExecutorsPoolEnhancer$_groupByParallel_closure9 extends java.lang.Object implements Serializable

Class groovyx.gpars.GParsExecutorsPoolUtil$_anyParallel_closure16 extends java.lang.Object implements Serializable

Class groovyx.gpars.GParsExecutorsPoolUtil$_async_closure3 extends java.lang.Object implements Serializable

Class groovyx.gpars.GParsExecutorsPoolUtil$_asyncFun_closure4 extends java.lang.Object implements Serializable

Class groovyx.gpars.GParsExecutorsPoolUtil$_callAsync_closure1 extends java.lang.Object implements Serializable

Class groovyx.gpars.GParsExecutorsPoolUtil$_callTimeoutAsync_closure2 extends java.lang.Object implements Serializable

Class groovyx.gpars.GParsExecutorsPoolUtil$_eachParallel_closure5 extends java.lang.Object implements Serializable

Class groovyx.gpars.GParsExecutorsPoolUtil$_eachWithIndexParallel_closure6 extends java.lang.Object implements Serializable

Class groovyx.gpars.GParsExecutorsPoolUtil$_everyParallel_closure15 extends java.lang.Object implements Serializable

Class groovyx.gpars.GParsExecutorsPoolUtil$_findAllParallel_closure7 extends java.lang.Object implements Serializable

Class groovyx.gpars.GParsExecutorsPoolUtil$_findAnyParallel_closure13 extends java.lang.Object implements Serializable

Class groovyx.gpars.GParsExecutorsPoolUtil$_findParallel_closure11 extends java.lang.Object implements Serializable

Class groovyx.gpars.GParsExecutorsPoolUtil$_grepParallel_closure9 extends java.lang.Object implements Serializable

Class groovyx.gpars.GParsExecutorsPoolUtil$_groupByParallel_closure17 extends java.lang.Object implements Serializable

Class groovyx.gpars.GParsExecutorsPoolUtil$_processResult_closure18 extends java.lang.Object implements Serializable

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.GParsPool$_executeAsync_closure2 extends java.lang.Object implements Serializable

Class groovyx.gpars.GParsPool$_speculate_closure3 extends java.lang.Object implements Serializable

Class groovyx.gpars.GParsPool$_speculate_closure3_closure5 extends java.lang.Object implements Serializable

Class groovyx.gpars.GParsPool$_withExistingPool_closure1 extends java.lang.Object implements Serializable

Class groovyx.gpars.GParsPoolUtil$_anyParallel_closure17 extends java.lang.Object implements Serializable

Class groovyx.gpars.GParsPoolUtil$_anyParallel_closure18 extends java.lang.Object implements Serializable

Class groovyx.gpars.GParsPoolUtil$_anyParallel_closure19 extends java.lang.Object implements Serializable

Class groovyx.gpars.GParsPoolUtil$_async_closure3 extends java.lang.Object implements Serializable

Class groovyx.gpars.GParsPoolUtil$_asyncFun_closure4 extends java.lang.Object implements Serializable

Class groovyx.gpars.GParsPoolUtil$_buildMemoizeFunction_closure5 extends java.lang.Object implements Serializable

Class groovyx.gpars.GParsPoolUtil$_buildSoftReferenceMemoizeFunction_closure6 extends java.lang.Object implements Serializable

Class groovyx.gpars.GParsPoolUtil$_callAsync_closure1 extends java.lang.Object implements Serializable

Class groovyx.gpars.GParsPoolUtil$_callTimeoutAsync_closure2 extends java.lang.Object implements Serializable

Class groovyx.gpars.GParsPoolUtil$_cleanUpNullReferences_closure8 extends java.lang.Object implements Serializable

Class groovyx.gpars.GParsPoolUtil$_countParallel_closure15 extends java.lang.Object implements Serializable

Class groovyx.gpars.GParsPoolUtil$_countParallel_closure16 extends java.lang.Object implements Serializable

Class groovyx.gpars.GParsPoolUtil$_eachParallelPA_closure9 extends java.lang.Object implements Serializable

Class groovyx.gpars.GParsPoolUtil$_eachWithIndexParallel_closure10 extends java.lang.Object implements Serializable

Class groovyx.gpars.GParsPoolUtil$_everyParallel_closure20 extends java.lang.Object implements Serializable

Class groovyx.gpars.GParsPoolUtil$_everyParallel_closure21 extends java.lang.Object implements Serializable

Class groovyx.gpars.GParsPoolUtil$_everyParallel_closure22 extends java.lang.Object implements Serializable

Class groovyx.gpars.GParsPoolUtil$_findAllParallelPA_closure11 extends java.lang.Object implements Serializable

Class groovyx.gpars.GParsPoolUtil$_findAnyParallelPA_closure13 extends java.lang.Object implements Serializable

Class groovyx.gpars.GParsPoolUtil$_findParallelPA_closure12 extends java.lang.Object implements Serializable

Class groovyx.gpars.GParsPoolUtil$_grepParallelPA_closure14 extends java.lang.Object implements Serializable

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

serialVersionUID: 4796783310470426395L

Class groovyx.gpars.Parallel$_anyParallel_closure11 extends java.lang.Object implements Serializable

Class groovyx.gpars.Parallel$_collectParallel_closure3 extends java.lang.Object implements Serializable

Class groovyx.gpars.Parallel$_countParallel_closure7 extends java.lang.Object implements Serializable

Class groovyx.gpars.Parallel$_eachParallel_closure1 extends java.lang.Object implements Serializable

Class groovyx.gpars.Parallel$_eachWithIndexParallel_closure2 extends java.lang.Object implements Serializable

Class groovyx.gpars.Parallel$_everyParallel_closure10 extends java.lang.Object implements Serializable

Class groovyx.gpars.Parallel$_findAllParallel_closure4 extends java.lang.Object implements Serializable

Class groovyx.gpars.Parallel$_findAnyParallel_closure9 extends java.lang.Object implements Serializable

Class groovyx.gpars.Parallel$_findParallel_closure8 extends java.lang.Object implements Serializable

Class groovyx.gpars.Parallel$_foldParallel_closure18 extends java.lang.Object implements Serializable

Class groovyx.gpars.Parallel$_foldParallel_closure19 extends java.lang.Object implements Serializable

Class groovyx.gpars.Parallel$_grepParallel_closure5 extends java.lang.Object implements Serializable

Class groovyx.gpars.Parallel$_groupByParallel_closure12 extends java.lang.Object implements Serializable

Class groovyx.gpars.Parallel$_maxParallel_closure15 extends java.lang.Object implements Serializable

Class groovyx.gpars.Parallel$_minParallel_closure13 extends java.lang.Object implements Serializable

Class groovyx.gpars.Parallel$_splitParallel_closure6 extends java.lang.Object implements Serializable

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

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.BlockingActor extends SequentialProcessingActor implements Serializable

serialVersionUID: -6232655362494852540L

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.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.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.DDAClosure$_createDDAClosure_closure1 extends java.lang.Object implements Serializable

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 code

parallelGroup

groovyx.gpars.group.PGroup parallelGroup

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

serialVersionUID: 6512046150477794254L

Serialized Fields

code

groovy.lang.Closure code

pool

Pool pool

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

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

Class groovyx.gpars.group.PGroup$_task_closure1 extends java.lang.Object implements Serializable

Class groovyx.gpars.group.PGroup$_task_closure2 extends java.lang.Object implements Serializable

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