org.codehaus.gpars
A B C D E F G H I J K L M N O P Q R S T U V W X Y Z _

A

a - Field in PAS.FJDCMerger
a - Field in PAS.FJDCSorter
a - Field in PAS.FJDMerger
a - Field in PAS.FJDSorter
a - Field in PAS.FJLCMerger
a - Field in PAS.FJLCSorter
a - Field in PAS.FJLMerger
a - Field in PAS.FJLSorter
a - Field in PAS.FJOCMerger
a - Field in PAS.FJOCSorter
a - Field in PAS.FJOMerger
a - Field in PAS.FJOSorter
A_SPLITTER_NEEDS_AN_INPUT_CHANNEL_AND_AT_LEAST_ONE_OUTPUT_CHANNEL_TO_BE_CREATED - Field in PGroup
AbstractForkJoinWorker - Class in groovyx.gpars.forkjoin
Implements the ForkJoin worker contract.
AbstractForkJoinWorker() - Constructor in AbstractForkJoinWorker
AbstractLoopingActor - Class in groovyx.gpars.actor
Wraps all actors that repeatedly loop through incoming messages and hold no implicit state between subsequent messages.
AbstractLoopingActor() - Constructor in AbstractLoopingActor
AbstractParallelAnyArray - Class in groovyx.gpars.extra166y
Abstract class serving as the basis of parallel array classes across types.
AbstractParallelAnyArray.AndPredicate - Class in groovyx.gpars.extra166y
AbstractParallelAnyArray.AndPredicate(Predicate, Predicate) - Constructor in AbstractParallelAnyArray.AndPredicate
AbstractParallelAnyArray.DDCPap - Class in groovyx.gpars.extra166y
AbstractParallelAnyArray.DDCPap(ForkJoinPool, int, int, double[], IntAndDoubleToDouble) - Constructor in AbstractParallelAnyArray.DDCPap
AbstractParallelAnyArray.DDMPap - Class in groovyx.gpars.extra166y
AbstractParallelAnyArray.DDMPap(ForkJoinPool, int, int, double[], DoubleOp) - Constructor in AbstractParallelAnyArray.DDMPap
AbstractParallelAnyArray.DFDCPap - Class in groovyx.gpars.extra166y
AbstractParallelAnyArray.DFDCPap(ForkJoinPool, int, int, double[], DoublePredicate, IntAndDoubleToDouble) - Constructor in AbstractParallelAnyArray.DFDCPap
AbstractParallelAnyArray.DFDMPap - Class in groovyx.gpars.extra166y
AbstractParallelAnyArray.DFDMPap(ForkJoinPool, int, int, double[], DoublePredicate, DoubleOp) - Constructor in AbstractParallelAnyArray.DFDMPap
AbstractParallelAnyArray.DFLCPap - Class in groovyx.gpars.extra166y
AbstractParallelAnyArray.DFLCPap(ForkJoinPool, int, int, double[], DoublePredicate, IntAndDoubleToLong) - Constructor in AbstractParallelAnyArray.DFLCPap
AbstractParallelAnyArray.DFLMPap - Class in groovyx.gpars.extra166y
AbstractParallelAnyArray.DFLMPap(ForkJoinPool, int, int, double[], DoublePredicate, DoubleToLong) - Constructor in AbstractParallelAnyArray.DFLMPap
AbstractParallelAnyArray.DFOCPap - Class in groovyx.gpars.extra166y
AbstractParallelAnyArray.DFOCPap(ForkJoinPool, int, int, double[], DoublePredicate, IntAndDoubleToObject) - Constructor in AbstractParallelAnyArray.DFOCPap
AbstractParallelAnyArray.DFOMPap - Class in groovyx.gpars.extra166y
AbstractParallelAnyArray.DFOMPap(ForkJoinPool, int, int, double[], DoublePredicate, DoubleToObject) - Constructor in AbstractParallelAnyArray.DFOMPap
AbstractParallelAnyArray.DFPap - Class in groovyx.gpars.extra166y
AbstractParallelAnyArray.DFPap(ForkJoinPool, int, int, double[], DoublePredicate) - Constructor in AbstractParallelAnyArray.DFPap
AbstractParallelAnyArray.DLCPap - Class in groovyx.gpars.extra166y
AbstractParallelAnyArray.DLCPap(ForkJoinPool, int, int, double[], IntAndDoubleToLong) - Constructor in AbstractParallelAnyArray.DLCPap
AbstractParallelAnyArray.DLMPap - Class in groovyx.gpars.extra166y
AbstractParallelAnyArray.DLMPap(ForkJoinPool, int, int, double[], DoubleToLong) - Constructor in AbstractParallelAnyArray.DLMPap
AbstractParallelAnyArray.DOCPap - Class in groovyx.gpars.extra166y
AbstractParallelAnyArray.DOCPap(ForkJoinPool, int, int, double[], IntAndDoubleToObject) - Constructor in AbstractParallelAnyArray.DOCPap
AbstractParallelAnyArray.DOMPap - Class in groovyx.gpars.extra166y
AbstractParallelAnyArray.DOMPap(ForkJoinPool, int, int, double[], DoubleToObject) - Constructor in AbstractParallelAnyArray.DOMPap
AbstractParallelAnyArray.DPap - Class in groovyx.gpars.extra166y
AbstractParallelAnyArray.DPap(ForkJoinPool, int, int, double[]) - Constructor in AbstractParallelAnyArray.DPap
AbstractParallelAnyArray.DRDCPap - Class in groovyx.gpars.extra166y
AbstractParallelAnyArray.DRDCPap(ForkJoinPool, int, int, double[], IntAndDoublePredicate, IntAndDoubleToDouble) - Constructor in AbstractParallelAnyArray.DRDCPap
AbstractParallelAnyArray.DRDMPap - Class in groovyx.gpars.extra166y
AbstractParallelAnyArray.DRDMPap(ForkJoinPool, int, int, double[], IntAndDoublePredicate, DoubleOp) - Constructor in AbstractParallelAnyArray.DRDMPap
AbstractParallelAnyArray.DRLCPap - Class in groovyx.gpars.extra166y
AbstractParallelAnyArray.DRLCPap(ForkJoinPool, int, int, double[], IntAndDoublePredicate, IntAndDoubleToLong) - Constructor in AbstractParallelAnyArray.DRLCPap
AbstractParallelAnyArray.DRLMPap - Class in groovyx.gpars.extra166y
AbstractParallelAnyArray.DRLMPap(ForkJoinPool, int, int, double[], IntAndDoublePredicate, DoubleToLong) - Constructor in AbstractParallelAnyArray.DRLMPap
AbstractParallelAnyArray.DROCPap - Class in groovyx.gpars.extra166y
AbstractParallelAnyArray.DROCPap(ForkJoinPool, int, int, double[], IntAndDoublePredicate, IntAndDoubleToObject) - Constructor in AbstractParallelAnyArray.DROCPap
AbstractParallelAnyArray.DROMPap - Class in groovyx.gpars.extra166y
AbstractParallelAnyArray.DROMPap(ForkJoinPool, int, int, double[], IntAndDoublePredicate, DoubleToObject) - Constructor in AbstractParallelAnyArray.DROMPap
AbstractParallelAnyArray.DRPap - Class in groovyx.gpars.extra166y
AbstractParallelAnyArray.DRPap(ForkJoinPool, int, int, double[], IntAndDoublePredicate) - Constructor in AbstractParallelAnyArray.DRPap
AbstractParallelAnyArray.DUDCPap - Class in groovyx.gpars.extra166y
AbstractParallelAnyArray.DUDCPap(ForkJoinPool, int, int, double[], IntAndDoubleToDouble) - Constructor in AbstractParallelAnyArray.DUDCPap
AbstractParallelAnyArray.DUDMPap - Class in groovyx.gpars.extra166y
AbstractParallelAnyArray.DUDMPap(ForkJoinPool, int, int, double[], DoubleOp) - Constructor in AbstractParallelAnyArray.DUDMPap
AbstractParallelAnyArray.DULCPap - Class in groovyx.gpars.extra166y
AbstractParallelAnyArray.DULCPap(ForkJoinPool, int, int, double[], IntAndDoubleToLong) - Constructor in AbstractParallelAnyArray.DULCPap
AbstractParallelAnyArray.DULMPap - Class in groovyx.gpars.extra166y
AbstractParallelAnyArray.DULMPap(ForkJoinPool, int, int, double[], DoubleToLong) - Constructor in AbstractParallelAnyArray.DULMPap
AbstractParallelAnyArray.DUOCPap - Class in groovyx.gpars.extra166y
AbstractParallelAnyArray.DUOCPap(ForkJoinPool, int, int, double[], IntAndDoubleToObject) - Constructor in AbstractParallelAnyArray.DUOCPap
AbstractParallelAnyArray.DUOMPap - Class in groovyx.gpars.extra166y
AbstractParallelAnyArray.DUOMPap(ForkJoinPool, int, int, double[], DoubleToObject) - Constructor in AbstractParallelAnyArray.DUOMPap
AbstractParallelAnyArray.DUPap - Class in groovyx.gpars.extra166y
AbstractParallelAnyArray.DUPap(ForkJoinPool, int, int, double[]) - Constructor in AbstractParallelAnyArray.DUPap
AbstractParallelAnyArray.FilteredAsDoubleIterator - Class in groovyx.gpars.extra166y
AbstractParallelAnyArray.FilteredAsDoubleIterator() - Constructor in AbstractParallelAnyArray.FilteredAsDoubleIterator
AbstractParallelAnyArray.FilteredAsLongIterator - Class in groovyx.gpars.extra166y
AbstractParallelAnyArray.FilteredAsLongIterator() - Constructor in AbstractParallelAnyArray.FilteredAsLongIterator
AbstractParallelAnyArray.FilteredIterator - Class in groovyx.gpars.extra166y
AbstractParallelAnyArray.FilteredIterator() - Constructor in AbstractParallelAnyArray.FilteredIterator
AbstractParallelAnyArray.LDCPap - Class in groovyx.gpars.extra166y
AbstractParallelAnyArray.LDCPap(ForkJoinPool, int, int, long[], IntAndLongToDouble) - Constructor in AbstractParallelAnyArray.LDCPap
AbstractParallelAnyArray.LDMPap - Class in groovyx.gpars.extra166y
AbstractParallelAnyArray.LDMPap(ForkJoinPool, int, int, long[], LongToDouble) - Constructor in AbstractParallelAnyArray.LDMPap
AbstractParallelAnyArray.LFDCPap - Class in groovyx.gpars.extra166y
AbstractParallelAnyArray.LFDCPap(ForkJoinPool, int, int, long[], LongPredicate, IntAndLongToDouble) - Constructor in AbstractParallelAnyArray.LFDCPap
AbstractParallelAnyArray.LFDMPap - Class in groovyx.gpars.extra166y
AbstractParallelAnyArray.LFDMPap(ForkJoinPool, int, int, long[], LongPredicate, LongToDouble) - Constructor in AbstractParallelAnyArray.LFDMPap
AbstractParallelAnyArray.LFLCPap - Class in groovyx.gpars.extra166y
AbstractParallelAnyArray.LFLCPap(ForkJoinPool, int, int, long[], LongPredicate, IntAndLongToLong) - Constructor in AbstractParallelAnyArray.LFLCPap
AbstractParallelAnyArray.LFLMPap - Class in groovyx.gpars.extra166y
AbstractParallelAnyArray.LFLMPap(ForkJoinPool, int, int, long[], LongPredicate, LongOp) - Constructor in AbstractParallelAnyArray.LFLMPap
AbstractParallelAnyArray.LFOCPap - Class in groovyx.gpars.extra166y
AbstractParallelAnyArray.LFOCPap(ForkJoinPool, int, int, long[], LongPredicate, IntAndLongToObject) - Constructor in AbstractParallelAnyArray.LFOCPap
AbstractParallelAnyArray.LFOMPap - Class in groovyx.gpars.extra166y
AbstractParallelAnyArray.LFOMPap(ForkJoinPool, int, int, long[], LongPredicate, LongToObject) - Constructor in AbstractParallelAnyArray.LFOMPap
AbstractParallelAnyArray.LFPap - Class in groovyx.gpars.extra166y
AbstractParallelAnyArray.LFPap(ForkJoinPool, int, int, long[], LongPredicate) - Constructor in AbstractParallelAnyArray.LFPap
AbstractParallelAnyArray.LLCPap - Class in groovyx.gpars.extra166y
AbstractParallelAnyArray.LLCPap(ForkJoinPool, int, int, long[], IntAndLongToLong) - Constructor in AbstractParallelAnyArray.LLCPap
AbstractParallelAnyArray.LLMPap - Class in groovyx.gpars.extra166y
AbstractParallelAnyArray.LLMPap(ForkJoinPool, int, int, long[], LongOp) - Constructor in AbstractParallelAnyArray.LLMPap
AbstractParallelAnyArray.LOCPap - Class in groovyx.gpars.extra166y
AbstractParallelAnyArray.LOCPap(ForkJoinPool, int, int, long[], IntAndLongToObject) - Constructor in AbstractParallelAnyArray.LOCPap
AbstractParallelAnyArray.LOMPap - Class in groovyx.gpars.extra166y
AbstractParallelAnyArray.LOMPap(ForkJoinPool, int, int, long[], LongToObject) - Constructor in AbstractParallelAnyArray.LOMPap
AbstractParallelAnyArray.LPap - Class in groovyx.gpars.extra166y
AbstractParallelAnyArray.LPap(ForkJoinPool, int, int, long[]) - Constructor in AbstractParallelAnyArray.LPap
AbstractParallelAnyArray.LRDCPap - Class in groovyx.gpars.extra166y
AbstractParallelAnyArray.LRDCPap(ForkJoinPool, int, int, long[], IntAndLongPredicate, IntAndLongToDouble) - Constructor in AbstractParallelAnyArray.LRDCPap
AbstractParallelAnyArray.LRDMPap - Class in groovyx.gpars.extra166y
AbstractParallelAnyArray.LRDMPap(ForkJoinPool, int, int, long[], IntAndLongPredicate, LongToDouble) - Constructor in AbstractParallelAnyArray.LRDMPap
AbstractParallelAnyArray.LRLCPap - Class in groovyx.gpars.extra166y
AbstractParallelAnyArray.LRLCPap(ForkJoinPool, int, int, long[], IntAndLongPredicate, IntAndLongToLong) - Constructor in AbstractParallelAnyArray.LRLCPap
AbstractParallelAnyArray.LRLMPap - Class in groovyx.gpars.extra166y
AbstractParallelAnyArray.LRLMPap(ForkJoinPool, int, int, long[], IntAndLongPredicate, LongOp) - Constructor in AbstractParallelAnyArray.LRLMPap
AbstractParallelAnyArray.LROCPap - Class in groovyx.gpars.extra166y
AbstractParallelAnyArray.LROCPap(ForkJoinPool, int, int, long[], IntAndLongPredicate, IntAndLongToObject) - Constructor in AbstractParallelAnyArray.LROCPap
AbstractParallelAnyArray.LROMPap - Class in groovyx.gpars.extra166y
AbstractParallelAnyArray.LROMPap(ForkJoinPool, int, int, long[], IntAndLongPredicate, LongToObject) - Constructor in AbstractParallelAnyArray.LROMPap
AbstractParallelAnyArray.LRPap - Class in groovyx.gpars.extra166y
AbstractParallelAnyArray.LRPap(ForkJoinPool, int, int, long[], IntAndLongPredicate) - Constructor in AbstractParallelAnyArray.LRPap
AbstractParallelAnyArray.LUDCPap - Class in groovyx.gpars.extra166y
AbstractParallelAnyArray.LUDCPap(ForkJoinPool, int, int, long[], IntAndLongToDouble) - Constructor in AbstractParallelAnyArray.LUDCPap
AbstractParallelAnyArray.LUDMPap - Class in groovyx.gpars.extra166y
AbstractParallelAnyArray.LUDMPap(ForkJoinPool, int, int, long[], LongToDouble) - Constructor in AbstractParallelAnyArray.LUDMPap
AbstractParallelAnyArray.LULCPap - Class in groovyx.gpars.extra166y
AbstractParallelAnyArray.LULCPap(ForkJoinPool, int, int, long[], IntAndLongToLong) - Constructor in AbstractParallelAnyArray.LULCPap
AbstractParallelAnyArray.LULMPap - Class in groovyx.gpars.extra166y
AbstractParallelAnyArray.LULMPap(ForkJoinPool, int, int, long[], LongOp) - Constructor in AbstractParallelAnyArray.LULMPap
AbstractParallelAnyArray.LUOCPap - Class in groovyx.gpars.extra166y
AbstractParallelAnyArray.LUOCPap(ForkJoinPool, int, int, long[], IntAndLongToObject) - Constructor in AbstractParallelAnyArray.LUOCPap
AbstractParallelAnyArray.LUOMPap - Class in groovyx.gpars.extra166y
AbstractParallelAnyArray.LUOMPap(ForkJoinPool, int, int, long[], LongToObject) - Constructor in AbstractParallelAnyArray.LUOMPap
AbstractParallelAnyArray.LUPap - Class in groovyx.gpars.extra166y
AbstractParallelAnyArray.LUPap(ForkJoinPool, int, int, long[]) - Constructor in AbstractParallelAnyArray.LUPap
AbstractParallelAnyArray.ODCPap - Class in groovyx.gpars.extra166y
AbstractParallelAnyArray.ODCPap(ForkJoinPool, int, int, Object, IntAndObjectToDouble) - Constructor in AbstractParallelAnyArray.ODCPap
AbstractParallelAnyArray.ODMPap - Class in groovyx.gpars.extra166y
AbstractParallelAnyArray.ODMPap(ForkJoinPool, int, int, Object, ObjectToDouble) - Constructor in AbstractParallelAnyArray.ODMPap
AbstractParallelAnyArray.OFDCPap - Class in groovyx.gpars.extra166y
AbstractParallelAnyArray.OFDCPap(ForkJoinPool, int, int, Object, Predicate, IntAndObjectToDouble) - Constructor in AbstractParallelAnyArray.OFDCPap
AbstractParallelAnyArray.OFDMPap - Class in groovyx.gpars.extra166y
AbstractParallelAnyArray.OFDMPap(ForkJoinPool, int, int, Object, Predicate, ObjectToDouble) - Constructor in AbstractParallelAnyArray.OFDMPap
AbstractParallelAnyArray.OFLCPap - Class in groovyx.gpars.extra166y
AbstractParallelAnyArray.OFLCPap(ForkJoinPool, int, int, Object, Predicate, IntAndObjectToLong) - Constructor in AbstractParallelAnyArray.OFLCPap
AbstractParallelAnyArray.OFLMPap - Class in groovyx.gpars.extra166y
AbstractParallelAnyArray.OFLMPap(ForkJoinPool, int, int, Object, Predicate, ObjectToLong) - Constructor in AbstractParallelAnyArray.OFLMPap
AbstractParallelAnyArray.OFOCPap - Class in groovyx.gpars.extra166y
AbstractParallelAnyArray.OFOCPap(ForkJoinPool, int, int, Object, Predicate, IntAndObjectToObject) - Constructor in AbstractParallelAnyArray.OFOCPap
AbstractParallelAnyArray.OFOMPap - Class in groovyx.gpars.extra166y
AbstractParallelAnyArray.OFOMPap(ForkJoinPool, int, int, Object, Predicate, Op) - Constructor in AbstractParallelAnyArray.OFOMPap
AbstractParallelAnyArray.OFPap - Class in groovyx.gpars.extra166y
AbstractParallelAnyArray.OFPap(ForkJoinPool, int, int, Object, Predicate) - Constructor in AbstractParallelAnyArray.OFPap
AbstractParallelAnyArray.OLCPap - Class in groovyx.gpars.extra166y
AbstractParallelAnyArray.OLCPap(ForkJoinPool, int, int, Object, IntAndObjectToLong) - Constructor in AbstractParallelAnyArray.OLCPap
AbstractParallelAnyArray.OLMPap - Class in groovyx.gpars.extra166y
AbstractParallelAnyArray.OLMPap(ForkJoinPool, int, int, Object, ObjectToLong) - Constructor in AbstractParallelAnyArray.OLMPap
AbstractParallelAnyArray.OOCPap - Class in groovyx.gpars.extra166y
AbstractParallelAnyArray.OOCPap(ForkJoinPool, int, int, Object, IntAndObjectToObject) - Constructor in AbstractParallelAnyArray.OOCPap
AbstractParallelAnyArray.OOMPap - Class in groovyx.gpars.extra166y
AbstractParallelAnyArray.OOMPap(ForkJoinPool, int, int, Object, Op) - Constructor in AbstractParallelAnyArray.OOMPap
AbstractParallelAnyArray.OPap - Class in groovyx.gpars.extra166y
AbstractParallelAnyArray.OPap(ForkJoinPool, int, int, Object) - Constructor in AbstractParallelAnyArray.OPap
AbstractParallelAnyArray.ORDCPap - Class in groovyx.gpars.extra166y
AbstractParallelAnyArray.ORDCPap(ForkJoinPool, int, int, Object, IntAndObjectPredicate, IntAndObjectToDouble) - Constructor in AbstractParallelAnyArray.ORDCPap
AbstractParallelAnyArray.ORDMPap - Class in groovyx.gpars.extra166y
AbstractParallelAnyArray.ORDMPap(ForkJoinPool, int, int, Object, IntAndObjectPredicate, ObjectToDouble) - Constructor in AbstractParallelAnyArray.ORDMPap
AbstractParallelAnyArray.ORLCPap - Class in groovyx.gpars.extra166y
AbstractParallelAnyArray.ORLCPap(ForkJoinPool, int, int, Object, IntAndObjectPredicate, IntAndObjectToLong) - Constructor in AbstractParallelAnyArray.ORLCPap
AbstractParallelAnyArray.ORLMPap - Class in groovyx.gpars.extra166y
AbstractParallelAnyArray.ORLMPap(ForkJoinPool, int, int, Object, IntAndObjectPredicate, ObjectToLong) - Constructor in AbstractParallelAnyArray.ORLMPap
AbstractParallelAnyArray.OROCPap - Class in groovyx.gpars.extra166y
AbstractParallelAnyArray.OROCPap(ForkJoinPool, int, int, Object, IntAndObjectPredicate, IntAndObjectToObject) - Constructor in AbstractParallelAnyArray.OROCPap
AbstractParallelAnyArray.OROMPap - Class in groovyx.gpars.extra166y
AbstractParallelAnyArray.OROMPap(ForkJoinPool, int, int, Object, IntAndObjectPredicate, Op) - Constructor in AbstractParallelAnyArray.OROMPap
AbstractParallelAnyArray.ORPap - Class in groovyx.gpars.extra166y
AbstractParallelAnyArray.ORPap(ForkJoinPool, int, int, Object, IntAndObjectPredicate) - Constructor in AbstractParallelAnyArray.ORPap
AbstractParallelAnyArray.OUDCPap - Class in groovyx.gpars.extra166y
AbstractParallelAnyArray.OUDCPap(ForkJoinPool, int, int, Object, IntAndObjectToDouble) - Constructor in AbstractParallelAnyArray.OUDCPap
AbstractParallelAnyArray.OUDMPap - Class in groovyx.gpars.extra166y
AbstractParallelAnyArray.OUDMPap(ForkJoinPool, int, int, Object, ObjectToDouble) - Constructor in AbstractParallelAnyArray.OUDMPap
AbstractParallelAnyArray.OULCPap - Class in groovyx.gpars.extra166y
AbstractParallelAnyArray.OULCPap(ForkJoinPool, int, int, Object, IntAndObjectToLong) - Constructor in AbstractParallelAnyArray.OULCPap
AbstractParallelAnyArray.OULMPap - Class in groovyx.gpars.extra166y
AbstractParallelAnyArray.OULMPap(ForkJoinPool, int, int, Object, ObjectToLong) - Constructor in AbstractParallelAnyArray.OULMPap
AbstractParallelAnyArray.OUOCPap - Class in groovyx.gpars.extra166y
AbstractParallelAnyArray.OUOCPap(ForkJoinPool, int, int, Object, IntAndObjectToObject) - Constructor in AbstractParallelAnyArray.OUOCPap
AbstractParallelAnyArray.OUOMPap - Class in groovyx.gpars.extra166y
AbstractParallelAnyArray.OUOMPap(ForkJoinPool, int, int, Object, Op) - Constructor in AbstractParallelAnyArray.OUOMPap
AbstractParallelAnyArray.OUPap - Class in groovyx.gpars.extra166y
AbstractParallelAnyArray.OUPap(ForkJoinPool, int, int, Object) - Constructor in AbstractParallelAnyArray.OUPap
AbstractParallelAnyArray.Sequentially - Class in groovyx.gpars.extra166y
AbstractParallelAnyArray.Sequentially() - Constructor in AbstractParallelAnyArray.Sequentially
AbstractParallelAnyArray.SequentiallyAsDouble - Class in groovyx.gpars.extra166y
AbstractParallelAnyArray.SequentiallyAsDouble() - Constructor in AbstractParallelAnyArray.SequentiallyAsDouble
AbstractParallelAnyArray.SequentiallyAsLong - Class in groovyx.gpars.extra166y
AbstractParallelAnyArray.SequentiallyAsLong() - Constructor in AbstractParallelAnyArray.SequentiallyAsLong
AbstractParallelAnyArray.UnfilteredAsDoubleIterator - Class in groovyx.gpars.extra166y
AbstractParallelAnyArray.UnfilteredAsDoubleIterator() - Constructor in AbstractParallelAnyArray.UnfilteredAsDoubleIterator
AbstractParallelAnyArray.UnfilteredAsLongIterator - Class in groovyx.gpars.extra166y
AbstractParallelAnyArray.UnfilteredAsLongIterator() - Constructor in AbstractParallelAnyArray.UnfilteredAsLongIterator
AbstractParallelAnyArray.UnfilteredIterator - Class in groovyx.gpars.extra166y
AbstractParallelAnyArray.UnfilteredIterator() - Constructor in AbstractParallelAnyArray.UnfilteredIterator
AbstractParallelAnyArray(ForkJoinPool, int, int) - Constructor in AbstractParallelAnyArray
AbstractPAWrapper - Class in groovyx.gpars.pa
Wraps a ParallelArray instance in map/reduce operation chains.
AbstractPAWrapper(def) - Constructor in AbstractPAWrapper
Creates an instance wrapping the supplied instance of ParallelArray
act() - Method in DefaultActor
If no parameter is provided at construction time, the act() method becomes the actor's body
act() - Method in RunnableBackedBlockingActor
act() - Method in SequentialProcessingActor
This method represents the body of the actor.
action - Field in RunnableBackedBlockingActor
active - Field in AsyncMessagingCore
Indicates, whether there's an active thread handling a message inside the agent's body
activeForks - Field in GracefulShutdownListener
ActiveMethod - Annotation Type in groovyx.gpars.activeobject
ActiveObject - Annotation Type in groovyx.gpars.activeobject
ActiveObjectASTTransformation - Class in groovyx.gpars.activeobject
Transforms active objects so that their active methods can be invoked asynchronously through an internal actor.
ActiveObjectASTTransformation.MyClassCodeExpressionTransformer - Class in groovyx.gpars.activeobject
ActiveObjectASTTransformation.MyClassCodeExpressionTransformer(SourceUnit, String, String) - Constructor in ActiveObjectASTTransformation.MyClassCodeExpressionTransformer
ActiveObjectASTTransformation() - Constructor in ActiveObjectASTTransformation
ActiveObjectRegistry - Class in groovyx.gpars.activeobject
Maps string identifiers to instances of PGroup.
ActiveObjectRegistry() - Constructor in ActiveObjectRegistry
activeParallelGroup - Field in Dataflow
Maps threads/tasks to parallel groups they belong to
activeUpdater - Field in AsyncMessagingCore
Actor - Class in groovyx.gpars.actor
Actors are active objects, which borrow a thread from a thread pool.
Actor.MyRemoteHandle - Class in groovyx.gpars.actor
Actor.MyRemoteHandle(SerialHandle, SerialContext, DataflowExpression) - Constructor in Actor.MyRemoteHandle
Actor.RemoteActor - Class in groovyx.gpars.actor
Actor.RemoteActor.StopActorMsg - Class in groovyx.gpars.actor
Actor.RemoteActor.StopActorMsg(RemoteActor) - Constructor in Actor.RemoteActor.StopActorMsg
Actor.RemoteActor.TerminateActorMsg - Class in groovyx.gpars.actor
Actor.RemoteActor.TerminateActorMsg(RemoteActor) - Constructor in Actor.RemoteActor.TerminateActorMsg
Actor.RemoteActor(SerialContext, DataflowExpression) - Constructor in Actor.RemoteActor
Actor(DataflowExpression, PGroup) - Constructor in Actor
actor - Field in Actor.RemoteActor.StopActorMsg
actor - Field in Actor.RemoteActor.TerminateActorMsg
actor(Runnable) - Method in Actors
Creates a new instance of DefaultActor, using the passed-in closure as the body of the actor's act() method.
actor - Field in ActorTimerTask
actor - Field in DataflowProcessor
The internal actor performing on behalf of the processor
ACTOR_HAS_ALREADY_BEEN_STARTED - Field in Actor
actor(Runnable) - Method in PGroup
Creates a new instance of DefaultActor, using the passed-in runnable/closure as the body of the actor's act() method.
ActorException - Class in groovyx.gpars.actor.impl
Pooled actors need to simulate continuations to create stacktrace-less chunks of work (ActorActions) to assign to the threads from the pool.
ActorException() - Constructor in ActorException
actorFieldName - Field in ActiveObjectASTTransformation.MyClassCodeExpressionTransformer
actorGroupName - Field in ActiveObjectASTTransformation.MyClassCodeExpressionTransformer
ActorMessage - Class in groovyx.gpars.actor
An internal representation of received messages holding both the original message plus the sender actor reference.
ActorMessage() - Constructor in ActorMessage
Constructor for serialization
actorName - Field in ActiveObject
@default INTERNAL_ACTIVE_OBJECT_ACTOR
actorNode - Field in ActiveObjectASTTransformation.MyClassCodeExpressionTransformer
ActorReplyException - Class in groovyx.gpars.actor.impl
Indicates problems sending replies to actors.
ActorReplyException(String, List) - Constructor in ActorReplyException
Actors - Class in groovyx.gpars.actor
Provides handy helper methods to create pooled actors and customize the underlying thread pool.
Actors() - Constructor in Actors
ActorStopException - Class in groovyx.gpars.actor.impl
An exception indicating Actor stopping request.
ActorStopException() - Constructor in ActorStopException
ActorTerminationException - Class in groovyx.gpars.actor.impl
An exception indicating Actor termination request.
ActorTerminationException() - Constructor in ActorTerminationException
ActorTimerTask - Class in groovyx.gpars.actor
Represents an ongoing timeout
ActorTimerTask(AbstractLoopingActor, int) - Constructor in ActorTimerTask
add(Object) - Method in CustomConcurrentHashMap.KeySet
Adds the specified element to this set if there is not already an element equivalent to the given element with respect to this set's Equivalence.
add(Object) - Method in DefaultMessageQueue
add(Object) - Method in FQMessageQueue
add(Object) - Method in MessageQueue
add(int, Object) - Method in ParallelArray.AsList
add(Object) - Method in ParallelArray.ListIter
add(int, Double) - Method in ParallelDoubleArray.AsList
add(Double) - Method in ParallelDoubleArray.ListIter
add(int, Long) - Method in ParallelLongArray.AsList
add(Long) - Method in ParallelLongArray.ListIter
add(SerialHandle) - Method in SerialContext
add(SerialHandle) - Method in SerialHandles
addActiveMethod(FieldNode, ClassNode, MethodNode, boolean) - Method in ActiveObjectASTTransformation.MyClassCodeExpressionTransformer
addActorFieldToClass(ClassNode, String, String) - Method in ActiveObjectASTTransformation.MyClassCodeExpressionTransformer
addAll(ParallelArrayWithMapping) - Method in ParallelArray
Appends all (possibly bounded, filtered, or mapped) elements of the given ParallelArray, resizing and/or reallocating this array if necessary.
addAll(int, Collection) - Method in ParallelArray.AsList
addAll(ParallelDoubleArrayWithDoubleMapping) - Method in ParallelDoubleArray
Appends all (possibly bounded, filtered, or mapped) elements of the given ParallelDoubleArray, resizing and/or reallocating this array if necessary.
addAll(int, Collection) - Method in ParallelDoubleArray.AsList
addAll(ParallelLongArrayWithLongMapping) - Method in ParallelLongArray
Appends all (possibly bounded, filtered, or mapped) elements of the given ParallelDoubleArray, resizing and/or reallocating this array if necessary.
addAll(int, Collection) - Method in ParallelLongArray.AsList
addAllDataflowChannelListeners(Collection) - Method in DataflowChannelEventListenerManager
addAllDataflowChannelListeners(Collection) - Method in DataflowChannelEventOrchestrator
addConnection(RemoteConnection) - Method in RemoteHost
addDataflowChannelListener(DataflowChannelListener) - Method in DataflowChannelEventListenerManager
addDataflowChannelListener(DataflowChannelListener) - Method in DataflowChannelEventOrchestrator
addDataflowEventListener(DataflowEventListener) - Method in DataflowProcessor
addDiscoveryListener(Closure) - Method in LocalNode
addDoubles(int, int) - Method in PAS.UniquifierTable
adder - Field in CommonOps.DoubleAdder
adder - Field in CommonOps.IntAdder
adder - Field in CommonOps.LongAdder
addError(String, ASTNode, SourceUnit) - Method in ASTUtils
addListener(Closure) - Method in AgentBase
Adds a listener interested in state updates A listener should be a closure accepting the old and the new value in this order plus optionally the agent reference as the first argument.
addLocalHost(LocalHost) - Method in LocalHostRegistry
addLongs(int, int) - Method in PAS.UniquifierTable
addObjects(int, int) - Method in PAS.UniquifierTable
addOptimalNumberOfTrays() - Method in KanbanLink
Put as many trays into the system as there are processing units.
address - Field in BroadcastDiscovery
address - Field in NettyTransportProvider.Server
addToMap(Object, Object, Closure, Closure) - Method in CombineHolder
addTray() - Method in KanbanLink
Putting another tray into system by adding an empty one to the upstream
addUpdateListener(DataflowChannelListener) - Method in StreamCore
addUpdateListeners(Collection) - Method in StreamCore
addValidator(Closure) - Method in AgentBase
Adds a validator checking the agent's state A listener should be a closure accepting the old and the new value in this order plus optionally the agent reference as the first argument.
advance() - Method in AbstractParallelAnyArray.FilteredAsDoubleIterator
advance() - Method in AbstractParallelAnyArray.FilteredAsLongIterator
advance() - Method in AbstractParallelAnyArray.FilteredIterator
advance() - Method in CustomConcurrentHashMap.HashIterator
AFTER_START - Field in Actor
afterLoopCode - Field in DefaultActor
afterRun(DataflowProcessor, List) - Method in DataflowEventAdapter
Invoked when the operator completes a single run.
afterRun(DataflowProcessor, List) - Method in DataflowEventListener
Invoked when the operator completes a single run When using maxForks, the method may be invoked from threads running the forks.
afterRun(DataflowProcessor, List) - Method in GracefulShutdownListener
Enters an idle state, so a notification needs to be sent to the monitor.
afterStart(DataflowProcessor) - Method in DataflowEventAdapter
Invoked immediately after the operator starts by a pooled thread before the first message is obtained
afterStart(DataflowProcessor) - Method in DataflowEventListener
Invoked immediately after the operator starts by a pooled thread before the first message is obtained
afterStart() - Method in DataflowOperatorActor
afterStart() - Method in DataflowProcessorActor
afterStart() - Method in DataflowSelectorActor
afterStop(DataflowProcessor) - Method in DataflowEventAdapter
Invoked immediately after the operator terminates
afterStop(DataflowProcessor) - Method in DataflowEventListener
Invoked immediately after the operator terminates
afterStop() - Method in DataflowProcessorActor
Agent - Class in groovyx.gpars.agent
A special-purpose thread-safe non-blocking reference implementation inspired by Agents in Clojure.
Agent(Object, Closure) - Constructor in Agent
Creates a new Agent around the supplied modifiable object
agent(Object, Closure) - Method in PGroup
Creates an agent instance initialized with the given state
AgentBase - Class in groovyx.gpars.agent
Implements most of Agent's public method in Java
AgentBase.AwaitClosure - Class in groovyx.gpars.agent
Returns the current value of the Agent's state
AgentBase.AwaitClosure() - Constructor in AgentBase.AwaitClosure
AgentBase(Object, Closure) - Constructor in AgentBase
Creates a new Agent around the supplied modifiable object
AgentCore - Class in groovyx.gpars.agent
@author Vaclav Pech Date: 13.4.2010
AgentCore() - Constructor in AgentCore
AgentThreadFactory - Class in groovyx.gpars.agent
Creates daemon threads for the default agent thread pools
AgentThreadFactory() - Constructor in AgentThreadFactory
all(Class) - Method in AbstractParallelAnyArray.DFOMPap
all(Class) - Method in AbstractParallelAnyArray.DROMPap
all(Class) - Method in ParallelArray
Returns a new ParallelArray with the given element type holding all elements
all() - Method in ParallelArrayWithDoubleMapping
Returns a new ParallelDoubleArray holding mappings
all() - Method in ParallelArrayWithLongMapping
Returns a new ParallelLongArray holding mappings
all(Class) - Method in ParallelArrayWithMapping
Returns a new ParallelArray with the given element type holding elements
all() - Method in ParallelDoubleArray
Returns a new ParallelDoubleArray holding all elements
all() - Method in ParallelDoubleArrayWithDoubleMapping
Returns a new ParallelDoubleArray holding elements
all() - Method in ParallelDoubleArrayWithLongMapping
Returns a new ParallelLongArray holding mappings
all(Class) - Method in ParallelDoubleArrayWithMapping
Returns a new ParallelArray with the given element type holding elements
all() - Method in ParallelLongArray
Returns a new ParallelLongArray holding all elements
all() - Method in ParallelLongArrayWithDoubleMapping
Returns a new ParallelDoubleArray holding mappings
all() - Method in ParallelLongArrayWithLongMapping
Returns a new ParallelLongArray holding elements
all(Class) - Method in ParallelLongArrayWithMapping
Returns a new ParallelArray with the given element type holding all elements
allDoubles() - Method in AbstractParallelAnyArray
allGuardsClosed() - Method in DataflowSelector
Indicates, whether the selector has some guards enabled and so can select a value from the input channels
allLongs() - Method in AbstractParallelAnyArray
allNonidenticalElements() - Method in ParallelArray
Returns a new ParallelArray containing only the non-null unique elements of this array (that is, without any duplicates), using reference identity to test for duplication.
allNonidenticalElements() - Method in ParallelArrayWithFilter
Returns a new ParallelArray containing only non-null unique elements (that is, without any duplicates).
allObjects(Class) - Method in AbstractParallelAnyArray
Shared support for select/map all -- probe filter, map, and type to start selection driver, or do parallel mapping, or just copy,
allUniqueElements() - Method in ParallelArray
Returns a new ParallelArray containing only the non-null unique elements of this array (that is, without any duplicates), using each element's equals method to test for duplication.
allUniqueElements() - Method in ParallelArrayWithFilter
Returns a new ParallelArray containing only non-null unique elements (that is, without any duplicates).
allUniqueElements() - Method in ParallelDoubleArray
Returns a new ParallelDoubleArray containing only the unique elements of this array (that is, without any duplicates).
allUniqueElements() - Method in ParallelDoubleArrayWithFilter
Returns a new ParallelDoubleArray containing only unique elements (that is, without any duplicates).
allUniqueElements() - Method in ParallelLongArray
Returns a new ParallelLongArray containing only the unique elements of this array (that is, without any duplicates).
allUniqueElements() - Method in ParallelLongArrayWithFilter
Returns a new ParallelLongArray containing only unique elements (that is, without any duplicates).
allUnprocessedDFVs() - Method in DataflowStreamReadAdapter
ALT - Class in groovyx.gpars.csp
ALT is used to create an Alternative object
ALT(List) - Constructor in ALT
AN_ACTOR_CAN_ONLY_RECEIVE_ONE_MESSAGE_AT_A_TIME - Field in BlockingActor
AN_EXCEPTION_WAS_EXPECTED_TO_BE_THROWN_FROM_UNWRAP_STM_CONTROL_ERROR_FOR - Field in GParsStm
anchor - Field in SerialHandle
andPredicate(LongPredicate, LongPredicate) - Method in CommonOps
Returns a predicate evaluating to the conjunction of its contained predicates
any() - Method in ParallelArrayWithMapping
Returns some element matching bound and filter constraints, or null if none.
any() - Method in ParallelDoubleArrayWithMapping
Returns mapping of some element matching bound and filter constraints, or null if none.
any() - Method in ParallelLongArrayWithMapping
Returns mapping of some element matching bound and filter constraints, or null if none.
any(Closure) - Method in TransparentParallel
anyIndex() - Method in AbstractParallelAnyArray
Returns the index of some element matching bound and filter constraints, or -1 if none.
anyParallel(Closure) - Method in GParsExecutorsPoolEnhancer
Performs the any() operation using an asynchronous variant of the supplied closure to evaluate each collection's/object's element.
anyParallel(Map, Closure) - Method in GParsExecutorsPoolUtil
Does parallel any on a map
anyParallel(Map, Closure) - Method in GParsPoolUtil
Creates a Parallel Array out of the supplied map and invokes the withFilter() method using the supplied closure as the filter predicate.
anyParallel(Closure) - Method in Parallel
Performs the any() operation using an asynchronous variant of the supplied closure to evaluate each collection's/object's element.
append(def) - Method in ChannelInputList
append(def) - Method in ChannelOutputList
appendElement(Object) - Method in ParallelArray
appendElement(double) - Method in ParallelDoubleArray
appendElement(long) - Method in ParallelLongArray
appendingString() - Method in FList
appendingString() - Method in StreamCore
appendingString() - Method in SyncDataflowStream
apply(Procedure) - Method in ParallelArray
Applies the given procedure to elements
apply(DoubleProcedure) - Method in ParallelArrayWithDoubleMapping
Applies the given procedure
apply(LongProcedure) - Method in ParallelArrayWithLongMapping
Applies the given procedure
apply(Procedure) - Method in ParallelArrayWithMapping
Applies the given procedure to elements
apply(DoubleProcedure) - Method in ParallelDoubleArray
Applies the given procedure to elements
apply(DoubleProcedure) - Method in ParallelDoubleArrayWithDoubleMapping
Applies the given procedure to elements
apply(LongProcedure) - Method in ParallelDoubleArrayWithLongMapping
Applies the given procedure
apply(Procedure) - Method in ParallelDoubleArrayWithMapping
Applies the given procedure to mapped elements
apply(LongProcedure) - Method in ParallelLongArray
Applies the given procedure to elements
apply(DoubleProcedure) - Method in ParallelLongArrayWithDoubleMapping
Applies the given procedure
apply(LongProcedure) - Method in ParallelLongArrayWithLongMapping
Applies the given procedure to elements
apply(Procedure) - Method in ParallelLongArrayWithMapping
Applies the given procedure to mapped elements
apply(Closure) - Method in StreamCore
Calls the supplied closure with the stream as a parameter
arg - Field in DataflowExpression.TransformOne
args - Field in DataflowComplexExpression
args - Field in FJWorker
arr - Field in ParallelArray.ListIter
arr - Field in ParallelArray.ParallelArrayIterator
arr - Field in ParallelDoubleArray.ListIter
arr - Field in ParallelDoubleArray.ParallelDoubleArrayIterator
arr - Field in ParallelLongArray.ListIter
arr - Field in ParallelLongArray.ParallelLongArrayIterator
array - Field in AbstractParallelAnyArray.DPap
array - Field in AbstractParallelAnyArray.LPap
array - Field in AbstractParallelAnyArray.OPap
array - Field in PAS.FJDScanOp
array - Field in PAS.FJDScanPlusOp
array - Field in PAS.FJLScanOp
array - Field in PAS.FJLScanPlusOp
array - Field in PAS.FJOScanOp
asConcurrent(Object, Closure) - Method in GParsPoolUtil
Makes the collection concurrent for the passed-in block of code.
asConcurrent(Object, Closure) - Method in Parallel
Makes the collection concurrent for the passed-in block of code.
asList() - Method in ParallelArray
Returns a view of this ParallelArray as a List.
asList() - Method in ParallelDoubleArray
Returns a view of this ParallelDoubleArray as a List.
asList() - Method in ParallelLongArray
Returns a view of this ParallelLongArray as a List.
ASTUtils - Class in groovyx.gpars.util
Common functions for writing AST related code.
ASTUtils() - Constructor in ASTUtils
async(Closure) - Method in GParsExecutorsPoolUtil
Creates an asynchronous variant of the supplied closure, which, when invoked returns a future for the potential return value
async(Closure) - Method in GParsPoolUtil
Creates an asynchronous variant of the supplied closure, which, when invoked returns a future for the potential return value
async(Closure) - Method in GParsPoolUtilHelper
AsyncException - Class in groovyx.gpars
This class wraps multiple exception, which occurred in concurrently run code inside one of the GParsExecutorsPoolUtil methods.
AsyncException(String, List) - Constructor in AsyncException
AsyncFun - Annotation Type in groovyx.gpars
This annotation makes a field or local variable as an asynchronous function, and the field/variable should be evaluated only within the context of a ThreadPool.
asyncFun(Closure, Pool, boolean) - Method in GParsExecutorsPoolUtil
Creates an asynchronous and composable variant of the supplied closure, which, when invoked returns a DataflowVariable for the potential return value
asyncFun(Closure, FJPool, boolean) - Method in GParsPoolUtil
Creates an asynchronous and composable variant of the supplied closure, which, when invoked returns a DataflowVariable for the potential return value
asyncFun(Closure, boolean, FJPool) - Method in GParsPoolUtilHelper
AsyncFunASTTransformation - Class in groovyx.gpars.util
This transformation turns field initialExpressions into method calls to GParsPoolUtil.asyncFun.
AsyncFunASTTransformation() - Constructor in AsyncFunASTTransformation
asyncHead - Field in DataflowStreamReadAdapter
AsyncMessagingCore - Class in groovyx.gpars.util
@author Vaclav Pech Date: Aug 23, 2010
AsyncMessagingCore(Pool) - Constructor in AsyncMessagingCore
atLeaf(int, int) - Method in PAS.FJBase
Leaf computation
atLeaf(int, int) - Method in PAS.FJCountSelected
atLeaf(int, int) - Method in PAS.FJDApply
atLeaf(int, int) - Method in PAS.FJDBinaryIndexMap
atLeaf(int, int) - Method in PAS.FJDCombineInPlace
atLeaf(int, int) - Method in PAS.FJDFill
atLeaf(int, int) - Method in PAS.FJDGenerate
atLeaf(int, int) - Method in PAS.FJDIndexMap
atLeaf(int, int) - Method in PAS.FJDIndexOf
atLeaf(int, int) - Method in PAS.FJDMap
atLeaf(int, int) - Method in PAS.FJDPACombineInPlace
atLeaf(int, int) - Method in PAS.FJDReduce
atLeaf(int, int) - Method in PAS.FJDStats
atLeaf(int, int) - Method in PAS.FJDTransform
atLeaf(int, int) - Method in PAS.FJDUniquifier
atLeaf(int, int) - Method in PAS.FJLApply
atLeaf(int, int) - Method in PAS.FJLBinaryIndexMap
atLeaf(int, int) - Method in PAS.FJLCombineInPlace
atLeaf(int, int) - Method in PAS.FJLFill
atLeaf(int, int) - Method in PAS.FJLGenerate
atLeaf(int, int) - Method in PAS.FJLIndexMap
atLeaf(int, int) - Method in PAS.FJLIndexOf
atLeaf(int, int) - Method in PAS.FJLMap
atLeaf(int, int) - Method in PAS.FJLPACombineInPlace
atLeaf(int, int) - Method in PAS.FJLReduce
atLeaf(int, int) - Method in PAS.FJLStats
atLeaf(int, int) - Method in PAS.FJLTransform
atLeaf(int, int) - Method in PAS.FJLUniquifier
atLeaf(int, int) - Method in PAS.FJOApply
atLeaf(int, int) - Method in PAS.FJOBinaryIndexMap
atLeaf(int, int) - Method in PAS.FJOCombineInPlace
atLeaf(int, int) - Method in PAS.FJOFill
atLeaf(int, int) - Method in PAS.FJOGenerate
atLeaf(int, int) - Method in PAS.FJOIndexMap
atLeaf(int, int) - Method in PAS.FJOIndexOf
atLeaf(int, int) - Method in PAS.FJOMap
atLeaf(int, int) - Method in PAS.FJOPACombineInPlace
atLeaf(int, int) - Method in PAS.FJOReduce
atLeaf(int, int) - Method in PAS.FJOStats
atLeaf(int, int) - Method in PAS.FJOTransform
atLeaf(int, int) - Method in PAS.FJOUniquifier
atLeaf(int, int) - Method in PAS.FJSearchBase
atLeaf(int, int) - Method in PAS.FJSelectAny
atomic(AtomicBlock, Closure) - Method in GParsStm
Performs the supplied code atomically within a transaction using the supplied atomic block.
atomicWithBoolean(AtomicBlock, Closure) - Method in GParsStm
Performs the supplied code atomically within a transaction using the supplied atomic block.
atomicWithDouble(AtomicBlock, Closure) - Method in GParsStm
Performs the supplied code atomically within a transaction using the supplied atomic block.
atomicWithInt(AtomicBlock, Closure) - Method in GParsStm
Performs the supplied code atomically within a transaction using the supplied atomic block.
atomicWithLong(AtomicBlock, Closure) - Method in GParsStm
Performs the supplied code atomically within a transaction using the supplied atomic block.
atomicWithVoid(AtomicBlock, Closure) - Method in GParsStm
Performs the supplied code atomically within a transaction using the supplied atomic block.
ATTACHMENT - Field in DataflowExpression
attachment - Field in DataflowExpression.WaitingThread
attachToThreadPool(Pool) - Method in AgentCore
Sets a new thread pool to be used by the agent
attachToThreadPool(Pool) - Method in AsyncMessagingCore
Sets a new thread pool to be used by the agent
attemptToCountDownAndAwait(long) - Method in ResizeableCountDownLatch
Attempts to atomically count down the latch and await release with a timeout.
average() - Method in ParallelDoubleArray.SummaryStatistics
Returns the arithmetic average of all elements
average() - Method in ParallelLongArray.SummaryStatistics
Returns the arithmetic average of all elements
average() - Method in PAS.FJDStats
average() - Method in PAS.FJLStats
await() - Method in AgentBase
Blocks until all messages in the queue prior to call to await() complete.
await(long, TimeUnit) - Method in ResizeableCountDownLatch
Causes the current thread to wait until the latch has counted down to zero, unless the thread is {
linkplain:
Thread#interrupt interrupted}, or the specified waiting time elapses.
awaitClosure - Field in AgentBase
awaitingParties() - Method in SyncDataflowVariable
Reports whether the variable is still waiting for parties to arrive for the rendezvous.
awaitNextMessage(long) - Method in SequentialProcessingActor
Holds common functionality for takeMessage() methods.
awaitParties() - Method in SyncDataflowVariable

B

base - Field in PAS.FJDScanOp
base - Field in PAS.FJLScanOp
base - Field in PAS.FJOScanOp
become(Closure) - Method in DynamicDispatchActor
Executes the supplied closure in the context of the actor to set all when() handlers
beforeRun(DataflowProcessor, List) - Method in DataflowEventAdapter
Invoked when all messages required to trigger the operator become available in the input channels.
beforeRun(DataflowProcessor, List) - Method in DataflowEventListener
Invoked when all messages required to trigger the operator become available in the input channels.
beforeRun(DataflowProcessor, List) - Method in GracefulShutdownListener
Entering a different non-idle state, so a notification needs to be sent to the monitor.
beforeRun(DataflowProcessor, List) - Method in ProcessorPauseResume
binaryChoice(PGroup, Map, DataflowWriteChannel, DataflowWriteChannel, Closure) - Method in DataflowExpression
binaryChoice(PGroup, Map, DataflowWriteChannel, DataflowWriteChannel, Closure) - Method in DataflowQueue
binaryChoice(PGroup, Map, DataflowWriteChannel, DataflowWriteChannel, Closure) - Method in DataflowReadChannel
Directs the output to one of the two output channels depending on the boolean result of the provided closure.
binaryChoice(PGroup, Map, DataflowWriteChannel, DataflowWriteChannel, Closure) - Method in DataflowStreamReadAdapter
binaryChoice(Map, DataflowWriteChannel, DataflowWriteChannel, Closure) - Method in Pipeline
Directs the output to one of the two output channels depending on the boolean result of the provided closure.
BinaryChoiceClosure - Class in groovyx.gpars.dataflow.operator
Used by the chainWith() method to wrap the supplied closure inside the operator's body.
BinaryChoiceClosure(Closure) - Constructor in BinaryChoiceClosure
binarySearch(double, DoubleComparator) - Method in AbstractParallelAnyArray.DUPap
binarySearch(long, LongComparator) - Method in AbstractParallelAnyArray.LUPap
binarySearch(Object, Comparator) - Method in AbstractParallelAnyArray.OUPap
binarySearch(Object, Comparator) - Method in ParallelArray
Assuming this array is sorted with respect to the given comparator, returns the index of an element equal to given target, or -1 if not present.
binarySearch(Object, Comparator) - Method in ParallelArrayWithBounds
Assuming this array is sorted with respect to the given comparator, returns the index of an element equal to given target, or -1 if not present.
binarySearch(double, DoubleComparator) - Method in ParallelDoubleArray
Assuming this array is sorted with respect to the given comparator, returns the index of an element equal to given target, or -1 if not present.
binarySearch(double, DoubleComparator) - Method in ParallelDoubleArrayWithBounds
Assuming this array is sorted with respect to the given comparator, returns the index of an element equal to given target, or -1 if not present.
binarySearch(long, LongComparator) - Method in ParallelLongArray
Assuming this array is sorted with respect to the given comparator, returns the index of an element equal to given target, or -1 if not present.
binarySearch(long, LongComparator) - Method in ParallelLongArrayWithBounds
Assuming this array is sorted with respect to the given comparator, returns the index of an element equal to given target, or -1 if not present.
bind(Object) - Method in DataflowExpression
Assigns a value to the variable.
bind(Object) - Method in DataflowQueue
Adds a DataflowVariable representing the passed in value to the buffer.
bind(Object) - Method in DataflowStreamWriteAdapter
bind(Object) - Method in DataflowWriteChannel
Assigns a value to the variable.
bind(def) - Method in KanbanTray
Put the product in the tray and send it downstream
bind(Object) - Method in StreamCore
bindAllOutputs(Object) - Method in DataflowProcessor
Used by the processor's body to send a value to all output channels.
bindAllOutputsAtomically(Object) - Method in DataflowProcessor
Used by the processor's body to send a value to all output channels, while guaranteeing atomicity of the operation and preventing other calls to bindAllOutputsAtomically() from interfering with one another.
bindAllOutputValues(Object) - Method in DataflowProcessor
Used by the processor's body to send a value to all output channels.
bindAllOutputValuesAtomically(Object) - Method in DataflowProcessor
Used by the processor's body to send a value to all output channels, while guaranteeing atomicity of the operation and preventing other calls to bindAllOutputsAtomically() from interfering with one another.
bindDFV(DataflowReadChannel) - Method in DataflowVariable
bindError(Throwable) - Method in DataflowExpression
bindOutput(Object) - Method in DataflowProcessor
Used by the processor's body to send a value to the first / only output channel
bindSafely(Object) - Method in DataflowExpression
Assigns a value to the variable.
bindUnique(Object) - Method in DataflowExpression
Assigns a value to the variable.
bitwiseNegate() - Method in KanbanTray
Alias for KanbanTray#release#release in order to write ˜ tray ("shake loose") *
blocking - Field in ActiveMethod
@default true
blocking - Field in AsyncFun
Set to true to execute the closure in blocking mode.
BlockingActor - Class in groovyx.gpars.actor
@author Vaclav Pech, Alex Tkachman, Dierk Koenig
blockingActor(Runnable) - Method in Actors
Creates a new instance of BlockingActor, using the passed-in closure as the body of the actor's act() method.
BlockingActor() - Constructor in BlockingActor
blockingActor(Runnable) - Method in PGroup
Creates a new instance of BlockingActor, using the passed-in closure as the body of the actor's act() method.
blockingMandated(String) - Method in ActiveObjectASTTransformation.MyClassCodeExpressionTransformer
body - Property in ProcessingNode
bootstrap - Field in NettyTransportProvider.Server
bound - Field in CommonOps.DoubleBoundedRandomGenerator
bound - Field in CommonOps.IntBoundedRandomGenerator
bound - Field in CommonOps.LongBoundedRandomGenerator
boundNotification(int, DataflowReadChannel) - Method in SelectBase
Invoked by the SelectCallback instances, potentially concurrently to inform about new values being available for read from channels.
boundsCheck(int, int) - Method in AbstractParallelAnyArray
BroadcastDiscovery - Class in groovyx.gpars.remote
BroadcastDiscovery(UUID, InetSocketAddress) - Constructor in BroadcastDiscovery
broadcastDiscovery - Field in NettyTransportProvider
build(Object) - Method in ActorMessage
Factory method to create instances of ActorMessage with given payload.
buildClosureForMaps(Closure) - Method in PAUtils
If the passed-in closure expects two arguments, it is considered to be a map-iterative code and is then wrapped with a single-argument closure, which unwraps the key:value pairs for the original closure.
buildClosureForMapsWithIndex(Closure) - Method in PAUtils
If the passed-in closure expects three arguments, it is considered to be a map-iterative_with_index code and is then wrapped with a two-argument closure, which unwraps the key:value pairs for the original closure.
buildMemoizeFunction(Map, Closure) - Method in GParsPoolUtilHelper
buildMessage() - Method in AsyncException
buildResultMap(Collection) - Method in PAUtils
Builds a resulting map out of an map entry collection
buildSoftReferenceMemoizeFunction(int, Map, Closure) - Method in GParsPoolUtilHelper
bundle - Field in SerialHandle
byIdentity - Field in PAS.UniquifierTable

C

call(Object) - Method in AgentBase.AwaitClosure
call(Object) - Method in AgentCore
Adds the message to the agent\s message queue
call() - Method in BinaryChoiceClosure
call(Object) - Method in CallClosure
call() - Method in ChainWithClosure
call() - Method in ChoiceClosure
call() - Method in CopyChannelsClosure
call(Object) - Method in DataflowMessagingRunnable
call(Object) - Method in DataflowProcessorAtomicBoundAllClosure
call(Object) - Method in DefaultActorClosure
call() - Method in FilterClosure
call(def) - Method in KanbanTray
Alias for KanbanTray#bind#bind in order to write tray product *
call(Object) - Method in MessageStream
Same as send
call(Object) - Method in MessagingRunnable
call(Object) - Method in ReactorMessagingRunnable
call(MessageStream, List) - Method in Select
Selects a value from a single randomly chosen input channel, which has a value available for read.
call(Object) - Method in SelectCallback
Invoked by the channel when a value has been bound to it and is available for consumption
call() - Method in SeparationClosure
call(Object) - Method in SumClosure
callAsync(Closure, Object) - Method in GParsExecutorsPoolUtil
Calls a closure in a separate thread supplying the given arguments, returning a future for the potential return value.
callAsync(Closure, Object) - Method in GParsPoolUtil
Calls a closure in a separate thread supplying the given arguments, returning a future for the potential return value.
callAsync(Closure, Object) - Method in GParsPoolUtilHelper
CallAsyncTask - Class in groovyx.gpars.pa
A helper class to wrap closures for callAsync on GParsPool
CallAsyncTask(Closure) - Constructor in CallAsyncTask
callback - Field in DataflowExpression.WaitingThread
CallClosure - Class in groovyx.gpars.pa
A call-forwarding closure
CallClosure(Closure) - Constructor in CallClosure
callDynamic(String, Object) - Method in Actor
callParallel(Closure) - Method in GParsExecutorsPoolUtil
schedules the supplied closure for processing in the underlying thread pool.
callParallel(Closure) - Method in GParsPoolUtil
schedules the supplied closure for processing in the underlying thread pool.
callTimeoutAsync(Closure, Duration, Object) - Method in GParsExecutorsPoolUtil
Calls a closure in a separate thread supplying the given arguments, returning a future for the potential return value.
callTimeoutAsync(Closure, Duration, Object) - Method in GParsPoolUtil
Calls a closure in a separate thread supplying the given arguments, returning a future for the potential return value.
cancel(boolean) - Method in GParsPool.MyCancellableRecursiveTask
cancelCurrentTimeoutTask() - Method in AbstractLoopingActor
CANNOT_CREATE_AN_ATOMIC_BLOCK_SOME_OF_THE_SPECIFIED_PARAMETERS_ARE_NOT_SUPPORTED - Field in GParsStm
CANNOT_OBTAIN_THE_SEMAPHORE_TO_FORK_OPERATOR_S_BODY - Field in DataflowProcessorActor
CANNOT_SEND_REPLIES_NO_SENDER_HAS_BEEN_REGISTERED - Field in Actor
castedComparator() - Method in CommonOps
Returns a Comparator that casts its arguments as Comparable on each comparison, throwing ClassCastException on failure.
castedMaxReducer() - Method in CommonOps
Returns a reducer returning maximum of two values, or null if both arguments are null, and that casts its arguments as Comparable on each comparison, throwing ClassCastException on failure.
castedMinReducer() - Method in CommonOps
Returns a reducer returning minimum of two values, or null if both arguments are null, and that casts its arguments as Comparable on each comparison, throwing ClassCastException on failure.
cchm - Field in CustomConcurrentHashMap.IntKeySoftValueNode
cchm - Field in CustomConcurrentHashMap.IntKeyWeakValueNode
cchm - Field in CustomConcurrentHashMap.KeySet
cchm - Field in CustomConcurrentHashMap.SoftKeyNode
cchm - Field in CustomConcurrentHashMap.StrongKeySoftValueNode
cchm - Field in CustomConcurrentHashMap.StrongKeyWeakValueNode
cchm - Field in CustomConcurrentHashMap.WeakKeyNode
chainWith(PGroup, Map, Closure) - Method in DataflowExpression
chainWith(PGroup, Map, Closure) - Method in DataflowQueue
chainWith(PGroup, Map, Closure) - Method in DataflowReadChannel
Creates and attaches a new operator processing values from the channel
chainWith(PGroup, Map, Closure) - Method in DataflowStreamReadAdapter
chainWith(Map, Closure) - Method in Pipeline
Creates and attaches a new operator
chainWith(PGroup, Closure) - Method in SyncDataflowQueue
chainWith(PGroup, Closure) - Method in SyncDataflowStreamReadAdapter
chainWith(PGroup, Closure) - Method in SyncDataflowVariable
ChainWithClosure - Class in groovyx.gpars.dataflow.operator
Used by the chainWith() method to wrap the supplied closure inside the operator's body.
ChainWithClosure(Closure) - Constructor in ChainWithClosure
channel - Field in NettyHandler
channel - Field in NettyTransportProvider.Server
channel - Field in SelectCallback
channelConnected(ChannelHandlerContext, ChannelStateEvent) - Method in NettyHandler
channelDisconnected(ChannelHandlerContext, ChannelStateEvent) - Method in NettyHandler
channelDisconnected(ChannelHandlerContext, ChannelStateEvent) - Method in NettyTransportProvider.ClientHandler
channelFuture - Field in NettyTransportProvider.Client
ChannelInputList - Class in groovyx.gpars.csp
ChannelInputList is used to create a list of ChannelInputEnds
ChannelInputList() - Constructor in ChannelInputList
ChannelInputList uses the ArrayList class of java This constructor creates an empty ArrayList to be populated with NetChannelInputs
channelOpen(ChannelHandlerContext, ChannelStateEvent) - Method in NettyHandler
ChannelOutputList - Class in groovyx.gpars.csp
ChannelOutputList is used to create a list of ChannelOUTPUTEnds
ChannelOutputList() - Constructor in ChannelOutputList
ChannelOutputList uses the ArrayList class of java This constructor creates an empty ArrayList to be populated with NetChannelOUTPUTs
channels - Field in SelectBase
checkBlockingMethod(MethodNode, Iterable) - Method in ActiveObjectASTTransformation.MyClassCodeExpressionTransformer
checkClosed() - Method in SyncDataflowStreamReadAdapter
checkClosure(Closure) - Method in AgentBase
Only two-argument closures are allowed
checkForBodyArguments(Closure) - Method in DefaultActor
checkForMessageHandlerArguments(Closure) - Method in DefaultActor
checkForNull(Runnable) - Method in DefaultActor
checkMaxForks(Map) - Method in DataflowProcessor
checkPoison(Object) - Method in DataflowProcessorActor
Handles the poisson message.
checkState() - Method in Pipeline
checkStoppedFlags() - Method in BlockingActor
checkStopTerminate() - Method in SequentialProcessingActor
checkValidPoolSize(int) - Method in PoolUtils
checkWhetherAnyEventsHaveArrived() - Method in GracefulShutdownMonitor
Checks the notification flag whether there has been some activity since last timer run.
children - Field in AbstractForkJoinWorker
Stores the child workers
choice(PGroup, Map, List, Closure) - Method in DataflowExpression
choice(PGroup, Map, List, Closure) - Method in DataflowQueue
choice(PGroup, Map, List, Closure) - Method in DataflowReadChannel
Directs the output to one of the output channels depending on the int result of the provided closure.
choice(PGroup, Map, List, Closure) - Method in DataflowStreamReadAdapter
choice(Map, List, Closure) - Method in Pipeline
Directs the output to one of the output channels depending on the int result of the provided closure.
ChoiceClosure - Class in groovyx.gpars.dataflow.operator
Used by the chainWith() method to wrap the supplied closure inside the operator's body.
ChoiceClosure(Closure) - Constructor in ChoiceClosure
cleanUpNullReferences(Map, ReferenceQueue) - Method in GParsPoolUtilHelper
clear() - Method in CustomConcurrentHashMap
Removes all of the mappings from this map.
clear() - Method in CustomConcurrentHashMap.EntrySet
clear() - Method in CustomConcurrentHashMap.KeySet
Removes all of the elements from this set.
clear() - Method in CustomConcurrentHashMap.KeySetView
clear() - Method in CustomConcurrentHashMap.Values
clear() - Method in ParallelArray.AsList
clear() - Method in ParallelDoubleArray.AsList
clear() - Method in ParallelLongArray.AsList
clearCount() - Method in CustomConcurrentHashMap.Segment
clearInputArea - Property in GConsole
clients - Field in NettyTransportProvider
cList - Property in ChannelInputList
cList - Property in ChannelOutputList
clone() - Method in CallClosure
clone() - Method in LRUProtectionStorage
Performs a shallow clone
close() - Method in SyncDataflowStreamReadAdapter
Closes the channel so that it cannot be used any longer
closed - Field in SyncDataflowStreamReadAdapter
closure - Field in DataflowExpression.TransformMany
closure - Field in DataflowExpression.TransformOne
closure - Field in RemoteNodeDiscoveryListener.RemoteNodeDiscoveryListenerClosure
closure - Field in ThenMessagingRunnable
ClosureMapper - Class in groovyx.gpars.pa
A PA mapper built around a closure
ClosureMapper(Closure) - Constructor in ClosureMapper
ClosureNegationPredicate - Class in groovyx.gpars.pa
A PA predicate built around a closure
ClosureNegationPredicate(Closure) - Constructor in ClosureNegationPredicate
ClosurePredicate - Class in groovyx.gpars.pa
A PA predicate built around a closure
ClosurePredicate(Closure) - Constructor in ClosurePredicate
ClosureReducer - Class in groovyx.gpars.pa
A PA reducer built around a closure
ClosureReducer(Closure) - Constructor in ClosureReducer
cmp - Field in CommonOps.RawComparator
cmp - Field in PAS.FJDMerger
cmp - Field in PAS.FJDSorter
cmp - Field in PAS.FJLMerger
cmp - Field in PAS.FJLSorter
cmp - Field in PAS.FJOMerger
cmp - Field in PAS.FJOSorter
code - Field in BinaryChoiceClosure
code - Field in CallAsyncTask
code - Field in ChainWithClosure
code - Field in ChoiceClosure
code - Field in ClosureMapper
code - Field in ClosureNegationPredicate
code - Field in ClosurePredicate
code - Field in ClosureReducer
code - Field in DataCallback
code - Field in DataCallbackWithPool
code - Field in DataflowProcessorActor
code - Field in FJWorker
code - Field in GParsAtomicBlock
code - Field in GParsAtomicBooleanBlock
code - Field in GParsAtomicDoubleBlock
code - Field in GParsAtomicIntBlock
code - Field in GParsAtomicLongBlock
code - Field in GParsAtomicVoidBlock
code - Field in GParsPool.MyCancellableRecursiveTask
code - Field in SeparationClosure
collect(Closure) - Method in TransparentParallel
collectingMessages - Field in GracefulShutdownListener
collectMany(Closure) - Method in TransparentParallel
collectManyParallel(Map, Closure) - Method in GParsPoolUtil
Creates a Parallel Array out of the supplied collection/object and invokes the withMapping() method using the supplied projection closure as the transformation operation.
collectManyParallel(Closure) - Method in Parallel
Iterates over a collection/object with the collectMany() method using an asynchronous variant of the supplied closure to evaluate each collection's element.
collectParallel(Closure) - Method in GParsExecutorsPoolEnhancer
Iterates over a collection/object with the collect() method using an asynchronous variant of the supplied closure to evaluate each collection's element.
collectParallel(Map, Closure) - Method in GParsExecutorsPoolUtil
Does parallel collect on a map
collectParallel(Map, Closure) - Method in GParsPoolUtil
Creates a Parallel Array out of the supplied map and invokes the withMapping() method using the supplied closure as the transformation operation.
collectParallel(Closure) - Method in Parallel
Iterates over a collection/object with the collect() method using an asynchronous variant of the supplied closure to evaluate each collection's element.
combine(Object, Closure) - Method in AbstractPAWrapper
Performs a parallel combine operation.
CombineHolder - Class in groovyx.gpars.pa
Holds a temporary reduce result for groupBy
CombineHolder(Map) - Constructor in CombineHolder
combineImpl(def, def, Closure, Closure) - Method in AbstractPAWrapper
combiner - Field in PAS.FJDCombineInPlace
combiner - Field in PAS.FJDPACombineInPlace
combiner - Field in PAS.FJLCombineInPlace
combiner - Field in PAS.FJLPACombineInPlace
combiner - Field in PAS.FJOCombineInPlace
combiner - Field in PAS.FJOPACombineInPlace
CommonOps - Class in groovyx.gpars.extra166y
A collection of static factory methods providing commonly useful implementations of operations.
CommonOps.DoubleAdder - Class in groovyx.gpars.extra166y
CommonOps.DoubleAdder() - Constructor in CommonOps.DoubleAdder
CommonOps.DoubleBoundedRandomGenerator - Class in groovyx.gpars.extra166y
CommonOps.DoubleBoundedRandomGenerator(double) - Constructor in CommonOps.DoubleBoundedRandomGenerator
CommonOps.DoubleEqualityPredicate - Class in groovyx.gpars.extra166y
CommonOps.DoubleEqualityPredicate() - Constructor in CommonOps.DoubleEqualityPredicate
CommonOps.DoubleInequalityPredicate - Class in groovyx.gpars.extra166y
CommonOps.DoubleInequalityPredicate() - Constructor in CommonOps.DoubleInequalityPredicate
CommonOps.DoubleIntervalRandomGenerator - Class in groovyx.gpars.extra166y
CommonOps.DoubleIntervalRandomGenerator(double, double) - Constructor in CommonOps.DoubleIntervalRandomGenerator
CommonOps.DoubleRandomGenerator - Class in groovyx.gpars.extra166y
CommonOps.DoubleRandomGenerator() - Constructor in CommonOps.DoubleRandomGenerator
CommonOps.EqualityPredicate - Class in groovyx.gpars.extra166y
CommonOps.EqualityPredicate() - Constructor in CommonOps.EqualityPredicate
CommonOps.IdentityPredicate - Class in groovyx.gpars.extra166y
CommonOps.IdentityPredicate() - Constructor in CommonOps.IdentityPredicate
CommonOps.InequalityPredicate - Class in groovyx.gpars.extra166y
CommonOps.InequalityPredicate() - Constructor in CommonOps.InequalityPredicate
CommonOps.IntAdder - Class in groovyx.gpars.extra166y
CommonOps.IntAdder() - Constructor in CommonOps.IntAdder
CommonOps.IntBoundedRandomGenerator - Class in groovyx.gpars.extra166y
CommonOps.IntBoundedRandomGenerator(int) - Constructor in CommonOps.IntBoundedRandomGenerator
CommonOps.IntEqualityPredicate - Class in groovyx.gpars.extra166y
CommonOps.IntEqualityPredicate() - Constructor in CommonOps.IntEqualityPredicate
CommonOps.IntInequalityPredicate - Class in groovyx.gpars.extra166y
CommonOps.IntInequalityPredicate() - Constructor in CommonOps.IntInequalityPredicate
CommonOps.IntIntervalRandomGenerator - Class in groovyx.gpars.extra166y
CommonOps.IntIntervalRandomGenerator(int, int) - Constructor in CommonOps.IntIntervalRandomGenerator
CommonOps.IntRandomGenerator - Class in groovyx.gpars.extra166y
CommonOps.IntRandomGenerator() - Constructor in CommonOps.IntRandomGenerator
CommonOps.IsNonNullPredicate - Class in groovyx.gpars.extra166y
CommonOps.IsNonNullPredicate() - Constructor in CommonOps.IsNonNullPredicate
CommonOps.IsNullPredicate - Class in groovyx.gpars.extra166y
CommonOps.IsNullPredicate() - Constructor in CommonOps.IsNullPredicate
CommonOps.LongAdder - Class in groovyx.gpars.extra166y
CommonOps.LongAdder() - Constructor in CommonOps.LongAdder
CommonOps.LongBoundedRandomGenerator - Class in groovyx.gpars.extra166y
CommonOps.LongBoundedRandomGenerator(long) - Constructor in CommonOps.LongBoundedRandomGenerator
CommonOps.LongEqualityPredicate - Class in groovyx.gpars.extra166y
CommonOps.LongEqualityPredicate() - Constructor in CommonOps.LongEqualityPredicate
CommonOps.LongInequalityPredicate - Class in groovyx.gpars.extra166y
CommonOps.LongInequalityPredicate() - Constructor in CommonOps.LongInequalityPredicate
CommonOps.LongIntervalRandomGenerator - Class in groovyx.gpars.extra166y
CommonOps.LongIntervalRandomGenerator(long, long) - Constructor in CommonOps.LongIntervalRandomGenerator
CommonOps.LongRandomGenerator - Class in groovyx.gpars.extra166y
CommonOps.LongRandomGenerator() - Constructor in CommonOps.LongRandomGenerator
CommonOps.NaturalDoubleComparator - Class in groovyx.gpars.extra166y
CommonOps.NaturalDoubleComparator() - Constructor in CommonOps.NaturalDoubleComparator
CommonOps.NaturalDoubleMaxReducer - Class in groovyx.gpars.extra166y
CommonOps.NaturalDoubleMaxReducer() - Constructor in CommonOps.NaturalDoubleMaxReducer
CommonOps.NaturalDoubleMinReducer - Class in groovyx.gpars.extra166y
CommonOps.NaturalDoubleMinReducer() - Constructor in CommonOps.NaturalDoubleMinReducer
CommonOps.NaturalLongComparator - Class in groovyx.gpars.extra166y
CommonOps.NaturalLongComparator() - Constructor in CommonOps.NaturalLongComparator
CommonOps.NaturalLongMaxReducer - Class in groovyx.gpars.extra166y
CommonOps.NaturalLongMaxReducer() - Constructor in CommonOps.NaturalLongMaxReducer
CommonOps.NaturalLongMinReducer - Class in groovyx.gpars.extra166y
CommonOps.NaturalLongMinReducer() - Constructor in CommonOps.NaturalLongMinReducer
CommonOps.NonidentityPredicate - Class in groovyx.gpars.extra166y
CommonOps.NonidentityPredicate() - Constructor in CommonOps.NonidentityPredicate
CommonOps.RawComparator - Class in groovyx.gpars.extra166y
CommonOps.RawComparator() - Constructor in CommonOps.RawComparator
CommonOps.RawMaxReducer - Class in groovyx.gpars.extra166y
CommonOps.RawMaxReducer() - Constructor in CommonOps.RawMaxReducer
CommonOps.RawMinReducer - Class in groovyx.gpars.extra166y
CommonOps.RawMinReducer() - Constructor in CommonOps.RawMinReducer
CommonOps() - Constructor in CommonOps
comparator - Field in CommonOps.NaturalDoubleComparator
comparator - Field in CommonOps.NaturalLongComparator
comparator - Field in PAS.FJDStats
comparator - Field in PAS.FJLStats
comparator - Field in PAS.FJOStats
compare(double, double) - Method in CommonOps.NaturalDoubleComparator
compare(long, long) - Method in CommonOps.NaturalLongComparator
compare(Object, Object) - Method in CommonOps.RawComparator
compare(double, double) - Method in Ops.DoubleComparator
compare(int, int) - Method in Ops.IntComparator
compare(long, long) - Method in Ops.LongComparator
complete - Field in Pipeline
compoundIndexedOp(LongOp, IntAndLongToLong) - Method in AbstractParallelAnyArray
compoundIndexedSelector(IntAndLongPredicate, LongPredicate) - Method in AbstractParallelAnyArray
compoundOp(LongToDouble, DoubleToLong) - Method in CommonOps
Returns a composite mapper that applies a second mapper to the results of applying the first one
compute() - Method in AbstractForkJoinWorker
compute() - Method in CallAsyncTask
compute(Object, CustomConcurrentHashMap.RemappingFunction) - Method in CustomConcurrentHashMap
Updates the mapping for the given key with the result of the given remappingFunction.
compute() - Method in GParsPool.MyCancellableRecursiveTask
compute() - Method in PAS.FJBase
compute() - Method in PAS.FJDCMerger
compute() - Method in PAS.FJDCSorter
compute() - Method in PAS.FJDMerger
compute() - Method in PAS.FJDSorter
compute() - Method in PAS.FJLCMerger
compute() - Method in PAS.FJLCSorter
compute() - Method in PAS.FJLMerger
compute() - Method in PAS.FJLSorter
compute() - Method in PAS.FJOCMerger
compute() - Method in PAS.FJOCSorter
compute() - Method in PAS.FJOMerger
compute() - Method in PAS.FJOSorter
compute() - Method in PAS.FJRemoveAll
compute() - Method in PAS.FJRemoveAllDriver
compute() - Method in PAS.FJSearchBase
compute() - Method in PAS.FJSelectAll
compute() - Method in PAS.FJSelectAllDriver
compute() - Method in PAS.FJSubSorter
computeIfAbsent(Object, CustomConcurrentHashMap.MappingFunction) - Method in CustomConcurrentHashMap
If the specified key is not already associated with a value, computes its value using the given mappingFunction, and if non-null, enters it into the map.
computeTask() - Method in AbstractForkJoinWorker
computeTask() - Method in FJWorker
computeThreshold() - Method in AbstractParallelAnyArray
Returns size threshold for splitting into subtask.
concurrencyActive - Field in TransparentParallel
concurrentExceptions - Field in AsyncException
configuredPoolSize - Field in FJPool
connect(def) - Method in GroovyMobileProcess
connect(LocalNode) - Method in LocalHost
Connect local node to the provider
connect(LocalNode) - Method in LocalHostRegistry
connect(LocalHost) - Method in LocalNode
connect(List) - Method in MobileAgent
connect(LocalNode) - Method in RemoteHost
connection - Field in NettyHandler
connection - Field in RemoteObjectDecoder
connection - Field in RemoteObjectEncoder
connections - Field in RemoteHost
connectRemoteNode(UUID, SerialContext, Actor) - Method in LocalHost
consumer - Field in KanbanLink
consumerAlreadyStarted() - Method in KanbanLink
consumerSpec - Property in KanbanLink
contains(def) - Method in ChannelInputList
contains(def) - Method in ChannelOutputList
contains(Object) - Method in CustomConcurrentHashMap.EntrySet
contains(Object) - Method in CustomConcurrentHashMap.KeySet
Returns true if this set contains an element equivalent to the given element with respect to this set's Equivalence.
contains(Object) - Method in CustomConcurrentHashMap.KeySetView
contains(Object) - Method in CustomConcurrentHashMap.Values
contains(Object) - Method in Dataflows
Checks whether a certain key is contained in the map.
contains(Object) - Method in ParallelArray.AsList
contains(Object) - Method in ParallelDoubleArray.AsList
contains(Object) - Method in ParallelLongArray.AsList
containsKey(Object) - Method in CustomConcurrentHashMap
Returns true if this map contains a key equivalent to the given key with respect to this map's key Equivalence.
containsValue(Object) - Method in CustomConcurrentHashMap
Returns true if this map maps one or more keys to a value equivalent to the given value with respect to this map's value Equivalence.
content - Field in CombineHolder
context - Field in SerialHandle
local host
continueProcessingMessages() - Method in AsyncMessagingCore
Informs about a new thread being assigned to process the next message
ControlMessage - Interface in groovyx.gpars.dataflow.operator
A marker interface indicating control dataflow messages, which in general do not get propagated to the operator's body
controlMessageArrived(DataflowProcessor, DataflowReadChannel, int, Object) - Method in DataflowEventAdapter
Invoked when a control message (instances of ControlMessage) becomes available in an input channel.
controlMessageArrived(DataflowProcessor, DataflowReadChannel, int, Object) - Method in DataflowEventListener
Invoked when a control message (instances of ControlMessage) becomes available in an input channel.
controlMessageArrived(DataflowProcessor, DataflowReadChannel, int, Object) - Method in GracefulShutdownListener
Entering a non-idle state, so a notification needs to be sent to the monitor.
convertToBoolean(def) - Method in GParsPoolUtilHelper
copy - Field in AgentBase
Function converting the internal state during read to prevent internal state escape from the protected boundary of the agent
copy() - Method in JCSPCopy
The interface JCSPCopy is used to define a copy method that is used to make a deep copy of an object.
CopyChannelsClosure - Class in groovyx.gpars.dataflow.operator
Used by the chainWith() method to wrap the supplied closure inside the operator's body.
CopyChannelsClosure() - Constructor in CopyChannelsClosure
copyDFV(Queue, Queue) - Method in DataflowQueue
core - Field in AbstractLoopingActor
Holds the particular instance of async messaging core to use
core - Field in AgentCore
count - Field in CustomConcurrentHashMap.Segment
count - Field in DataflowExpression.DataflowExpressionsCollector
count - Field in PAS.FJCountSelected
count - Field in PAS.FJDUniquifier
count - Field in PAS.FJLUniquifier
count - Field in PAS.FJOUniquifier
count - Field in PAS.FJRemoveAll
count - Field in PAS.FJSelectAll
count(def) - Method in TransparentParallel
countDown() - Method in CountingPoisonPill
countDown() - Method in ImmediateCountingPoisonPill
countDown() - Method in PoisonPill
countDown() - Method in PoisonTrackCounter
countDown() - Method in ResizeableCountDownLatch
Decrements the count of the latch, releasing all waiting threads if the count reaches zero.
counter - Field in PoisonTrackCounter
CountingPoisonPill - Class in groovyx.gpars.dataflow.operator
Represents a non-immediate PoisonPill that counts stopped operators and can be used to wait for all the operators to terminate.
CountingPoisonPill(int) - Constructor in CountingPoisonPill
Creates a non-immediate instance that could be used to stop operators in a network.
countInputChannels(Map) - Method in DataflowOperator
countInputChannels(Map) - Method in DataflowSelector
countParallel(Object, Closure) - Method in GParsPoolUtil
Creates a Parallel Array out of the supplied collection/object and invokes the withFilter() method using the supplied rule as the filter predicate.
countParallel(Object) - Method in Parallel
Performs the count() operation using an asynchronous variant of the supplied closure to evaluate each collection's/object's element.
create(Object) - Method in InternalActor
create(int, Class, ForkJoinPool) - Method in ParallelArray
Creates a new ParallelArray using the given executor and an array of the given size constructed using the indicated base element type.
create(int, ForkJoinPool) - Method in ParallelDoubleArray
Creates a new ParallelDoubleArray using the given executor and an array of the given size
create(int, ForkJoinPool) - Method in ParallelLongArray
Creates a new ParallelLongArray using the given executor and an array of the given size
create(WithSerialId, UUID) - Method in SerialHandle
createActorMessage(Object) - Method in Actor
createArray(Map) - Method in PAUtils
createAtomicBlock(Map) - Method in GParsStm
A factory method to create custom atomic blocks allowing the caller to set desired transactional characteristics.
createCollection(Object) - Method in PAGroovyUtils
createCollection(Iterator) - Method in PAUtils
createComparator(Closure) - Method in PAUtils
Builds a comparator depending on the number of arguments accepted by the supplied closure.
createDDAClosure(DynamicDispatchActor) - Method in DDAClosure
Creates the closure for a given DDA
createDefaultThreadFactory() - Method in GParsExecutorsPool
createDefaultUncaughtExceptionHandler() - Method in GParsPool
createEmpty(int, Class, ForkJoinPool) - Method in ParallelArray
Creates a new ParallelArray using the given executor and an array of the given size constructed using the indicated base element type, but with an initial effective size of zero, enabling incremental insertion via ParallelArray#asList#asList operations.
createEmpty(int, ForkJoinPool) - Method in ParallelDoubleArray
Creates a new ParallelDoubleArray using the given executor and an array of the given size, but with an initial effective size of zero, enabling incremental insertion via ParallelDoubleArray#asList#asList operations.
createEmpty(int, ForkJoinPool) - Method in ParallelLongArray
Creates a new ParallelLongArray using the given executor and an array of the given size, but with an initial effective size of zero, enabling incremental insertion via ParallelLongArray#asList#asList operations.
createFromCopy(int, Object, ForkJoinPool) - Method in ParallelArray
Creates a new ParallelArray using an array of the given size, initially holding copies of the given source truncated or padded with nulls to obtain the specified length.
createFromCopy(int, double[], ForkJoinPool) - Method in ParallelDoubleArray
Creates a new ParallelDoubleArray using an array of the given size, initially holding copies of the given source truncated or padded with zeros to obtain the specified length.
createFromCopy(int, long[], ForkJoinPool) - Method in ParallelLongArray
Creates a new ParallelLongArray using an array of the given size, initially holding copies of the given source truncated or padded with zeros to obtain the specified length.
createFromPool(ThreadPoolExecutor) - Method in PGroupBuilder
Builds a PGroup instance from a ThreadPoolExecutor instance
createGroupByClosure(Closure, ConcurrentMap) - Method in PAUtils
Creates a closure that will insert elements in the appropriate group
createNewStream() - Method in DataflowStream
A factory method to create new instances of the correct class when needed
createNewStream() - Method in StreamCore
A factory method to create new instances of the correct class when needed
createNewStream() - Method in SyncDataflowStream
A factory method to create new instances of the correct class when needed
createObject(SerialContext) - Method in Actor.MyRemoteHandle
createObject(SerialContext) - Method in DefaultRemoteHandle
createObject(SerialContext) - Method in RemoteHandle
createPA(Map, ForkJoinPool) - Method in GParsPoolUtil
createPA(Object, ForkJoinPool) - Method in GParsPoolUtilHelper
createPAFromArray(Object, ForkJoinPool) - Method in GParsPoolUtilHelper
createPAFromCollection(def, ForkJoinPool) - Method in GParsPoolUtilHelper
createPool(boolean, int) - Method in DefaultPool
Creates a fixed-thread pool of given size.
createPool(int) - Method in FJPool
Creates a fork/join pool of given size.
createPool(int, ThreadFactory) - Method in GParsExecutorsPool
createPool(int, UncaughtExceptionHandler) - Method in GParsPool
createPool(boolean, int) - Method in PoolFactory
createReadChannel() - Method in DataflowBroadcast
Retrieves an implementation of DataflowReadChannel to read all messages submitted to the broadcast chanel.
createReadChannel() - Method in SyncDataflowBroadcast
Retrieves an implementation of DataflowReadChannel to read all messages submitted to the broadcast chanel.
createRemoteHandle(SerialHandle, SerialContext) - Method in Actor
createRemoteHandle(SerialHandle, SerialContext) - Method in WithSerialId
createResizeablePool(boolean, int) - Method in ResizeablePool
Creates a fixed-thread pool of given size.
createResults(int) - Method in PAS.FJDAppendAllDriver
createResults(int) - Method in PAS.FJDSelectAllDriver
createResults(int) - Method in PAS.FJLAppendAllDriver
createResults(int) - Method in PAS.FJLSelectAllDriver
createResults(int) - Method in PAS.FJOAppendAllDriver
createResults(int) - Method in PAS.FJOSelectAllDriver
createResults(int) - Method in PAS.FJSelectAllDriver
createSDAClosure(StaticDispatchActor) - Method in SDAClosure
Creates the closure for a given SDA
createThreadName() - Method in DefaultPool
Created a JVM-unique name for Actors' threads.
createTimer(String, boolean) - Method in TimerFactory
createUsingHandoff(Object, ForkJoinPool) - Method in ParallelArray
Creates a new ParallelArray initially using the given array and executor.
createUsingHandoff(double[], ForkJoinPool) - Method in ParallelDoubleArray
Creates a new ParallelDoubleArray initially using the given array and executor.
createUsingHandoff(long[], ForkJoinPool) - Method in ParallelLongArray
Creates a new ParallelLongArray initially using the given array and executor.
createVariable() - Method in DataflowQueue
Creates a new variable to perform the next data exchange
createVariable() - Method in SyncDataflowQueue
Creates a new variable to perform the next data exchange
cumulate(DoubleReducer, double) - Method in AbstractParallelAnyArray.DUPap
cumulate(LongReducer, long) - Method in AbstractParallelAnyArray.LUPap
cumulate(Reducer, Object) - Method in AbstractParallelAnyArray.OUPap
cumulate(Reducer, Object) - Method in ParallelArray
Replaces each element with the running cumulation of applying the given reducer.
cumulate(Reducer, Object) - Method in ParallelArrayWithBounds
Replaces each element with the running cumulation of applying the given reducer.
cumulate(DoubleReducer, double) - Method in ParallelDoubleArray
Replaces each element with the running cumulation of applying the given reducer.
cumulate(DoubleReducer, double) - Method in ParallelDoubleArrayWithBounds
Replaces each element with the running cumulation of applying the given reducer.
cumulate(LongReducer, long) - Method in ParallelLongArray
Replaces each element with the running cumulation of applying the given reducer.
cumulate(LongReducer, long) - Method in ParallelLongArrayWithBounds
Replaces each element with the running cumulation of applying the given reducer.
CUMULATE - Field in PAS.FJScan
cumulateLeaf(int, int, FJScan) - Method in PAS.FJDCumulateOp
cumulateLeaf(int, int, FJScan) - Method in PAS.FJDCumulatePlusOp
cumulateLeaf(int, int, FJScan) - Method in PAS.FJDPrecumulateOp
cumulateLeaf(int, int, FJScan) - Method in PAS.FJDPrecumulatePlusOp
cumulateLeaf(int, int, FJScan) - Method in PAS.FJLCumulateOp
cumulateLeaf(int, int, FJScan) - Method in PAS.FJLCumulatePlusOp
cumulateLeaf(int, int, FJScan) - Method in PAS.FJLPrecumulateOp
cumulateLeaf(int, int, FJScan) - Method in PAS.FJLPrecumulatePlusOp
cumulateLeaf(int, int, FJScan) - Method in PAS.FJOCumulateOp
cumulateLeaf(int, int, FJScan) - Method in PAS.FJOPrecumulateOp
cumulateLeaf(int, int, FJScan) - Method in PAS.FJScanOp
cumulateSum() - Method in AbstractParallelAnyArray.DUPap
cumulateSum() - Method in AbstractParallelAnyArray.LUPap
cumulateSum() - Method in ParallelDoubleArray
Replaces each element with the running sum
cumulateSum() - Method in ParallelDoubleArrayWithBounds
Replaces each element with the running sum
cumulateSum() - Method in ParallelLongArray
Replaces each element with the running sum
cumulateSum() - Method in ParallelLongArrayWithBounds
Replaces each element with the running sum
current - Field in FListIterator
currentActorPerThread - Field in Actor
Maps each thread to the actor it currently processes.
currentPoolStack - Field in GParsExecutorsPool
Maps threads to their appropriate thread pools
currentPoolStack - Field in GParsPool
Maps threads to their appropriate thread pools
currentSender - Field in AbstractLoopingActor
currentTable - Field in CustomConcurrentHashMap.HashIterator
currentThread - Field in Actor
currentTimerTask - Field in AbstractLoopingActor
cursor - Field in AbstractParallelAnyArray.FilteredAsDoubleIterator
cursor - Field in AbstractParallelAnyArray.FilteredAsLongIterator
cursor - Field in AbstractParallelAnyArray.FilteredIterator
cursor - Field in AbstractParallelAnyArray.UnfilteredAsDoubleIterator
cursor - Field in AbstractParallelAnyArray.UnfilteredAsLongIterator
cursor - Field in AbstractParallelAnyArray.UnfilteredIterator
cursor - Field in ParallelArray.ListIter
cursor - Field in ParallelArray.ParallelArrayIterator
cursor - Field in ParallelDoubleArray.ListIter
cursor - Field in ParallelDoubleArray.ParallelDoubleArrayIterator
cursor - Field in ParallelLongArray.ListIter
cursor - Field in ParallelLongArray.ParallelLongArrayIterator
CustomConcurrentHashMap - Class in groovyx.gpars.extra166y
A java.util.ConcurrentMap supporting user-defined equivalence comparisons, soft, weak, or strong keys and values, and user-supplied computational methods for setting and updating values.
CustomConcurrentHashMap.EmbeddedSoftReference - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.EmbeddedSoftReference(Object, Reclaimable) - Constructor in CustomConcurrentHashMap.EmbeddedSoftReference
CustomConcurrentHashMap.EmbeddedWeakReference - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.EmbeddedWeakReference(Object, Reclaimable) - Constructor in CustomConcurrentHashMap.EmbeddedWeakReference
CustomConcurrentHashMap.EntryIterator - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.EntryIterator() - Constructor in CustomConcurrentHashMap.EntryIterator
CustomConcurrentHashMap.EntrySet - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.EntrySet() - Constructor in CustomConcurrentHashMap.EntrySet
CustomConcurrentHashMap.Equivalence - Interface in groovyx.gpars.extra166y
An object performing equality comparisons, along with a hash function consistent with this comparison.
CustomConcurrentHashMap.EquivalenceUsingEquals - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.EquivalenceUsingEquals() - Constructor in CustomConcurrentHashMap.EquivalenceUsingEquals
CustomConcurrentHashMap.EquivalenceUsingIdentity - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.EquivalenceUsingIdentity() - Constructor in CustomConcurrentHashMap.EquivalenceUsingIdentity
CustomConcurrentHashMap.HashIterator - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.HashIterator() - Constructor in CustomConcurrentHashMap.HashIterator
CustomConcurrentHashMap.IntKeyIntValueNode - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.IntKeyIntValueNode(int, Object, Object) - Constructor in CustomConcurrentHashMap.IntKeyIntValueNode
CustomConcurrentHashMap.IntKeyIntValueNodeFactory - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.IntKeyIntValueNodeFactory() - Constructor in CustomConcurrentHashMap.IntKeyIntValueNodeFactory
CustomConcurrentHashMap.IntKeyNode - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.IntKeyNode(int, Object) - Constructor in CustomConcurrentHashMap.IntKeyNode
CustomConcurrentHashMap.IntKeySelfValueNode - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.IntKeySelfValueNode(int, Object) - Constructor in CustomConcurrentHashMap.IntKeySelfValueNode
CustomConcurrentHashMap.IntKeySelfValueNodeFactory - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.IntKeySelfValueNodeFactory() - Constructor in CustomConcurrentHashMap.IntKeySelfValueNodeFactory
CustomConcurrentHashMap.IntKeySoftValueNode - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.IntKeySoftValueNode(int, Object, Object, CustomConcurrentHashMap) - Constructor in CustomConcurrentHashMap.IntKeySoftValueNode
CustomConcurrentHashMap.IntKeySoftValueNodeFactory - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.IntKeySoftValueNodeFactory() - Constructor in CustomConcurrentHashMap.IntKeySoftValueNodeFactory
CustomConcurrentHashMap.IntKeyStrongValueNode - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.IntKeyStrongValueNode(int, Object, Object) - Constructor in CustomConcurrentHashMap.IntKeyStrongValueNode
CustomConcurrentHashMap.IntKeyStrongValueNodeFactory - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.IntKeyStrongValueNodeFactory() - Constructor in CustomConcurrentHashMap.IntKeyStrongValueNodeFactory
CustomConcurrentHashMap.IntKeyWeakValueNode - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.IntKeyWeakValueNode(int, Object, Object, CustomConcurrentHashMap) - Constructor in CustomConcurrentHashMap.IntKeyWeakValueNode
CustomConcurrentHashMap.IntKeyWeakValueNodeFactory - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.IntKeyWeakValueNodeFactory() - Constructor in CustomConcurrentHashMap.IntKeyWeakValueNodeFactory
CustomConcurrentHashMap.KeyIterator - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.KeyIterator() - Constructor in CustomConcurrentHashMap.KeyIterator
CustomConcurrentHashMap.KeySet - Class in groovyx.gpars.extra166y
A hash-based set with properties identical to those of Collections.newSetFromMap applied to a CustomConcurrentHashMap, but possibly more space-efficient.
CustomConcurrentHashMap.KeySet(Strength, Equivalence, int) - Constructor in CustomConcurrentHashMap.KeySet
Creates a set with the given parameters
CustomConcurrentHashMap.KeySetView - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.KeySetView() - Constructor in CustomConcurrentHashMap.KeySetView
CustomConcurrentHashMap.LinkedIntKeyIntValueNode - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.LinkedIntKeyIntValueNode(int, Object, Object, Node) - Constructor in CustomConcurrentHashMap.LinkedIntKeyIntValueNode
CustomConcurrentHashMap.LinkedIntKeySelfValueNode - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.LinkedIntKeySelfValueNode(int, Object, Node) - Constructor in CustomConcurrentHashMap.LinkedIntKeySelfValueNode
CustomConcurrentHashMap.LinkedIntKeySoftValueNode - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.LinkedIntKeySoftValueNode(int, Object, Object, CustomConcurrentHashMap, Node) - Constructor in CustomConcurrentHashMap.LinkedIntKeySoftValueNode
CustomConcurrentHashMap.LinkedIntKeyStrongValueNode - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.LinkedIntKeyStrongValueNode(int, Object, Object, Node) - Constructor in CustomConcurrentHashMap.LinkedIntKeyStrongValueNode
CustomConcurrentHashMap.LinkedIntKeyWeakValueNode - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.LinkedIntKeyWeakValueNode(int, Object, Object, CustomConcurrentHashMap, Node) - Constructor in CustomConcurrentHashMap.LinkedIntKeyWeakValueNode
CustomConcurrentHashMap.LinkedSoftKeyIntValueNode - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.LinkedSoftKeyIntValueNode(int, Object, Object, CustomConcurrentHashMap, Node) - Constructor in CustomConcurrentHashMap.LinkedSoftKeyIntValueNode
CustomConcurrentHashMap.LinkedSoftKeySelfValueNode - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.LinkedSoftKeySelfValueNode(int, Object, CustomConcurrentHashMap, Node) - Constructor in CustomConcurrentHashMap.LinkedSoftKeySelfValueNode
CustomConcurrentHashMap.LinkedSoftKeySoftValueNode - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.LinkedSoftKeySoftValueNode(int, Object, Object, CustomConcurrentHashMap, Node) - Constructor in CustomConcurrentHashMap.LinkedSoftKeySoftValueNode
CustomConcurrentHashMap.LinkedSoftKeyStrongValueNode - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.LinkedSoftKeyStrongValueNode(int, Object, Object, CustomConcurrentHashMap, Node) - Constructor in CustomConcurrentHashMap.LinkedSoftKeyStrongValueNode
CustomConcurrentHashMap.LinkedSoftKeyWeakValueNode - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.LinkedSoftKeyWeakValueNode(int, Object, Object, CustomConcurrentHashMap, Node) - Constructor in CustomConcurrentHashMap.LinkedSoftKeyWeakValueNode
CustomConcurrentHashMap.LinkedStrongKeyIntValueNode - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.LinkedStrongKeyIntValueNode(int, Object, Object, Node) - Constructor in CustomConcurrentHashMap.LinkedStrongKeyIntValueNode
CustomConcurrentHashMap.LinkedStrongKeySelfValueNode - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.LinkedStrongKeySelfValueNode(int, Object, Node) - Constructor in CustomConcurrentHashMap.LinkedStrongKeySelfValueNode
CustomConcurrentHashMap.LinkedStrongKeySoftValueNode - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.LinkedStrongKeySoftValueNode(int, Object, Object, CustomConcurrentHashMap, Node) - Constructor in CustomConcurrentHashMap.LinkedStrongKeySoftValueNode
CustomConcurrentHashMap.LinkedStrongKeyStrongValueNode - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.LinkedStrongKeyStrongValueNode(int, Object, Object, Node) - Constructor in CustomConcurrentHashMap.LinkedStrongKeyStrongValueNode
CustomConcurrentHashMap.LinkedStrongKeyWeakValueNode - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.LinkedStrongKeyWeakValueNode(int, Object, Object, CustomConcurrentHashMap, Node) - Constructor in CustomConcurrentHashMap.LinkedStrongKeyWeakValueNode
CustomConcurrentHashMap.LinkedWeakKeyIntValueNode - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.LinkedWeakKeyIntValueNode(int, Object, Object, CustomConcurrentHashMap, Node) - Constructor in CustomConcurrentHashMap.LinkedWeakKeyIntValueNode
CustomConcurrentHashMap.LinkedWeakKeySelfValueNode - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.LinkedWeakKeySelfValueNode(int, Object, CustomConcurrentHashMap, Node) - Constructor in CustomConcurrentHashMap.LinkedWeakKeySelfValueNode
CustomConcurrentHashMap.LinkedWeakKeySoftValueNode - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.LinkedWeakKeySoftValueNode(int, Object, Object, CustomConcurrentHashMap, Node) - Constructor in CustomConcurrentHashMap.LinkedWeakKeySoftValueNode
CustomConcurrentHashMap.LinkedWeakKeyStrongValueNode - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.LinkedWeakKeyStrongValueNode(int, Object, Object, CustomConcurrentHashMap, Node) - Constructor in CustomConcurrentHashMap.LinkedWeakKeyStrongValueNode
CustomConcurrentHashMap.LinkedWeakKeyWeakValueNode - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.LinkedWeakKeyWeakValueNode(int, Object, Object, CustomConcurrentHashMap, Node) - Constructor in CustomConcurrentHashMap.LinkedWeakKeyWeakValueNode
CustomConcurrentHashMap.MappingFunction - Interface in groovyx.gpars.extra166y
A function computing a mapping from the given key to a value, or null if there is no mapping.
CustomConcurrentHashMap.Node - Interface in groovyx.gpars.extra166y
An object maintaining a key-value mapping.
CustomConcurrentHashMap.NodeFactory - Interface in groovyx.gpars.extra166y
A factory for Nodes.
CustomConcurrentHashMap.Reclaimable - Interface in groovyx.gpars.extra166y
An object that may be subject to cleanup operations when removed from a java.lang.ref.ReferenceQueue
CustomConcurrentHashMap.ReclamationThread - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.ReclamationThread(ReferenceQueue) - Constructor in CustomConcurrentHashMap.ReclamationThread
CustomConcurrentHashMap.RemappingFunction - Interface in groovyx.gpars.extra166y
A function computing a new mapping from the given key and its current value to a new value, or null if there is no mapping
CustomConcurrentHashMap.Segment - Class in groovyx.gpars.extra166y
Each Segment holds a count and table corresponding to a segment of the table.
CustomConcurrentHashMap.Segment() - Constructor in CustomConcurrentHashMap.Segment
CustomConcurrentHashMap.SoftKeyIntValueNode - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.SoftKeyIntValueNode(int, Object, Object, CustomConcurrentHashMap) - Constructor in CustomConcurrentHashMap.SoftKeyIntValueNode
CustomConcurrentHashMap.SoftKeyIntValueNodeFactory - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.SoftKeyIntValueNodeFactory() - Constructor in CustomConcurrentHashMap.SoftKeyIntValueNodeFactory
CustomConcurrentHashMap.SoftKeyNode - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.SoftKeyNode(int, Object, CustomConcurrentHashMap) - Constructor in CustomConcurrentHashMap.SoftKeyNode
CustomConcurrentHashMap.SoftKeySelfValueNode - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.SoftKeySelfValueNode(int, Object, CustomConcurrentHashMap) - Constructor in CustomConcurrentHashMap.SoftKeySelfValueNode
CustomConcurrentHashMap.SoftKeySelfValueNodeFactory - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.SoftKeySelfValueNodeFactory() - Constructor in CustomConcurrentHashMap.SoftKeySelfValueNodeFactory
CustomConcurrentHashMap.SoftKeySoftValueNode - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.SoftKeySoftValueNode(int, Object, Object, CustomConcurrentHashMap) - Constructor in CustomConcurrentHashMap.SoftKeySoftValueNode
CustomConcurrentHashMap.SoftKeySoftValueNodeFactory - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.SoftKeySoftValueNodeFactory() - Constructor in CustomConcurrentHashMap.SoftKeySoftValueNodeFactory
CustomConcurrentHashMap.SoftKeyStrongValueNode - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.SoftKeyStrongValueNode(int, Object, Object, CustomConcurrentHashMap) - Constructor in CustomConcurrentHashMap.SoftKeyStrongValueNode
CustomConcurrentHashMap.SoftKeyStrongValueNodeFactory - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.SoftKeyStrongValueNodeFactory() - Constructor in CustomConcurrentHashMap.SoftKeyStrongValueNodeFactory
CustomConcurrentHashMap.SoftKeyWeakValueNode - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.SoftKeyWeakValueNode(int, Object, Object, CustomConcurrentHashMap) - Constructor in CustomConcurrentHashMap.SoftKeyWeakValueNode
CustomConcurrentHashMap.SoftKeyWeakValueNodeFactory - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.SoftKeyWeakValueNodeFactory() - Constructor in CustomConcurrentHashMap.SoftKeyWeakValueNodeFactory
CustomConcurrentHashMap.Strength - Enum in groovyx.gpars.extra166y
The strength of keys and values that may be held by maps. strong denotes ordinary objects. weak and soft denote the corresponding java.lang.ref.Reference types.
CustomConcurrentHashMap.StrongKeyIntValueNode - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.StrongKeyIntValueNode(int, Object, Object) - Constructor in CustomConcurrentHashMap.StrongKeyIntValueNode
CustomConcurrentHashMap.StrongKeyIntValueNodeFactory - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.StrongKeyIntValueNodeFactory() - Constructor in CustomConcurrentHashMap.StrongKeyIntValueNodeFactory
CustomConcurrentHashMap.StrongKeyNode - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.StrongKeyNode(int, Object) - Constructor in CustomConcurrentHashMap.StrongKeyNode
CustomConcurrentHashMap.StrongKeySelfValueNode - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.StrongKeySelfValueNode(int, Object) - Constructor in CustomConcurrentHashMap.StrongKeySelfValueNode
CustomConcurrentHashMap.StrongKeySelfValueNodeFactory - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.StrongKeySelfValueNodeFactory() - Constructor in CustomConcurrentHashMap.StrongKeySelfValueNodeFactory
CustomConcurrentHashMap.StrongKeySoftValueNode - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.StrongKeySoftValueNode(int, Object, Object, CustomConcurrentHashMap) - Constructor in CustomConcurrentHashMap.StrongKeySoftValueNode
CustomConcurrentHashMap.StrongKeySoftValueNodeFactory - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.StrongKeySoftValueNodeFactory() - Constructor in CustomConcurrentHashMap.StrongKeySoftValueNodeFactory
CustomConcurrentHashMap.StrongKeyStrongValueNode - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.StrongKeyStrongValueNode(int, Object, Object) - Constructor in CustomConcurrentHashMap.StrongKeyStrongValueNode
CustomConcurrentHashMap.StrongKeyStrongValueNodeFactory - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.StrongKeyStrongValueNodeFactory() - Constructor in CustomConcurrentHashMap.StrongKeyStrongValueNodeFactory
CustomConcurrentHashMap.StrongKeyWeakValueNode - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.StrongKeyWeakValueNode(int, Object, Object, CustomConcurrentHashMap) - Constructor in CustomConcurrentHashMap.StrongKeyWeakValueNode
CustomConcurrentHashMap.StrongKeyWeakValueNodeFactory - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.StrongKeyWeakValueNodeFactory() - Constructor in CustomConcurrentHashMap.StrongKeyWeakValueNodeFactory
CustomConcurrentHashMap.TerminalIntKeyIntValueNode - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.TerminalIntKeyIntValueNode(int, Object, Object) - Constructor in CustomConcurrentHashMap.TerminalIntKeyIntValueNode
CustomConcurrentHashMap.TerminalIntKeySelfValueNode - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.TerminalIntKeySelfValueNode(int, Object) - Constructor in CustomConcurrentHashMap.TerminalIntKeySelfValueNode
CustomConcurrentHashMap.TerminalIntKeySoftValueNode - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.TerminalIntKeySoftValueNode(int, Object, Object, CustomConcurrentHashMap) - Constructor in CustomConcurrentHashMap.TerminalIntKeySoftValueNode
CustomConcurrentHashMap.TerminalIntKeyStrongValueNode - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.TerminalIntKeyStrongValueNode(int, Object, Object) - Constructor in CustomConcurrentHashMap.TerminalIntKeyStrongValueNode
CustomConcurrentHashMap.TerminalIntKeyWeakValueNode - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.TerminalIntKeyWeakValueNode(int, Object, Object, CustomConcurrentHashMap) - Constructor in CustomConcurrentHashMap.TerminalIntKeyWeakValueNode
CustomConcurrentHashMap.TerminalSoftKeyIntValueNode - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.TerminalSoftKeyIntValueNode(int, Object, Object, CustomConcurrentHashMap) - Constructor in CustomConcurrentHashMap.TerminalSoftKeyIntValueNode
CustomConcurrentHashMap.TerminalSoftKeySelfValueNode - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.TerminalSoftKeySelfValueNode(int, Object, CustomConcurrentHashMap) - Constructor in CustomConcurrentHashMap.TerminalSoftKeySelfValueNode
CustomConcurrentHashMap.TerminalSoftKeySoftValueNode - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.TerminalSoftKeySoftValueNode(int, Object, Object, CustomConcurrentHashMap) - Constructor in CustomConcurrentHashMap.TerminalSoftKeySoftValueNode
CustomConcurrentHashMap.TerminalSoftKeyStrongValueNode - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.TerminalSoftKeyStrongValueNode(int, Object, Object, CustomConcurrentHashMap) - Constructor in CustomConcurrentHashMap.TerminalSoftKeyStrongValueNode
CustomConcurrentHashMap.TerminalSoftKeyWeakValueNode - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.TerminalSoftKeyWeakValueNode(int, Object, Object, CustomConcurrentHashMap) - Constructor in CustomConcurrentHashMap.TerminalSoftKeyWeakValueNode
CustomConcurrentHashMap.TerminalStrongKeyIntValueNode - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.TerminalStrongKeyIntValueNode(int, Object, Object) - Constructor in CustomConcurrentHashMap.TerminalStrongKeyIntValueNode
CustomConcurrentHashMap.TerminalStrongKeySelfValueNode - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.TerminalStrongKeySelfValueNode(int, Object) - Constructor in CustomConcurrentHashMap.TerminalStrongKeySelfValueNode
CustomConcurrentHashMap.TerminalStrongKeySoftValueNode - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.TerminalStrongKeySoftValueNode(int, Object, Object, CustomConcurrentHashMap) - Constructor in CustomConcurrentHashMap.TerminalStrongKeySoftValueNode
CustomConcurrentHashMap.TerminalStrongKeyStrongValueNode - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.TerminalStrongKeyStrongValueNode(int, Object, Object) - Constructor in CustomConcurrentHashMap.TerminalStrongKeyStrongValueNode
CustomConcurrentHashMap.TerminalStrongKeyWeakValueNode - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.TerminalStrongKeyWeakValueNode(int, Object, Object, CustomConcurrentHashMap) - Constructor in CustomConcurrentHashMap.TerminalStrongKeyWeakValueNode
CustomConcurrentHashMap.TerminalWeakKeyIntValueNode - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.TerminalWeakKeyIntValueNode(int, Object, Object, CustomConcurrentHashMap) - Constructor in CustomConcurrentHashMap.TerminalWeakKeyIntValueNode
CustomConcurrentHashMap.TerminalWeakKeySelfValueNode - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.TerminalWeakKeySelfValueNode(int, Object, CustomConcurrentHashMap) - Constructor in CustomConcurrentHashMap.TerminalWeakKeySelfValueNode
CustomConcurrentHashMap.TerminalWeakKeySoftValueNode - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.TerminalWeakKeySoftValueNode(int, Object, Object, CustomConcurrentHashMap) - Constructor in CustomConcurrentHashMap.TerminalWeakKeySoftValueNode
CustomConcurrentHashMap.TerminalWeakKeyStrongValueNode - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.TerminalWeakKeyStrongValueNode(int, Object, Object, CustomConcurrentHashMap) - Constructor in CustomConcurrentHashMap.TerminalWeakKeyStrongValueNode
CustomConcurrentHashMap.TerminalWeakKeyWeakValueNode - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.TerminalWeakKeyWeakValueNode(int, Object, Object, CustomConcurrentHashMap) - Constructor in CustomConcurrentHashMap.TerminalWeakKeyWeakValueNode
CustomConcurrentHashMap.ValueIterator - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.ValueIterator() - Constructor in CustomConcurrentHashMap.ValueIterator
CustomConcurrentHashMap.Values - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.Values() - Constructor in CustomConcurrentHashMap.Values
CustomConcurrentHashMap.WeakKeyIntValueNode - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.WeakKeyIntValueNode(int, Object, Object, CustomConcurrentHashMap) - Constructor in CustomConcurrentHashMap.WeakKeyIntValueNode
CustomConcurrentHashMap.WeakKeyIntValueNodeFactory - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.WeakKeyIntValueNodeFactory() - Constructor in CustomConcurrentHashMap.WeakKeyIntValueNodeFactory
CustomConcurrentHashMap.WeakKeyNode - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.WeakKeyNode(int, Object, CustomConcurrentHashMap) - Constructor in CustomConcurrentHashMap.WeakKeyNode
CustomConcurrentHashMap.WeakKeySelfValueNode - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.WeakKeySelfValueNode(int, Object, CustomConcurrentHashMap) - Constructor in CustomConcurrentHashMap.WeakKeySelfValueNode
CustomConcurrentHashMap.WeakKeySelfValueNodeFactory - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.WeakKeySelfValueNodeFactory() - Constructor in CustomConcurrentHashMap.WeakKeySelfValueNodeFactory
CustomConcurrentHashMap.WeakKeySoftValueNode - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.WeakKeySoftValueNode(int, Object, Object, CustomConcurrentHashMap) - Constructor in CustomConcurrentHashMap.WeakKeySoftValueNode
CustomConcurrentHashMap.WeakKeySoftValueNodeFactory - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.WeakKeySoftValueNodeFactory() - Constructor in CustomConcurrentHashMap.WeakKeySoftValueNodeFactory
CustomConcurrentHashMap.WeakKeyStrongValueNode - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.WeakKeyStrongValueNode(int, Object, Object, CustomConcurrentHashMap) - Constructor in CustomConcurrentHashMap.WeakKeyStrongValueNode
CustomConcurrentHashMap.WeakKeyStrongValueNodeFactory - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.WeakKeyStrongValueNodeFactory() - Constructor in CustomConcurrentHashMap.WeakKeyStrongValueNodeFactory
CustomConcurrentHashMap.WeakKeyWeakValueNode - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.WeakKeyWeakValueNode(int, Object, Object, CustomConcurrentHashMap) - Constructor in CustomConcurrentHashMap.WeakKeyWeakValueNode
CustomConcurrentHashMap.WeakKeyWeakValueNodeFactory - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.WeakKeyWeakValueNodeFactory() - Constructor in CustomConcurrentHashMap.WeakKeyWeakValueNodeFactory
CustomConcurrentHashMap.WriteThroughEntry - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.WriteThroughEntry(Object, Object) - Constructor in CustomConcurrentHashMap.WriteThroughEntry
CustomConcurrentHashMap() - Constructor in CustomConcurrentHashMap
customEvent(DataflowProcessor, Object) - Method in DataflowEventAdapter
Invoked when the fireCustomEvent() method is triggered manually on a dataflow operator/selector.
customEvent(DataflowProcessor, Object) - Method in DataflowEventListener
Invoked when the fireCustomEvent() method is triggered manually on a dataflow operator/selector When using maxForks, the method may be invoked from threads running the forks.
cycleAllowed - Property in KanbanFlow
If adapted, this must be set before calling link()

D

data - Field in AgentBase
Holds the internal mutable state
DATA_FLOW_GROUP - Field in Dataflow
The parallel group used by all Dataflow Concurrency actors by default.
DataCallback - Class in groovyx.gpars.dataflow
A helper class enabling the 'whenBound()' or 'getValAsync' functionality of a DataflowVariable and DataflowQueue, as well as 'sendAndContinue()' on actors.
DataCallback(Closure, PGroup) - Constructor in DataCallback
@param code The closure to run
DataCallbackWithPool - Class in groovyx.gpars.dataflow
A helper class enabling the 'whenBound()' or 'getValAsync' functionality of a DataflowVariable and DataflowQueue, whenever a thread pool instead of a PGroup is specified..
DataCallbackWithPool(Pool, Closure) - Constructor in DataCallbackWithPool
@param pool The thread pool to schedule on
Dataflow - Class in groovyx.gpars.dataflow
Contains factory methods to create dataflow actors and starting them.
Dataflow() - Constructor in Dataflow
DataflowBroadcast - Class in groovyx.gpars.dataflow
Offers a deterministic one-to-many and many-to-many messaging alternative to DataflowQueue.
DataflowBroadcast() - Constructor in DataflowBroadcast
Creates a new instance
DataflowChannel - Interface in groovyx.gpars.dataflow
A common interface for all dataflow variables, streams or queues
DataflowChannelEventDistibutor - Interface in groovyx.gpars.dataflow.impl
@author Vaclav Pech
DataflowChannelEventListenerManager - Interface in groovyx.gpars.dataflow.impl
@author Vaclav Pech
DataflowChannelEventOrchestrator - Class in groovyx.gpars.dataflow.impl
Groups the listener-related functionality shared by dataflow channels
DataflowChannelEventOrchestrator() - Constructor in DataflowChannelEventOrchestrator
DataflowChannelListener - Interface in groovyx.gpars.dataflow
Gets notified about state changes inside DataflowReadChannels
DataflowComplexExpression - Class in groovyx.gpars.dataflow.expression
Provides the infrastructure for dataflow expressions to evaluate arguments.
DataflowComplexExpression(Object) - Constructor in DataflowComplexExpression
DataflowEventAdapter - Class in groovyx.gpars.dataflow.operator
A default empty implementation of DataflowEventListener
DataflowEventAdapter() - Constructor in DataflowEventAdapter
DataflowEventListener - Interface in groovyx.gpars.dataflow.operator
Enables external entities to observe the state of dataflow selectors and operators
DataflowExpression - Class in groovyx.gpars.dataflow.expression
The base class for all dataflow elements.
DataflowExpression.BindDataflow - Class in groovyx.gpars.dataflow.expression
Represents a remote message binding a value to a remoted DataflowExpression
DataflowExpression.BindDataflow(DataflowExpression, Object, UUID) - Constructor in DataflowExpression.BindDataflow
@param expr The local DataflowExpression instance
DataflowExpression.DataflowExpressionsCollector - Class in groovyx.gpars.dataflow.expression
Listener for availability of data flow expressions we depend on.
DataflowExpression.DataflowExpressionsCollector() - Constructor in DataflowExpression.DataflowExpressionsCollector
DataflowExpression.TransformMany - Class in groovyx.gpars.dataflow.expression
DataflowExpression.TransformMany(Collection, Closure) - Constructor in DataflowExpression.TransformMany
DataflowExpression.TransformOne - Class in groovyx.gpars.dataflow.expression
DataflowExpression.TransformOne(Object, Closure) - Constructor in DataflowExpression.TransformOne
DataflowExpression.WaitingThread - Class in groovyx.gpars.dataflow.expression
A logical representation of a synchronous or asynchronous request to read the value once it is bound.
DataflowExpression.WaitingThread(Thread, WaitingThread, Object, MessageStream) - Constructor in DataflowExpression.WaitingThread
Creates a representation of the request to read the value once it is bound
DataflowExpression() - Constructor in DataflowExpression
DataflowGetPropertyExpression - Class in groovyx.gpars.dataflow.expression
A DFE, which evaluates a property when the receiver becomes available
DataflowGetPropertyExpression(DataflowExpression, String) - Constructor in DataflowGetPropertyExpression
DataflowInvocationExpression - Class in groovyx.gpars.dataflow.expression
A dataflow expression, which invokes a method after the receiver as well as all the arguments become available
DataflowInvocationExpression(Object, String, Object) - Constructor in DataflowInvocationExpression
DataflowMessagingRunnable - Class in groovyx.gpars
Represents a multi-argument Closure when using GPars dataflow operators and selectors through the Java API.
DataflowMessagingRunnable(Object, int) - Constructor in DataflowMessagingRunnable
DataflowOperator - Class in groovyx.gpars.dataflow.operator
Dataflow selectors and operators (processors) form the basic units in dataflow networks.
DataflowOperator(PGroup, Map, Closure) - Constructor in DataflowOperator
Creates an operator After creation the operator needs to be started using the start() method.
DataflowOperatorActor - Class in groovyx.gpars.dataflow.operator
An operator's internal actor.
DataflowOperatorActor(DataflowOperator, PGroup, List, List, Closure) - Constructor in DataflowOperatorActor
DataflowPrioritySelector - Class in groovyx.gpars.dataflow.operator
Dataflow selectors and operators (processors) form the basic units in dataflow networks.
DataflowPrioritySelector(PGroup, Map, Closure) - Constructor in DataflowPrioritySelector
Creates a priority selector After creation the selector needs to be started using the start() method.
DataflowProcessor - Class in groovyx.gpars.dataflow.operator
Dataflow selectors and operators (processors) form the basic units in dataflow networks.
DataflowProcessor(Map, Closure) - Constructor in DataflowProcessor
Creates a processor After creation the processor needs to be started using the start() method.
DataflowProcessorActor - Class in groovyx.gpars.dataflow.operator
A base actor class for operators' and selectors' actors
DataflowProcessorActor(DataflowProcessor, PGroup, List, List, Closure) - Constructor in DataflowProcessorActor
DataflowProcessorAtomicBoundAllClosure - Class in groovyx.gpars.dataflow.operator
DataflowProcessorAtomicBoundAllClosure() - Constructor in DataflowProcessorAtomicBoundAllClosure
DataflowQueue - Class in groovyx.gpars.dataflow
Represents a thread-safe data flow stream.
DataflowQueue() - Constructor in DataflowQueue
DataflowReadChannel - Interface in groovyx.gpars.dataflow
A common interface for all dataflow variables, streams or queues
Dataflows - Class in groovyx.gpars.dataflow
Convenience class that makes working with DataflowVariables more comfortable.
Dataflows() - Constructor in Dataflows
Constructor with default values for building the underlying ConcurrentHashMap
DataflowSelector - Class in groovyx.gpars.dataflow.operator
Dataflow selectors and operators (processors) form the basic units in dataflow networks.
DataflowSelector(PGroup, Map, Closure) - Constructor in DataflowSelector
Creates a selector After creation the selector needs to be started using the start() method.
DataflowSelectorActor - Class in groovyx.gpars.dataflow.operator
An selector's internal actor.
DataflowSelectorActor(DataflowSelector, PGroup, List, List, Closure) - Constructor in DataflowSelectorActor
DataflowStream - Class in groovyx.gpars.dataflow.stream
Represents a deterministic dataflow channel.
DataflowStream(Collection, Collection) - Constructor in DataflowStream
DataflowStreamReadAdapter - Class in groovyx.gpars.dataflow.stream
Adapts a DataflowStream to accommodate for the DataflowReadChannel interface.
DataflowStreamReadAdapter(StreamCore) - Constructor in DataflowStreamReadAdapter
Creates a new adapter
DataflowStreamWriteAdapter - Class in groovyx.gpars.dataflow.stream
Adapts a DataflowStream to accommodate for the DataflowWriteChannel interface.
DataflowStreamWriteAdapter(StreamCore) - Constructor in DataflowStreamWriteAdapter
Creates a new adapter
DataflowVariable - Class in groovyx.gpars.dataflow
Represents a thread-safe single-assignment, multi-read variable.
DataflowVariable.RemoteDataflowVariable - Class in groovyx.gpars.dataflow
DataflowVariable.RemoteDataflowVariable(RemoteHost) - Constructor in DataflowVariable.RemoteDataflowVariable
DataflowVariable() - Constructor in DataflowVariable
Creates a new unbound Dataflow Variable
DataflowWriteChannel - Interface in groovyx.gpars.dataflow
A common interface for all writable dataflow variables, streams or queues
DDAClosure - Class in groovyx.gpars.actor.impl
Creates a DDA closure to invoke appropriate actor's message handlers based on message runtime type
DDAClosure() - Constructor in DDAClosure
DDAHelper - Class in groovyx.gpars.actor
Hooks the supplied when handlers to DDAs
DDAHelper() - Constructor in DDAHelper
decode(ChannelHandlerContext, Channel, ChannelBuffer) - Method in RemoteObjectDecoder
decreaseCount() - Method in ResizeableCountDownLatch
decreaseCount() - Method in ResizeableCountDownLatch.Sync
decrementCount() - Method in CustomConcurrentHashMap.Segment
decrementParties() - Method in StreamCore
Decreases the number of parties required to perform the data exchange
decrementParties() - Method in SyncDataflowStream
Decreases the number of parties required to perform the data exchange
decrementParties() - Method in SyncDataflowVariable
Decreases the number of parties required to perform data exchange by one
DEFAULT_CONCURRENCY_LEVEL - Field in Dataflows
DEFAULT_DELAY - Field in GracefulShutdownMonitor
DEFAULT_INITIAL_CAPACITY - Field in Dataflows
DEFAULT_LOAD_FACTOR - Field in Dataflows
DEFAULT_SHUTDOWN_TIMEOUT - Field in FJPool
DefaultActor - Class in groovyx.gpars.actor
The DefaultActor class is the base for all stateful actors, who need to maintain implicit state between subsequent message arrivals.
DefaultActor(Runnable) - Constructor in DefaultActor
Creates an actor, which will execute the supplied code
DefaultActorClosure - Class in groovyx.gpars.actor
Represents the DDA closure to invoke appropriate message handlers based on message runtime type
DefaultActorClosure(DefaultActor) - Constructor in DefaultActorClosure
defaultActorPGroup - Field in Actors
The default actor group to share by all actors created through the Actors class.
defaultAtomicBlock - Field in GParsStm
The atomic block to use when no block is specified explicitly
defaultExecutor() - Method in ParallelArray
Returns a common default executor for use in ParallelArrays.
defaultExecutor() - Method in ParallelDoubleArray
Returns a common default executor for use in ParallelArrays.
defaultExecutor() - Method in ParallelLongArray
Returns a common default executor for use in ParallelArrays.
defaultExecutor - Field in PAS
Global default executor
DefaultMessageQueue - Class in groovyx.gpars.util
An implementation of the message queue for actor and agent messaging.
DefaultMessageQueue() - Constructor in DefaultMessageQueue
defaultParamTypes - Field in DataflowMessagingRunnable
DefaultPGroup - Class in groovyx.gpars.group
Provides logical grouping for actors, agents and dataflow tasks and operators.
DefaultPGroup(int) - Constructor in DefaultPGroup
Creates a group for actors, agents, tasks and operators.
DefaultPool - Class in groovyx.gpars.scheduler
Represents the actors' thread pool, which performs tasks on behalf of the actors.
DefaultPool(ThreadPoolExecutor) - Constructor in DefaultPool
Creates the pool around the given executor service
defaultPoolSize - Field in GParsExecutorsPool
Caches the default pool size.
defaultPoolSize - Field in GParsPool
Caches the default pool size.
defaultPoolSize() - Method in PoolUtils
DefaultRemoteHandle - Class in groovyx.gpars.serial
@author Alex Tkachman
DefaultRemoteHandle(UUID, UUID, Class) - Constructor in DefaultRemoteHandle
delay - Property in GFixedDelay
delay - Property in GParPrint
delay - Property in GPrint
delay - Field in GracefulShutdownMonitor
deregisterCurrentActorWithThread() - Method in Actor
Deregisters the actor registered from the thread
dest - Field in PAS.FJDMap
dest - Field in PAS.FJLMap
dest - Field in PAS.FJOMap
dget(int) - Method in AbstractParallelAnyArray
dget(int) - Method in AbstractParallelAnyArray.DDCPap
dget(int) - Method in AbstractParallelAnyArray.DDMPap
dget(int) - Method in AbstractParallelAnyArray.DLCPap
dget(int) - Method in AbstractParallelAnyArray.DLMPap
dget(int) - Method in AbstractParallelAnyArray.DOCPap
dget(int) - Method in AbstractParallelAnyArray.DOMPap
dget(int) - Method in AbstractParallelAnyArray.LDCPap
dget(int) - Method in AbstractParallelAnyArray.LDMPap
dget(int) - Method in AbstractParallelAnyArray.LLCPap
dget(int) - Method in AbstractParallelAnyArray.LLMPap
dget(int) - Method in AbstractParallelAnyArray.LOCPap
dget(int) - Method in AbstractParallelAnyArray.LOMPap
dget(int) - Method in AbstractParallelAnyArray.LPap
dget(int) - Method in AbstractParallelAnyArray.ODCPap
dget(int) - Method in AbstractParallelAnyArray.ODMPap
dget(int) - Method in AbstractParallelAnyArray.OLCPap
dget(int) - Method in AbstractParallelAnyArray.OLMPap
dget(int) - Method in AbstractParallelAnyArray.OOCPap
dget(int) - Method in AbstractParallelAnyArray.OOMPap
dget(int) - Method in AbstractParallelAnyArray.OPap
dget(int) - Method in ParallelDoubleArrayWithFilter
dgetArray() - Method in AbstractParallelAnyArray
dgetArray() - Method in AbstractParallelAnyArray.DPap
dgetIn() - Method in PAS.FJDScan
dgetIn() - Method in PAS.FJScan
dgetOut() - Method in PAS.FJDScan
dgetOut() - Method in PAS.FJScan
disabledDFVs - Field in SelectBase
Since DataflowVariables should be only read once, they need to be disabled after selecting their value The array stores a boolean flag for each index, indicating, whether the channel/variable has been disabled
disableDFV(int, DataflowReadChannel) - Method in SelectBase
Sets the flag in the disabledDFVs array, if the channel is a DFV
disconnect() - Method in GroovyMobileProcess
disconnect() - Method in LocalHost
disconnect(LocalNode) - Method in LocalHostRegistry
disconnect() - Method in LocalNode
disconnect() - Method in MobileAgent
disconnect() - Method in NettyRemoteConnection
disconnect() - Method in NettyTransportProvider
disconnect() - Method in RemoteConnection
disconnect(LocalNode) - Method in RemoteHost
disconnected - Field in DataflowVariable.RemoteDataflowVariable
disconnectRemoteNode(UUID) - Method in LocalHost
doBind(Object) - Method in DataflowExpression
Performs the actual bind operation, unblocks all blocked threads and informs all asynchronously waiting actors.
doBindImpl(Object) - Method in DataflowExpression
doBindImpl(Object) - Method in SyncDataflowVariable
doBindRemote(UUID, Object) - Method in DataflowExpression
Binds the value after receiving a bing message over the wire
doLoop(Callable, Closure, Runnable) - Method in DefaultActor
Ensures that the supplied closure will be invoked repeatedly in a loop.
doPut(Object, Object, boolean) - Method in CustomConcurrentHashMap
Shared implementation for put, putIfAbsent
doRun(Object) - Method in DataflowMessagingRunnable
Defines the action performed by the Runnable
doRun(Object) - Method in MessagingRunnable
Defines the action performed by the Runnable
doRun(Object) - Method in ReactorMessagingRunnable
Defines the action performed by the Runnable
doRun(Object) - Method in ThenMessagingRunnable
doSelect() - Method in DataflowPrioritySelector
Ask for another select operation on the internal select instance.
doSelect() - Method in DataflowSelector
Ask for another select operation on the internal select instance.
doSelect(int, SelectRequest) - Method in SelectBase
Invoked whenever the Select is asked for the next value.
doStart() - Method in AbstractLoopingActor
doubleAdder() - Method in CommonOps
Returns a reducer that adds two double elements
doubleEqualityPredicate() - Method in CommonOps
Returns a predicate evaluating to true if the first argument == the second
doubleInequalityPredicate() - Method in CommonOps
Returns a predicate evaluating to true if the first argument !
doubleMaxReducer(DoubleComparator) - Method in CommonOps
Returns a reducer returning the maximum of two double elements, using the given comparator
doubleMinReducer(DoubleComparator) - Method in CommonOps
Returns a reducer returning the minimum of two double elements, using the given comparator
doubleRandom(double, double) - Method in CommonOps
Returns a generator producing uniform random values between the given least value (inclusive) and bound (exclusive)
downstream - Field in KanbanLink
dquickSort(double[], DoubleComparator, int, int) - Method in PAS
driver - Field in PAS.FJSelectAll
dsetIn(double) - Method in PAS.FJDScan
dsetIn(double) - Method in PAS.FJScan
dsetOut(double) - Method in PAS.FJDScan
dsetOut(double) - Method in PAS.FJScan
DUMMY - Field in Dataflows
dummyWaitingThread - Field in DataflowExpression
A request chain terminator
DynamicDispatchActor - Class in groovyx.gpars.actor
A pooled actor allowing for an alternative structure of the message handling code.
DynamicDispatchActor() - Constructor in DynamicDispatchActor
Creates a new instance without any when handlers registered

E

each(Closure) - Method in TransparentParallel
eachParallel(Closure) - Method in GParsExecutorsPoolEnhancer
Iterates over a collection/object with the each() method using an asynchronous variant of the supplied closure to evaluate each collection's element.
eachParallel(Map, Closure) - Method in GParsExecutorsPoolUtil
Does parallel each on maps
eachParallel(Map, Closure) - Method in GParsPoolUtil
Creates a Parallel Array out of the supplied map and invokes the withMapping() method using the supplied closure as the transformation operation.
eachParallel(Closure) - Method in Parallel
Iterates over a collection/object with the each() method using an asynchronous variant of the supplied closure to evaluate each collection's element.
eachParallelPA(ParallelArray, Closure) - Method in GParsPoolUtilHelper
eachWithIndex(ParallelArray, Closure) - Method in GParsPoolUtilHelper
eachWithIndex(Closure) - Method in TransparentParallel
eachWithIndexParallel(Closure) - Method in GParsExecutorsPoolEnhancer
Iterates over a collection/object with the eachWithIndex() method using an asynchronous variant of the supplied closure to evaluate each collection's element.
eachWithIndexParallel(Map, Closure) - Method in GParsExecutorsPoolUtil
Does parallel eachWithIndex on maps
eachWithIndexParallel(Map, Closure) - Method in GParsPoolUtil
Does parallel eachWithIndex on maps
eachWithIndexParallel(Closure) - Method in Parallel
Iterates over a collection/object with the eachWithIndex() method using an asynchronous variant of the supplied closure to evaluate each collection's element.
elementType - Field in PAS.FJOSelectAllDriver
EMPTY_ARGUMENTS - Field in Actor
empty - Field in DefaultMessageQueue
EMPTY_OBJECTS - Field in FJWorker
encode(ChannelHandlerContext, Channel, Object) - Method in RemoteObjectEncoder
enhance(Object) - Method in Parallel
Enhances to resulting collection so that parallel methods can be chained.
enhanceAndUnwrap(ActorMessage) - Method in BlockingActor
enhanceClass(Class) - Method in GParsExecutorsPoolEnhancer
Enhances a class and so all instances created in the future by mixing-in an instance of GParsExecutorsPoolEnhancer.
enhanceClass(Class) - Method in ParallelEnhancer
Enhances a class and so all instances created in the future by mixing-in an instance of Parallel.
enhanceClosure(Closure) - Method in DefaultActor
EnhancedRWLock - Class in groovyx.gpars.util
Extends ReentrantReadWriteLock with handy withReadLock(Closure) and withWriteLock(Closure) methods to safely lock and unlock the lock for the passed-in closure.
EnhancedRWLock(boolean) - Constructor in EnhancedRWLock
EnhancedSemaphore - Class in groovyx.gpars.util
Extends Semaphore with a handy withSemaphore(Closure) method to safely acquire and release the Semaphore for the passed-in closure.
EnhancedSemaphore(int) - Constructor in EnhancedSemaphore
Creates a new EnhancedSemaphore, delegating to the Semaphore class constructor.
enhanceInstance(Object) - Method in GParsExecutorsPoolEnhancer
Enhances a single instance by mixing-in an instance of GParsExecutorsPoolEnhancer.
enhanceInstance(Object) - Method in ParallelEnhancer
Enhances a single instance by mixing-in an instance of Parallel.
enhanceReplies(ActorMessage) - Method in BlockingActor
Adds reply and replyIfExists methods to the current Actor and the message.
ensurePool(ForkJoinPool, Closure) - Method in GParsPool
Just like withExistingPool() registers a thread pool, but doesn't install the GParsPoolUtil category.
ensureToContainVariable(Object) - Method in Dataflows
The idea is following: - we try to putIfAbsent dummy DFV in to map - if something real already there we are done - if not we obtain lock and put new DFV with double check

Unfortunately we have to sync on this as there is no better option (God forbid to sync on name)

enter() - Method in SerialContext
Enter to the context
entrySet - Field in CustomConcurrentHashMap
eos() - Method in StreamCore
equal(Object, Object) - Method in CustomConcurrentHashMap.Equivalence
Returns true if the given objects are considered equal.
equal(Object, Object) - Method in CustomConcurrentHashMap.EquivalenceUsingEquals
equal(Object, Object) - Method in CustomConcurrentHashMap.EquivalenceUsingIdentity
equalityPredicate() - Method in CommonOps
Returns a predicate evaluating to true if the first argument equals the second
EQUALS - Field in CustomConcurrentHashMap
An Equivalence object performing java.lang.Object#equals based comparisons and using java.lang.Object#hashCode hashing
equals(Object) - Method in CustomConcurrentHashMap.WriteThroughEntry
equals(Object) - Method in NullValue
equals(Object) - Method in SelectResult
equals(Object) - Method in StreamCore
error - Field in DataflowExpression
ERROR_READING_A_SYNCHRONOUS_CHANNEL - Field in SyncDataflowVariable
errorHandler - Field in ThenMessagingRunnable
errors - Field in AgentCore
Holds agent errors
eval(Object) - Method in StreamCore
evalLoopCondition() - Method in DefaultActor
evaluate() - Method in DataflowComplexExpression
Evaluates all the arguments
evaluate() - Method in DataflowExpression
Evaluates the expression after the ones we depend on are ready
evaluate() - Method in DataflowExpression.TransformMany
evaluate() - Method in DataflowExpression.TransformOne
evaluate() - Method in DataflowGetPropertyExpression
Retrieves the receiver's property value
evaluate() - Method in DataflowInvocationExpression
evaluate() - Method in RemoteDataflowExpression
evaluateArguments(Pool, Object, int, List, DataflowVariable, Closure, boolean) - Method in PAUtils
Performs a single step in the evaluation of parameters passed into an asynchronous function
eventManager - Field in DataflowExpression
eventManager - Field in DataflowQueue
eventManager - Field in DataflowStreamReadAdapter
every(Closure) - Method in TransparentParallel
everyParallel(Closure) - Method in GParsExecutorsPoolEnhancer
Performs the all() operation using an asynchronous variant of the supplied closure to evaluate each collection's/object's element.
everyParallel(Map, Closure) - Method in GParsExecutorsPoolUtil
Does parallel every on a map
everyParallel(Map, Closure) - Method in GParsPoolUtil
Creates a Parallel Array out of the supplied map and invokes the withFilter() method using the supplied closure as the filter predicate.
everyParallel(Closure) - Method in Parallel
Performs the all() operation using an asynchronous variant of the supplied closure to evaluate each collection's/object's element.
ex - Field in AbstractParallelAnyArray
exceptionCaught(ChannelHandlerContext, ExceptionEvent) - Method in NettyHandler
exec() - Method in PAS.FJScan
execute(RemoteConnection) - Method in Actor.RemoteActor.StopActorMsg
execute(RemoteConnection) - Method in Actor.RemoteActor.TerminateActorMsg
execute(RemoteConnection) - Method in DataflowExpression.BindDataflow
Performs the actual bind on the remote host
execute(Runnable) - Method in DefaultPool
schedules a new task for processing with the pool
execute(Runnable) - Method in FJPool
schedules a new task for processing with the pool
execute(Transaction) - Method in GParsAtomicBlock
execute(Transaction) - Method in GParsAtomicBooleanBlock
execute(Transaction) - Method in GParsAtomicDoubleBlock
execute(Transaction) - Method in GParsAtomicIntBlock
execute(Transaction) - Method in GParsAtomicLongBlock
execute(Transaction) - Method in GParsAtomicVoidBlock
execute(RemoteConnection) - Method in MessageStream.SendTo
execute(RemoteConnection) - Method in NodeConnectedMsg
execute(RemoteConnection) - Method in NodeDisconnectedMsg
execute(Runnable) - Method in PGroup
schedules a new task for processing with the pool
execute(Runnable) - Method in Pool
schedules a new task for processing with the pool
execute(Runnable) - Method in Scheduler
execute(RemoteConnection) - Method in SerialHandle.RemoteSerialHandle.ReleaseHandle
execute(RemoteConnection) - Method in SerialMsg
executeAsync(List) - Method in GParsExecutorsPool
Starts multiple closures in separate threads, collecting Futures for their return values If an exception is thrown from the closure when called on any of the collection's elements, it will be re-thrown in the calling thread when it calls the Future.get() method.
executeAsync(List) - Method in GParsPool
Starts multiple closures in separate threads, collecting Futures for their return values Reuses the pool defined by the surrounding withPool() call.
executeAsyncAndWait(List) - Method in GParsExecutorsPool
Starts multiple closures in separate threads, collecting their return values If an exception is thrown from the closure when called on any of the collection's elements, it will be re-thrown in the calling thread when it calls the Future.get() method.
executeAsyncAndWait(List) - Method in GParsPool
Starts multiple closures in separate threads, collecting their return values Reuses the pool defined by the surrounding withPool() call.
EXPECTED - Field in DefaultActor
expr - Field in DataflowExpression.BindDataflow
extractInputs(Map) - Method in DataflowProcessor
extractListeners(Map) - Method in DataflowProcessor
extractOutputs(Map) - Method in DataflowProcessor
extractState(Map) - Method in DataflowProcessor

F

factory - Field in CustomConcurrentHashMap
The factory for this map
factory - Field in NettyTransportProvider.Client
factory - Field in NettyTransportProvider.Server
fair - Field in AsyncMessagingCore
Fair agents give up the thread after processing each message, non-fair agents keep a thread until their message queue is empty.
fairActor(Runnable) - Method in Actors
Creates a new instance of PooledActor, using the passed-in closure as the body of the actor's act() method.
fairActor(Runnable) - Method in PGroup
Creates a new instance of DefaultActor, using the passed-in runnable/closure as the body of the actor's act() method.
fairAgent(Object, Closure) - Method in Agent
Creates an agent instance initialized with the given state, which will cooperate in thread sharing with other agents and actors in a fair manner.
fairAgent(Object, Closure) - Method in PGroup
Creates an agent instance initialized with the given state, which will cooperate in thread sharing with other agents and actors in a fair manner.
fairMessageHandler(Closure) - Method in Actors
Creates an instance of DynamicDispatchActor, which will cooperate in thread sharing with other actors in a fair manner.
fairMessageHandler(Closure) - Method in PGroup
Creates an instance of DynamicDispatchActor, which will cooperate in thread sharing with other actors sharing the same thread pool
FairMultiplex - Class in groovyx.gpars.csp.util
FairMultiplex() - Constructor in FairMultiplex
fairReactor(Closure) - Method in Actors
Creates a reactor around the supplied code, which will cooperate in thread sharing with other actors in a fair manner.
fairReactor(Closure) - Method in PGroup
Creates a reactor around the supplied code, which will cooperate in thread sharing with other actors sharing the same thread pool When a reactor receives a message, the supplied block of code is run with the message as a parameter and the result of the code is send in reply.
fairStaticMessageHandler(Closure) - Method in Actors
Creates an instance of StaticDispatchActor, which will cooperate in thread sharing with other actors sharing the same thread pool.
fairStaticMessageHandler(Closure) - Method in PGroup
Creates an instance of StaticDispatchActor, which will cooperate in thread sharing with other actors sharing the same thread pool.
fence - Field in AbstractParallelAnyArray
fence - Field in PAS.FJScanOp
filter(Closure) - Method in AbstractPAWrapper
Filters concurrently elements in the collection based on the outcome of the supplied function on each of the elements.
filter(PGroup, Map, Closure) - Method in DataflowExpression
filter(PGroup, Map, Closure) - Method in DataflowQueue
filter(PGroup, Map, Closure) - Method in DataflowReadChannel
Creates and attaches a new operator that will filter data using the provided closure
filter(PGroup, Map, Closure) - Method in DataflowStreamReadAdapter
filter(Closure) - Method in FList
filter(Closure) - Method in MappedPAWrapper
Filters concurrently elements in the collection based on the outcome of the supplied function on each of the elements.
filter(Map, Closure) - Method in Pipeline
Creates and attaches a new operator that will filter data using the provided closure
filter(StreamCore, Closure, StreamCore) - Method in StreamCore
FilterClosure - Class in groovyx.gpars.dataflow.operator
Used by the filter() method to wrap the supplied closure and use it for filtering data.
FilterClosure(Closure) - Constructor in FilterClosure
filteredAtLeaf(int, int) - Method in PAS.FJDStats
filteredAtLeaf(int, int) - Method in PAS.FJLStats
filteredAtLeaf(int, int) - Method in PAS.FJOStats
finalize() - Method in PGroup
Shutdown the thread pool gracefully
finalizeHandle(SerialHandle) - Method in SerialContext
finalizeHandle(SerialHandle) - Method in SerialHandles
finalizeReference() - Method in SerialHandle
finalizeReference() - Method in SerialHandle.RemoteSerialHandle
find(Closure) - Method in TransparentParallel
findAll(Closure) - Method in TransparentParallel
findAllParallel(Closure) - Method in GParsExecutorsPoolEnhancer
Performs the findAll() operation using an asynchronous variant of the supplied closure to evaluate each collection's/object's element.
findAllParallel(Map, Closure) - Method in GParsExecutorsPoolUtil
Does parallel findAll on a map returning a map of found items
findAllParallel(Map, Closure) - Method in GParsPoolUtil
Creates a Parallel Array out of the supplied map and invokes the withFilter() method using the supplied closure as the filter predicate.
findAllParallel(Closure) - Method in Parallel
Performs the findAll() operation using an asynchronous variant of the supplied closure to evaluate each collection's/object's element.
findAllParallelPA(ParallelArray, Closure) - Method in GParsPoolUtilHelper
findAny(Closure) - Method in TransparentParallel
findAnyParallel(Map, Closure) - Method in GParsExecutorsPoolUtil
Does parallel findAny on a map
findAnyParallel(Map, Closure) - Method in GParsPoolUtil
Creates a Parallel Array out of the supplied map and invokes the withFilter() method using the supplied closure as the filter predicate.
findAnyParallel(Closure) - Method in Parallel
Performs the find() operation using an asynchronous variant of the supplied closure to evaluate each collection's/object's element.
findAnyParallelPA(ParallelArray, Closure) - Method in GParsPoolUtilHelper
findGroupById(String) - Method in ActiveObjectRegistry
findNode(Object, int, CustomConcurrentHashMap.Segment) - Method in CustomConcurrentHashMap
Returns node for key, or null if none
findParallel(Closure) - Method in GParsExecutorsPoolEnhancer
Performs the find() operation using an asynchronous variant of the supplied closure to evaluate each collection's/object's element.
findParallel(Map, Closure) - Method in GParsExecutorsPoolUtil
Does parallel find on a map
findParallel(Map, Closure) - Method in GParsPoolUtil
Creates a Parallel Array out of the supplied map and invokes the withFilter() method using the supplied closure as the filter predicate.
findParallel(Closure) - Method in Parallel
Performs the find() operation using an asynchronous variant of the supplied closure to evaluate each collection's/object's element.
findParallelPA(ParallelArray, Closure) - Method in GParsPoolUtilHelper
findSuitablePrivateMethodName(ClassNode, MethodNode) - Method in ActiveObjectASTTransformation.MyClassCodeExpressionTransformer
FINISHED - Field in PAS.FJScan
fireAfterRun(List) - Method in DataflowProcessor
fireAfterStart() - Method in DataflowProcessor
fireAfterStop() - Method in DataflowProcessor
fireBeforeRun(List) - Method in DataflowProcessor
fireControlMessageArrived(DataflowReadChannel, int, Object) - Method in DataflowProcessor
fireCustomEvent(Object) - Method in DataflowProcessor
fireEvent() - Method in GracefulShutdownListener
If shutdown is in progress, we'll notify the monitor
fireMessageArrived(DataflowReadChannel, int, Object) - Method in DataflowProcessor
fireMessageArrived(Object, int, boolean) - Method in DataflowProcessorActor
fireMessageSentOut(DataflowWriteChannel, int, Object) - Method in DataflowProcessor
fireOnException(Throwable) - Method in DataflowProcessor
fireOnMessage(Object) - Method in DataflowChannelEventDistibutor
fireOnMessage(Object) - Method in DataflowChannelEventOrchestrator
fireOnMessage(Object) - Method in DataflowExpression
fireOnMessage(Object) - Method in DataflowQueue
fireOnMessage(Object) - Method in DataflowStreamReadAdapter
first - Field in AbstractParallelAnyArray.AndPredicate
first - Field in ForwardingDelegate
first - Field in RunnableBackedBlockingActor.RunnableBackedPooledActorDelegate
first - Field in StreamCore
FJPool - Class in groovyx.gpars.scheduler
Represents the actors' thread pool, which performs tasks on behalf of the actors.
FJPool(ForkJoinPool) - Constructor in FJPool
Creates the pool wrapping the provided ForkJoinPool
FJWorker - Class in groovyx.gpars.forkjoin
Represents a recursive task for the builder-style fork/join algorithm.
FJWorker(Object) - Constructor in FJWorker
FList - Interface in groovyx.gpars.dataflow.stream
Represents a list implemented as a Functional Queue.
FListIterator - Class in groovyx.gpars.dataflow.stream
FListIterator(FList) - Constructor in FListIterator
flow - Property in KanbanLink
fold(def, Closure) - Method in TransparentParallel
foldParallel(Object, Object, Closure) - Method in GParsPoolUtil
Creates a Parallel Array out of the supplied collection/object and invokes its reduce() method using the supplied closure as the reduction operation.
foldParallel(Object, def, Closure) - Method in GParsPoolUtilHelper
foldParallel(def, Closure) - Method in Parallel
Creates a Parallel Array out of the supplied collection/object and invokes its reduce() method using the supplied closure as the reduction operation.
ForkingDataflowOperatorActor - Class in groovyx.gpars.dataflow.operator
An operator's internal actor.
ForkingDataflowOperatorActor(DataflowOperator, PGroup, List, List, Closure, int) - Constructor in ForkingDataflowOperatorActor
ForkingDataflowSelectorActor - Class in groovyx.gpars.dataflow.operator
An selector's internal actor.
ForkingDataflowSelectorActor(DataflowSelector, PGroup, List, List, Closure, int) - Constructor in ForkingDataflowSelectorActor
ForkJoinUtils - Class in groovyx.gpars.forkjoin
@author Vaclav Pech
ForkJoinUtils() - Constructor in ForkJoinUtils
forkOffChild(AbstractForkJoinWorker) - Method in AbstractForkJoinWorker
Forks a child task.
forkOffChild(Object) - Method in FJWorker
ForwardingDelegate - Class in groovyx.gpars.actor
@author Alex Tkachman, Vaclav Pech
ForwardingDelegate(Object, Object) - Constructor in ForwardingDelegate
forwardPoisonPill(Object) - Method in DataflowProcessorActor
forwardPoisonPill(Object) - Method in ForkingDataflowOperatorActor
forwardPoisonPill(Object) - Method in ForkingDataflowSelectorActor
FQMessageQueue - Class in groovyx.gpars.util
An implementation of the message queue for actor and agent messaging using functional queues.
FQMessageQueue.EmptyNode - Class in groovyx.gpars.util
FQMessageQueue.EmptyNode() - Constructor in FQMessageQueue.EmptyNode
FQMessageQueue.Node - Class in groovyx.gpars.util
FQMessageQueue.Node(Node, Object) - Constructor in FQMessageQueue.Node
FQMessageQueue() - Constructor in FQMessageQueue
frameLabel - Property in GConsole
fromConsole - Property in GConsole

G

GConsole - Class in groovyx.gpars.csp.plugAndPlay
GConsole() - Constructor in GConsole
GConsoleStringToInteger - Class in groovyx.gpars.csp.plugAndPlay
GConsoleStringToInteger() - Constructor in GConsoleStringToInteger
GDelta2 - Class in groovyx.gpars.csp.plugAndPlay
GDelta2() - Constructor in GDelta2
GeneralTimer - Interface in groovyx.gpars.util
Represents timers, either java.util.Timer or timers provided by the hosting environment, such as GAE
generate(Object, Closure, Closure) - Method in StreamCore
Populates the stream with generated values
generateNext(Object, StreamCore, Closure, Closure) - Method in StreamCore
generator - Field in CommonOps.DoubleRandomGenerator
generator - Field in CommonOps.IntRandomGenerator
generator - Field in CommonOps.LongRandomGenerator
generator - Field in PAS.FJDGenerate
generator - Field in PAS.FJLGenerate
generator - Field in PAS.FJOGenerate
get(Object) - Method in CustomConcurrentHashMap
Returns the value associated with a key equivalent to the given key with respect to this map's key Equivalence, or null if no such mapping exists.
get() - Method in CustomConcurrentHashMap.IntKeyNode
get() - Method in CustomConcurrentHashMap.Node
Returns the key established during the creation of this node.
get() - Method in CustomConcurrentHashMap.StrongKeyNode
get(long, TimeUnit) - Method in DataflowVariable
Retrieves the value of the variable, blocking up to given timeout, if the value has not been assigned yet.
get(int) - Method in ParallelArray
Returns the element of the array at the given index
get(int) - Method in ParallelArray.AsList
get(int) - Method in ParallelDoubleArray
Returns the element of the array at the given index
get(int) - Method in ParallelDoubleArray.AsList
get(int) - Method in ParallelLongArray
Returns the element of the array at the given index
get(int) - Method in ParallelLongArray.AsList
get(long, TimeUnit) - Method in Promise
Retrieves the value of the variable, blocking up to given timeout, if the value has not been assigned yet.
get(UUID) - Method in SerialContext
get(UUID) - Method in SerialHandles
getAddress() - Method in NettyTransportProvider.Server
getArray() - Method in ParallelArray
Returns the underlying array used for computations
getArray() - Method in ParallelDoubleArray
Returns the underlying array used for computations
getArray() - Method in ParallelLongArray
Returns the underlying array used for computations
getAt(def) - Method in ChannelInputList
getAt(def) - Method in ChannelOutputList
getAt(int) - Method in Dataflows
Retrieves the DFV associated with the given index
getChannel() - Method in NettyHandler
getChildrenResults() - Method in AbstractForkJoinWorker
Waits for and returns the results of the child tasks.
getCollection() - Method in AbstractPAWrapper
Reconstructs a collection from the wrapped ParallelArray instance
getConcurrentExceptions() - Method in AsyncException
getConfiguredPoolSize() - Method in FJPool
getConnection() - Method in RemoteHost
getContent() - Method in CombineHolder
getCore() - Method in AbstractLoopingActor
getCount() - Method in ResizeableCountDownLatch
Returns the current count.
getCount() - Method in ResizeableCountDownLatch.Sync
getCurrent() - Method in ThreadLocalPools
Gives the current element
getError() - Method in DataflowVariable
Returns the error bound to the promise
getError() - Method in Promise
Returns the error bound to the promise
getErrors() - Method in AgentCore
Retrieves a list of exception thrown within the agent's body.
getEventManager() - Method in DataflowExpression
getEventManager() - Method in DataflowQueue
getEventManager() - Method in DataflowReadChannel
Retrieves the event manager object of this channel
getEventManager() - Method in DataflowStreamReadAdapter
getExecutor() - Method in ParallelArray
Returns the executor used for computations.
getExecutor() - Method in ParallelDoubleArray
Returns the executor used for computations
getExecutor() - Method in ParallelLongArray
Returns the executor used for computations
getExecutorService() - Method in DefaultPool
Retrieves the internal executor service.
getFirst() - Method in FList
getFirst() - Method in StreamCore
Retrieved the first element in the stream, blocking until a value is available
getFirstDFV() - Method in StreamCore
getForkJoinPool() - Method in FJPool
Retrieves the internal executor service.
getGroup() - Method in Pipeline
getHead() - Method in DataflowStreamWriteAdapter
getHost() - Method in RemoteConnection
getHostId() - Method in SerialContext
getId() - Method in ActorTimerTask
getId() - Method in KanbanLink
The index of this link in its flow
getId() - Method in LocalHandle
getId() - Method in LocalNode
getId() - Method in RemoteNode
getId() - Method in SerialHandles
Getter for provider id
getImmediateInstance() - Method in PoisonPill
Retrieves an immediate poison pill instance
getIndex() - Method in SelectResult
getInstance() - Method in ActiveObjectRegistry
getInstance() - Method in PoisonPill
Retrieves a non-immediate poison pill instance
getInstance() - Method in StopGently
getInstance() - Method in SumClosure
getInstantVal() - Method in AgentBase
A shorthand method for safe message-based retrieval of the internal state.
getIssues() - Method in ActorReplyException
getJoinLatch() - Method in Actor
Join-point for this actor
getKey() - Method in CustomConcurrentHashMap.WriteThroughEntry
getLinkage() - Method in CustomConcurrentHashMap.LinkedIntKeyIntValueNode
getLinkage() - Method in CustomConcurrentHashMap.LinkedIntKeySelfValueNode
getLinkage() - Method in CustomConcurrentHashMap.LinkedIntKeySoftValueNode
getLinkage() - Method in CustomConcurrentHashMap.LinkedIntKeyStrongValueNode
getLinkage() - Method in CustomConcurrentHashMap.LinkedIntKeyWeakValueNode
getLinkage() - Method in CustomConcurrentHashMap.LinkedSoftKeyIntValueNode
getLinkage() - Method in CustomConcurrentHashMap.LinkedSoftKeySelfValueNode
getLinkage() - Method in CustomConcurrentHashMap.LinkedSoftKeySoftValueNode
getLinkage() - Method in CustomConcurrentHashMap.LinkedSoftKeyStrongValueNode
getLinkage() - Method in CustomConcurrentHashMap.LinkedSoftKeyWeakValueNode
getLinkage() - Method in CustomConcurrentHashMap.LinkedStrongKeyIntValueNode
getLinkage() - Method in CustomConcurrentHashMap.LinkedStrongKeySelfValueNode
getLinkage() - Method in CustomConcurrentHashMap.LinkedStrongKeySoftValueNode
getLinkage() - Method in CustomConcurrentHashMap.LinkedStrongKeyStrongValueNode
getLinkage() - Method in CustomConcurrentHashMap.LinkedStrongKeyWeakValueNode
getLinkage() - Method in CustomConcurrentHashMap.LinkedWeakKeyIntValueNode
getLinkage() - Method in CustomConcurrentHashMap.LinkedWeakKeySelfValueNode
getLinkage() - Method in CustomConcurrentHashMap.LinkedWeakKeySoftValueNode
getLinkage() - Method in CustomConcurrentHashMap.LinkedWeakKeyStrongValueNode
getLinkage() - Method in CustomConcurrentHashMap.LinkedWeakKeyWeakValueNode
getLinkage() - Method in CustomConcurrentHashMap.Node
Returns the linkage established during the creation of this node or, if since updated, the linkage set by the most recent call to setLinkage.
getLinkage() - Method in CustomConcurrentHashMap.TerminalIntKeyIntValueNode
getLinkage() - Method in CustomConcurrentHashMap.TerminalIntKeySelfValueNode
getLinkage() - Method in CustomConcurrentHashMap.TerminalIntKeySoftValueNode
getLinkage() - Method in CustomConcurrentHashMap.TerminalIntKeyStrongValueNode
getLinkage() - Method in CustomConcurrentHashMap.TerminalIntKeyWeakValueNode
getLinkage() - Method in CustomConcurrentHashMap.TerminalSoftKeyIntValueNode
getLinkage() - Method in CustomConcurrentHashMap.TerminalSoftKeySelfValueNode
getLinkage() - Method in CustomConcurrentHashMap.TerminalSoftKeySoftValueNode
getLinkage() - Method in CustomConcurrentHashMap.TerminalSoftKeyStrongValueNode
getLinkage() - Method in CustomConcurrentHashMap.TerminalSoftKeyWeakValueNode
getLinkage() - Method in CustomConcurrentHashMap.TerminalStrongKeyIntValueNode
getLinkage() - Method in CustomConcurrentHashMap.TerminalStrongKeySelfValueNode
getLinkage() - Method in CustomConcurrentHashMap.TerminalStrongKeySoftValueNode
getLinkage() - Method in CustomConcurrentHashMap.TerminalStrongKeyStrongValueNode
getLinkage() - Method in CustomConcurrentHashMap.TerminalStrongKeyWeakValueNode
getLinkage() - Method in CustomConcurrentHashMap.TerminalWeakKeyIntValueNode
getLinkage() - Method in CustomConcurrentHashMap.TerminalWeakKeySelfValueNode
getLinkage() - Method in CustomConcurrentHashMap.TerminalWeakKeySoftValueNode
getLinkage() - Method in CustomConcurrentHashMap.TerminalWeakKeyStrongValueNode
getLinkage() - Method in CustomConcurrentHashMap.TerminalWeakKeyWeakValueNode
getListeners() - Method in DataflowChannelEventListenerManager
getListeners() - Method in DataflowChannelEventOrchestrator
getLocalHost() - Method in LocalNode
getLocalHost() - Method in RemoteHost
getLocalHostId() - Method in SerialContext
getLocator() - Method in CustomConcurrentHashMap.IntKeyNode
getLocator() - Method in CustomConcurrentHashMap.Node
Returns the locator established during the creation of this node.
getLocator() - Method in CustomConcurrentHashMap.SoftKeyNode
getLocator() - Method in CustomConcurrentHashMap.StrongKeyNode
getLocator() - Method in CustomConcurrentHashMap.WeakKeyNode
getMainActor() - Method in LocalNode
getMainActor() - Method in RemoteNode
getMaximumNumberOfParameters() - Method in BinaryChoiceClosure
getMaximumNumberOfParameters() - Method in ChainWithClosure
getMaximumNumberOfParameters() - Method in ChoiceClosure
getMaximumNumberOfParameters() - Method in CopyChannelsClosure
getMaximumNumberOfParameters() - Method in DataflowMessagingRunnable
getMaximumNumberOfParameters() - Method in DataflowProcessorAtomicBoundAllClosure
getMaximumNumberOfParameters() - Method in FilterClosure
getMaximumNumberOfParameters() - Method in MessagingRunnable
getMaximumNumberOfParameters() - Method in ReactorMessagingRunnable
getMaximumNumberOfParameters() - Method in SeparationClosure
getMessage() - Method in AsyncException
getMessage() - Method in MessageStream.SendTo
getMetaClass() - Method in DataflowExpression
getName() - Method in CustomConcurrentHashMap.Strength
getOrCreateSerialHandle() - Method in WithSerialId
Gets serial handle for the object If needed new handle created and serialization host subscribed for the object handle
getOutput() - Method in DataflowProcessor
The processor's first / only output channel
getOutput() - Method in Pipeline
getOutputs() - Method in DataflowProcessor
The processor's all output channels
getOwningProcessor() - Method in DataflowMessagingRunnable
Retrieves the owning processor (operator or selector) giving the DataflowMessagingRunnable a way to call methods like bindOutput()
getParallel(Object) - Method in GParsPoolUtil
Creates a PAWrapper around a ParallelArray wrapping the elements of the original collection.
getParallel() - Method in Parallel
Creates a PAWrapper around a ParallelArray wrapping te elements of the original collection.
getParallelArray(Object) - Method in GParsPoolUtil
Creates a ParallelArray wrapping the elements of the original collection.
getParallelGroup() - Method in Actor
Retrieves the group to which the actor belongs
getParameterTypes() - Method in BinaryChoiceClosure
getParameterTypes() - Method in ChainWithClosure
getParameterTypes() - Method in ChoiceClosure
getParameterTypes() - Method in CopyChannelsClosure
getParameterTypes() - Method in DataflowMessagingRunnable
Returns types expected by the Runnable.
getParameterTypes() - Method in FilterClosure
getParameterTypes() - Method in MessagingRunnable
getParameterTypes() - Method in ReactorMessagingRunnable
getParameterTypes() - Method in SeparationClosure
getPayLoad() - Method in ActorMessage
getPipeline() - Method in NettyTransportProvider.ServerPipelineFactory
getPoolFactory() - Method in GParsConfig
getPoolSize() - Method in DefaultPool
Retrieves the current thread pool size
getPoolSize() - Method in FJPool
Retrieves the current thread pool size
getPoolSize() - Method in PGroup
Retrieves the current thread pool size
getPoolSize() - Method in Pool
Retrieves the current thread pool size
getPoolSize() - Method in Scheduler
Retrieves the current thread pool size
getProperty(String) - Method in DataflowExpression
Returns either standard property of the expression or creates an expression, which will request given property when the receiver becomes available
getProperty(String) - Method in Dataflows
Returns:
the value of the DataflowVariable associated with the property "name".
getProperty(String) - Method in ForwardingDelegate
getProperty(String) - Method in RunnableBackedBlockingActor.RunnableBackedPooledActorDelegate
getQueue() - Method in DataflowQueue
getRawResult() - Method in PAS.FJScan
getRealSelf() - Method in Parallel
Retrieves the mixed it parent and potentially casts it dynamically to a Map.
getReclamationQueue() - Method in CustomConcurrentHashMap
Returns a queue that may be used as the ReferenceQueue argument to java.lang.ref.Reference constructors to arrange removal of reclaimed nodes from maps via a background thread.
getRemoteClass() - Method in DataflowVariable
getRemoteClass() - Method in MessageStream
getRemoteClass() - Method in WithSerialId
Class of remote object to be created
getRemoteHost() - Method in RemoteNode
getRest() - Method in DataflowStream
Retrieves a DataflowStream representing the rest of this Stream after removing the first element
getRest() - Method in FList
getRest() - Method in StreamCore
Retrieves a DataflowStream representing the rest of this Stream after removing the first element
getRest() - Method in SyncDataflowStream
Retrieves a DataflowStream representing the rest of this Stream after removing the first element
getResult(long, TimeUnit) - Method in MessageStream.ResultWaiter
Retrieves the response blocking until a message arrives
getScheduler() - Method in LocalNode
getSegmentForAdd(int) - Method in CustomConcurrentHashMap
Returns the segment for possibly inserting into the table associated with given hash, constructing it if necessary.
getSegmentForTraversal(int) - Method in CustomConcurrentHashMap
Returns the segment for traversing table for key with given hash
getSender() - Method in AbstractLoopingActor
Retrieves the sender actor of the currently processed message.
getSender() - Method in ActorMessage
getSender() - Method in ReplyingMessageStream
getSerialHost(UUID, Object) - Method in LocalHost
getSerialHost(UUID, Object) - Method in SerialContext
getSerialHost(UUID, Object) - Method in SerialHandles
getSerialId() - Method in SerialHandle
Serial id of the object
getSourceUnit() - Method in ActiveObjectASTTransformation.MyClassCodeExpressionTransformer
getStateObject() - Method in DataflowProcessor
Retrieves the custom state object
getSubscribers() - Method in SerialHandle
Getter for subscribers
getTableForAdd(CustomConcurrentHashMap) - Method in CustomConcurrentHashMap.Segment
getTableForTraversal() - Method in CustomConcurrentHashMap.Segment
getTermination() - Method in CountingPoisonPill
Retrieves the promise for termination
getTermination() - Method in ImmediateCountingPoisonPill
Retrieves the promise for termination
getTermination() - Method in PoisonTrackCounter
getThreadPool() - Method in AsyncMessagingCore
getThreadPool() - Method in GParsExecutorsPoolEnhancer
Retrieves the underlying pool
getThreadPool() - Method in ParallelEnhancer
Retrieves the underlying pool
getThreadPool() - Method in PGroup
getThreshold() - Method in AbstractParallelAnyArray
Returns lazily computed threshold.
getTimerFactory() - Method in GParsConfig
getTo() - Method in MessageStream.SendTo
getUnsafe() - Method in CustomConcurrentHashMap
getUnsafePrivileged() - Method in CustomConcurrentHashMap
getVal() - Method in AgentBase
A shorthand method for safe message-based retrieval of the internal state.
getVal(long, TimeUnit) - Method in DataflowExpression
Reads the value of the variable.
getVal(long, TimeUnit) - Method in DataflowQueue
Retrieves the value at the head of the buffer.
getVal(long, TimeUnit) - Method in DataflowReadChannel
Reads the current value of the channel.
getVal(long, TimeUnit) - Method in DataflowStreamReadAdapter
getVal(long, TimeUnit) - Method in SyncDataflowStreamReadAdapter
getVal(long, TimeUnit) - Method in SyncDataflowVariable
Reads the value of the variable.
getValAsync(Object, MessageStream) - Method in DataflowExpression
Used by Dataflow operators.
getValAsync(Object, MessageStream) - Method in DataflowQueue
Asynchronously retrieves the value at the head of the buffer.
getValAsync(Object, MessageStream) - Method in DataflowReadChannel
Asynchronously retrieves the value from the channel.
getValAsync(Object, MessageStream) - Method in DataflowStreamReadAdapter
getValAsync(Object, MessageStream) - Method in SyncDataflowStreamReadAdapter
getValue() - Method in CustomConcurrentHashMap.IntKeyIntValueNode
getValue() - Method in CustomConcurrentHashMap.IntKeySelfValueNode
getValue() - Method in CustomConcurrentHashMap.IntKeySoftValueNode
getValue() - Method in CustomConcurrentHashMap.IntKeyStrongValueNode
getValue() - Method in CustomConcurrentHashMap.IntKeyWeakValueNode
getValue() - Method in CustomConcurrentHashMap.Node
Returns the value established during the creation of this node or, if since updated, the value set by the most recent call to setValue, or throws an exception if value could not be computed
getValue() - Method in CustomConcurrentHashMap.SoftKeyIntValueNode
getValue() - Method in CustomConcurrentHashMap.SoftKeySelfValueNode
getValue() - Method in CustomConcurrentHashMap.SoftKeySoftValueNode
getValue() - Method in CustomConcurrentHashMap.SoftKeyStrongValueNode
getValue() - Method in CustomConcurrentHashMap.SoftKeyWeakValueNode
getValue() - Method in CustomConcurrentHashMap.StrongKeyIntValueNode
getValue() - Method in CustomConcurrentHashMap.StrongKeySelfValueNode
getValue() - Method in CustomConcurrentHashMap.StrongKeySoftValueNode
getValue() - Method in CustomConcurrentHashMap.StrongKeyStrongValueNode
getValue() - Method in CustomConcurrentHashMap.StrongKeyWeakValueNode
getValue() - Method in CustomConcurrentHashMap.WeakKeyIntValueNode
getValue() - Method in CustomConcurrentHashMap.WeakKeySelfValueNode
getValue() - Method in CustomConcurrentHashMap.WeakKeySoftValueNode
getValue() - Method in CustomConcurrentHashMap.WeakKeyStrongValueNode
getValue() - Method in CustomConcurrentHashMap.WeakKeyWeakValueNode
getValue() - Method in CustomConcurrentHashMap.WriteThroughEntry
getValue() - Method in SelectResult
GFixedDelay - Class in groovyx.gpars.csp.plugAndPlay
GFixedDelay() - Constructor in GFixedDelay
GIdentity - Class in groovyx.gpars.csp.plugAndPlay
GIdentity() - Constructor in GIdentity
GIntegrate - Class in groovyx.gpars.csp.plugAndPlay
GIntegrate() - Constructor in GIntegrate
gmemoize(Closure) - Method in GParsPoolUtil
Creates a caching variant of the supplied closure.
gmemoizeAtLeast(Closure, int) - Method in GParsPoolUtil
Creates a caching variant of the supplied closure with automatic cache size adjustment and lower limit on the cache size.
gmemoizeAtMost(Closure, int) - Method in GParsPoolUtil
Creates a caching variant of the supplied closure with upper limit on the cache size.
gmemoizeBetween(Closure, int, int) - Method in GParsPoolUtil
Creates a caching variant of the supplied closure with automatic cache size adjustment and lower and upper limits on the cache size.
GNumbers - Class in groovyx.gpars.csp.plugAndPlay
GNumbers() - Constructor in GNumbers
GObjectToConsoleString - Class in groovyx.gpars.csp.plugAndPlay
GObjectToConsoleString() - Constructor in GObjectToConsoleString
GPairs - Class in groovyx.gpars.csp.plugAndPlay
GPairs() - Constructor in GPairs
GParPrint - Class in groovyx.gpars.csp.plugAndPlay
GParPrint() - Constructor in GParPrint
GPARS_POOLSIZE - Field in PoolUtils
GParsAtomicBlock - Class in groovyx.gpars.stm
A default implementation of org.multiverse.api.closures.AtomicClosure properly handling exception propagation
GParsAtomicBlock(Closure) - Constructor in GParsAtomicBlock
GParsAtomicBooleanBlock - Class in groovyx.gpars.stm
A default implementation of org.multiverse.api.closures.AtomicBooleanClosure properly handling exception propagation
GParsAtomicBooleanBlock(Closure) - Constructor in GParsAtomicBooleanBlock
GParsAtomicDoubleBlock - Class in groovyx.gpars.stm
A default implementation of org.multiverse.api.closures.AtomicDoubleClosure properly handling exception propagation
GParsAtomicDoubleBlock(Closure) - Constructor in GParsAtomicDoubleBlock
GParsAtomicIntBlock - Class in groovyx.gpars.stm
A default implementation of org.multiverse.api.closures.AtomicIntClosure properly handling exception propagation
GParsAtomicIntBlock(Closure) - Constructor in GParsAtomicIntBlock
GParsAtomicLongBlock - Class in groovyx.gpars.stm
A default implementation of org.multiverse.api.closures.AtomicLongClosure properly handling exception propagation
GParsAtomicLongBlock(Closure) - Constructor in GParsAtomicLongBlock
GParsAtomicVoidBlock - Class in groovyx.gpars.stm
A default implementation of org.multiverse.api.closures.AtomicVoidClosure properly handling exception propagation
GParsAtomicVoidBlock(Closure) - Constructor in GParsAtomicVoidBlock
GParsConfig - Class in groovyx.gpars
Enables to specify custom thread pools and timers to run GPars in hosted environments, such as GAE
GParsConfig() - Constructor in GParsConfig
GParsExecutorsPool - Class in groovyx.gpars
Enables a ExecutorService-based DSL on closures, objects and collections.
GParsExecutorsPool() - Constructor in GParsExecutorsPool
GParsExecutorsPoolEnhancer - Class in groovyx.gpars
GParsExecutorsPoolEnhancer allows classes or instances to be enhanced with asynchronous variants of iterative methods, like eachParallel(), collectParallel(), findAllParallel() and others.
GParsExecutorsPoolEnhancer() - Constructor in GParsExecutorsPoolEnhancer
GParsExecutorsPoolUtil - Class in groovyx.gpars
This class forms the core of the DSL initialized by GParsExecutorsPool.
GParsExecutorsPoolUtil() - Constructor in GParsExecutorsPoolUtil
GParsPool - Class in groovyx.gpars
Enables a ParallelArray-based (from JSR-166y) DSL on collections.
GParsPool.MyCancellableRecursiveTask - Class in groovyx.gpars
GParsPool.MyCancellableRecursiveTask(def) - Constructor in GParsPool.MyCancellableRecursiveTask
GParsPool() - Constructor in GParsPool
GParsPoolUtil - Class in groovyx.gpars
This class forms the core of the DSL initialized by GParsPool.
GParsPoolUtil() - Constructor in GParsPoolUtil
GParsPoolUtilHelper - Class in groovyx.gpars.pa
Off-loads some of the heavy-on-Groovy functionality from GParsPoolUtil
GParsPoolUtilHelper() - Constructor in GParsPoolUtilHelper
GParsStm - Class in groovyx.gpars.stm
Provides access to GPars Stm services.
GParsStm() - Constructor in GParsStm
GPCopy - Class in groovyx.gpars.csp.plugAndPlay
GPCopy() - Constructor in GPCopy
GPlus - Class in groovyx.gpars.csp.plugAndPlay
GPlus() - Constructor in GPlus
GPrefix - Class in groovyx.gpars.csp.plugAndPlay
GPrefix() - Constructor in GPrefix
GPrint - Class in groovyx.gpars.csp.plugAndPlay
GPrint() - Constructor in GPrint
GracefulShutdownListener - Class in groovyx.gpars.dataflow.operator.component
Listens to an operator/selector and reports its state and activity to a GracefulShutdownMonitor, shared with other listeners.
GracefulShutdownListener(OperatorStateMonitor) - Constructor in GracefulShutdownListener
Hooks hooks the shared monitor
GracefulShutdownMonitor - Class in groovyx.gpars.dataflow.operator.component
The monitor will orchestrate a graceful shutdown, when its shutdownNetwork() method is called.
GracefulShutdownMonitor(long) - Constructor in GracefulShutdownMonitor
Allows to use a customized delay
gran - Field in PAS.FJDCMerger
gran - Field in PAS.FJDCSorter
gran - Field in PAS.FJDMerger
gran - Field in PAS.FJDSorter
gran - Field in PAS.FJLCMerger
gran - Field in PAS.FJLCSorter
gran - Field in PAS.FJLMerger
gran - Field in PAS.FJLSorter
gran - Field in PAS.FJOCMerger
gran - Field in PAS.FJOCSorter
gran - Field in PAS.FJOMerger
gran - Field in PAS.FJOSorter
grep(def) - Method in TransparentParallel
grepParallel(Closure) - Method in GParsExecutorsPoolEnhancer
Performs the grep()() operation using an asynchronous variant of the supplied closure to evaluate each collection's/object's element.
grepParallel(Map, def) - Method in GParsExecutorsPoolUtil
Does parallel grep on a map
grepParallel(Map, Object) - Method in GParsPoolUtil
Creates a Parallel Array out of the supplied map and invokes the withFilter() method using the supplied rule as the filter predicate.
grepParallel(Object) - Method in Parallel
Performs the grep() operation using an asynchronous variant of the supplied closure to evaluate each collection's/object's element.
grepParallelPA(ParallelArray, Object) - Method in GParsPoolUtilHelper
GroovyMobileProcess - Class in groovyx.gpars.csp
GroovyMobileProcess() - Constructor in GroovyMobileProcess
group - Field in BroadcastDiscovery
group - Field in Pipeline
groupBy(Closure) - Method in AbstractPAWrapper
Performs parallel groupBy operation.
groupBy(Closure) - Method in TransparentParallel
groupByParallel(Closure) - Method in GParsExecutorsPoolEnhancer
Performs the groupBy() operation using an asynchronous variant of the supplied closure to evaluate each collection's/object's element.
groupByParallel(Object, Closure) - Method in GParsExecutorsPoolUtil
Performs the groupBy() operation using an asynchronous variant of the supplied closure to evaluate each collection's/object's element.
groupByParallel(Object, Closure) - Method in GParsPoolUtil
Creates a Parallel Array out of the supplied collection/object and invokes the withMapping() method using the supplied closure as the mapping predicate.
groupByParallel(Closure) - Method in Parallel
Performs the groupBy() operation using an asynchronous variant of the supplied closure to evaluate each collection's/object's element.
groupByParallelPA(ParallelArray, Closure) - Method in GParsPoolUtil
GSquares - Class in groovyx.gpars.csp.plugAndPlay
GSquares() - Constructor in GSquares
GStatePairs - Class in groovyx.gpars.csp.plugAndPlay
GStatePairs() - Constructor in GStatePairs
GSuccessor - Class in groovyx.gpars.csp.plugAndPlay
GSuccessor() - Constructor in GSuccessor
GTail - Class in groovyx.gpars.csp.plugAndPlay
GTail() - Constructor in GTail
GuardedSelectRequest - Class in groovyx.gpars.dataflow.impl
The base implementation of the SelectRequest interface, providing a useful default masking (guarding) functionality.
GuardedSelectRequest(List) - Constructor in GuardedSelectRequest
Parameters:
mask - The list of boolean flags indicating which position should be matched against.
guards - Field in DataflowSelector

H

handleCurrentMessage(Object) - Method in InternalActor
handleException(Throwable) - Method in Actor
handleInterrupt(InterruptedException) - Method in Actor
handleInterruption(AtomicBoolean) - Method in DataflowExpression
handleMessage(Object) - Method in Agent
Dynamically dispatches the method call
handleMessage(Object) - Method in AgentCore
Dynamically dispatches the method call
handleMessage(Object) - Method in AsyncMessagingCore
handlePoisonPillInSelector(int, Object) - Method in DataflowSelectorActor
handler - Field in NettyRemoteConnection
handler - Field in NettyRemoteConnection.MyChannelFutureListener
handleStart() - Method in Actor
handleStart() - Method in BlockingActor
handleStart() - Method in DefaultActor
Called once the START_MESSAGE arrives.
handleTermination() - Method in Actor
handleTermination() - Method in SequentialProcessingActor
handleTimeout() - Method in Actor
hasAllEqualElements(ParallelArrayWithMapping) - Method in ParallelArray
Returns true if all elements at the same relative positions of this and other array are equal.
hasAllEqualElements(ParallelArrayWithMapping) - Method in ParallelArrayWithFilter
Returns true if all elements at the same relative positions of this and other array are equal.
hasAllEqualElements(ParallelDoubleArrayWithDoubleMapping) - Method in ParallelDoubleArray
Returns true if all elements at the same relative positions of this and other array are equal.
hasAllEqualElements(ParallelDoubleArrayWithDoubleMapping) - Method in ParallelDoubleArrayWithFilter
Returns true if all elements at the same relative positions of this and other array are equal.
hasAllEqualElements(ParallelLongArrayWithLongMapping) - Method in ParallelLongArray
Returns true if all elements at the same relative positions of this and other array are equal.
hasAllEqualElements(ParallelLongArrayWithLongMapping) - Method in ParallelLongArrayWithFilter
Returns true if all elements at the same relative positions of this and other array are equal.
hasAllIdenticalElements(ParallelArrayWithMapping) - Method in ParallelArray
Returns true if all elements at the same relative positions of this and other array are identical.
hasAllIdenticalElements(ParallelArrayWithMapping) - Method in ParallelArrayWithFilter
Returns true if all elements at the same relative positions of this and other array are identical.
hasBeenStopped() - Method in AbstractLoopingActor
hasBeenStopped() - Method in Actor
hasBeenStopped() - Method in Actor.RemoteActor
hasBeenStopped() - Method in SequentialProcessingActor
hasErrors() - Method in AgentCore
Indicates whether there have been exception thrown within the agent's body.
hasFilter() - Method in AbstractParallelAnyArray
hasFilter() - Method in AbstractParallelAnyArray.DFDCPap
hasFilter() - Method in AbstractParallelAnyArray.DFDMPap
hasFilter() - Method in AbstractParallelAnyArray.DFLCPap
hasFilter() - Method in AbstractParallelAnyArray.DFLMPap
hasFilter() - Method in AbstractParallelAnyArray.DFOCPap
hasFilter() - Method in AbstractParallelAnyArray.DFOMPap
hasFilter() - Method in AbstractParallelAnyArray.DFPap
hasFilter() - Method in AbstractParallelAnyArray.DRDCPap
hasFilter() - Method in AbstractParallelAnyArray.DRDMPap
hasFilter() - Method in AbstractParallelAnyArray.DRLCPap
hasFilter() - Method in AbstractParallelAnyArray.DRLMPap
hasFilter() - Method in AbstractParallelAnyArray.DROCPap
hasFilter() - Method in AbstractParallelAnyArray.DROMPap
hasFilter() - Method in AbstractParallelAnyArray.DRPap
hasFilter() - Method in AbstractParallelAnyArray.LFDCPap
hasFilter() - Method in AbstractParallelAnyArray.LFDMPap
hasFilter() - Method in AbstractParallelAnyArray.LFLCPap
hasFilter() - Method in AbstractParallelAnyArray.LFLMPap
hasFilter() - Method in AbstractParallelAnyArray.LFOCPap
hasFilter() - Method in AbstractParallelAnyArray.LFOMPap
hasFilter() - Method in AbstractParallelAnyArray.LFPap
hasFilter() - Method in AbstractParallelAnyArray.LRDCPap
hasFilter() - Method in AbstractParallelAnyArray.LRDMPap
hasFilter() - Method in AbstractParallelAnyArray.LRLCPap
hasFilter() - Method in AbstractParallelAnyArray.LRLMPap
hasFilter() - Method in AbstractParallelAnyArray.LROCPap
hasFilter() - Method in AbstractParallelAnyArray.LROMPap
hasFilter() - Method in AbstractParallelAnyArray.LRPap
hasFilter() - Method in AbstractParallelAnyArray.OFDCPap
hasFilter() - Method in AbstractParallelAnyArray.OFDMPap
hasFilter() - Method in AbstractParallelAnyArray.OFLCPap
hasFilter() - Method in AbstractParallelAnyArray.OFLMPap
hasFilter() - Method in AbstractParallelAnyArray.OFOCPap
hasFilter() - Method in AbstractParallelAnyArray.OFOMPap
hasFilter() - Method in AbstractParallelAnyArray.OFPap
hasFilter() - Method in AbstractParallelAnyArray.ORDCPap
hasFilter() - Method in AbstractParallelAnyArray.ORDMPap
hasFilter() - Method in AbstractParallelAnyArray.ORLCPap
hasFilter() - Method in AbstractParallelAnyArray.ORLMPap
hasFilter() - Method in AbstractParallelAnyArray.OROCPap
hasFilter() - Method in AbstractParallelAnyArray.OROMPap
hasFilter() - Method in AbstractParallelAnyArray.ORPap
hash(Object) - Method in CustomConcurrentHashMap.Equivalence
Returns a hash value such that equal(a, b) implies hash(a)==hash(b).
hash(Object) - Method in CustomConcurrentHashMap.EquivalenceUsingEquals
hash(Object) - Method in CustomConcurrentHashMap.EquivalenceUsingIdentity
hash(int) - Method in PAS.UniquifierTable
hashCode() - Method in CustomConcurrentHashMap
Returns the sum of the hash codes of each entry in this map's entrySet() view, which in turn are the hash codes computed using key and value Equivalences for this Map.
hashCode() - Method in CustomConcurrentHashMap.KeySet
Returns the sum of the hash codes of each element, as computed by this set's Equivalence.
hashCode() - Method in CustomConcurrentHashMap.WriteThroughEntry
hashCode() - Method in NullValue
hashCode() - Method in SelectResult
hashCode() - Method in StreamCore
hasMap() - Method in AbstractParallelAnyArray
hasMap() - Method in AbstractParallelAnyArray.DDCPap
hasMap() - Method in AbstractParallelAnyArray.DDMPap
hasMap() - Method in AbstractParallelAnyArray.DLCPap
hasMap() - Method in AbstractParallelAnyArray.DLMPap
hasMap() - Method in AbstractParallelAnyArray.DOCPap
hasMap() - Method in AbstractParallelAnyArray.DOMPap
hasMap() - Method in AbstractParallelAnyArray.LDCPap
hasMap() - Method in AbstractParallelAnyArray.LDMPap
hasMap() - Method in AbstractParallelAnyArray.LLCPap
hasMap() - Method in AbstractParallelAnyArray.LLMPap
hasMap() - Method in AbstractParallelAnyArray.LOCPap
hasMap() - Method in AbstractParallelAnyArray.LOMPap
hasMap() - Method in AbstractParallelAnyArray.ODCPap
hasMap() - Method in AbstractParallelAnyArray.ODMPap
hasMap() - Method in AbstractParallelAnyArray.OLCPap
hasMap() - Method in AbstractParallelAnyArray.OLMPap
hasMap() - Method in AbstractParallelAnyArray.OOCPap
hasMap() - Method in AbstractParallelAnyArray.OOMPap
hasNext() - Method in AbstractParallelAnyArray.FilteredAsDoubleIterator
hasNext() - Method in AbstractParallelAnyArray.FilteredAsLongIterator
hasNext() - Method in AbstractParallelAnyArray.FilteredIterator
hasNext() - Method in AbstractParallelAnyArray.UnfilteredAsDoubleIterator
hasNext() - Method in AbstractParallelAnyArray.UnfilteredAsLongIterator
hasNext() - Method in AbstractParallelAnyArray.UnfilteredIterator
hasNext() - Method in CustomConcurrentHashMap.HashIterator
hasNext() - Method in FListIterator
hasNext() - Method in ParallelArray.ListIter
hasNext() - Method in ParallelArray.ParallelArrayIterator
hasNext() - Method in ParallelDoubleArray.ListIter
hasNext() - Method in ParallelDoubleArray.ParallelDoubleArrayIterator
hasNext() - Method in ParallelLongArray.ListIter
hasNext() - Method in ParallelLongArray.ParallelLongArrayIterator
hasPrevious() - Method in ParallelArray.ListIter
hasPrevious() - Method in ParallelDoubleArray.ListIter
hasPrevious() - Method in ParallelLongArray.ListIter
head - Field in DataflowStreamReadAdapter
head - Field in DataflowStreamWriteAdapter
heading - Property in GPrint
headings - Property in GParPrint
hi - Field in ParallelArray.ListIter
hi - Field in ParallelArray.ParallelArrayIterator
hi - Field in ParallelDoubleArray.ListIter
hi - Field in ParallelDoubleArray.ParallelDoubleArrayIterator
hi - Field in ParallelLongArray.ListIter
hi - Field in ParallelLongArray.ParallelLongArrayIterator
hi - Field in PAS.FJBase
hi - Field in PAS.FJRemoveAll
hi - Field in PAS.FJRemoveAllDriver
hi - Field in PAS.FJScan
hi - Field in PAS.FJSearchBase
hi - Field in PAS.FJSelectAll
hookWheneverBoundListeners(DataflowExpression) - Method in DataflowQueue
Hooks the registered when bound handlers to the supplied dataflow expression
hookWheneverBoundListeners(DataflowExpression) - Method in StreamCore
Hooks the registered when bound handlers to the supplied dataflow expression
host - Field in RemoteConnection
hostId - Field in RemoteHandle
hostId - Field in SerialContext
hostId - Field in SerialMsg
HostIdMsg - Class in groovyx.gpars.remote.message
Message sent by NetTransportProvider immediately after connection to another host is set up
HostIdMsg(UUID) - Constructor in HostIdMsg
Construct message representing current state of the transport provider

I

id - Field in ActorTimerTask
id - Field in LocalHandle
id - Field in LocalNode
id - Field in NettyTransportProvider.ClientHandler
id - Field in RemoteNode
id - Field in SerialHandles
Unique id of the provider
IDENTITY - Field in CustomConcurrentHashMap
An Equivalence object performing identity-based comparisons and using java.lang.System#identityHashCode for hashing
identityPredicate() - Method in CommonOps
Returns a predicate evaluating to true if the first argument == the second
immediate - Field in PoisonPill
ImmediateCountingPoisonPill - Class in groovyx.gpars.dataflow.operator
Represents an immediate PoisonPill that counts stopped operators and can be used to wait for all the operators to terminate.
ImmediateCountingPoisonPill(int) - Constructor in ImmediateCountingPoisonPill
Creates an immediate instance that could be used to stop operators in a network.
immediateInstance - Field in PoisonPill
in - Field in PAS.FJDScan
in - Field in PAS.FJLScan
in - Field in PAS.FJOScan
inChannel0 - Property in GPlus
inChannel1 - Property in GPlus
inChannel - Property in GConsoleStringToInteger
inChannel - Property in GDelta2
inChannel - Property in GFixedDelay
inChannel - Property in GIdentity
inChannel - Property in GIntegrate
inChannel - Property in GObjectToConsoleString
inChannel - Property in GPairs
inChannel - Property in GPCopy
inChannel - Property in GPrefix
inChannel - Property in GPrint
inChannel - Property in GStatePairs
inChannel - Property in GSuccessor
inChannel - Property in GTail
inChannels - Property in FairMultiplex
inChannels - Property in GParPrint
inChannels - Property in Multiplexer
inChannels - Property in PriMultiplex
inChannels - Property in TimedMultiplex
increaseCount() - Method in ResizeableCountDownLatch
increaseCount() - Method in ResizeableCountDownLatch.Sync
incrementCount() - Method in CustomConcurrentHashMap.Segment
incrementParties() - Method in StreamCore
Increases the number of parties required to perform the data exchange
incrementParties() - Method in SyncDataflowStream
Increases the number of parties required to perform the data exchange
incrementParties() - Method in SyncDataflowVariable
Increases the number of parties required to perform data exchange by one.
index - Field in SelectCallback
index - Field in SelectResult
indexedMapper(BinaryLongOp, ParallelLongArrayWithLongMapping, int) - Method in AbstractParallelAnyArray
indexedSelector(BinaryLongPredicate, ParallelLongArrayWithLongMapping, int) - Method in AbstractParallelAnyArray
indexOf(double) - Method in AbstractParallelAnyArray.DUPap
indexOf(long) - Method in AbstractParallelAnyArray.LUPap
indexOf(Object) - Method in AbstractParallelAnyArray.OUPap
indexOf(Object) - Method in ParallelArray
Returns the index of some element equal to given target, or -1 if not present
indexOf(Object) - Method in ParallelArray.AsList
indexOf(Object) - Method in ParallelArrayWithBounds
Returns the index of some element equal to given target, or -1 if not present
indexOf(double) - Method in ParallelDoubleArray
Returns the index of some element equal to given target, or -1 if not present
indexOf(Object) - Method in ParallelDoubleArray.AsList
indexOf(double) - Method in ParallelDoubleArrayWithBounds
Returns the index of some element equal to given target, or -1 if not present
indexOf(long) - Method in ParallelLongArray
Returns the index of some element equal to given target, or -1 if not present
indexOf(Object) - Method in ParallelLongArray.AsList
indexOf(long) - Method in ParallelLongArrayWithBounds
Returns the index of some element equal to given target, or -1 if not present
indexOfMax() - Method in ParallelArray.SummaryStatistics
Returns the index of the maximum element, or -1 if empty
indexOfMax() - Method in ParallelDoubleArray.SummaryStatistics
Returns the index of the maximum element, or -1 if empty
indexOfMax() - Method in ParallelLongArray.SummaryStatistics
Returns the index of the maximum element, or -1 if empty
indexOfMax - Field in PAS.FJDStats
indexOfMax - Field in PAS.FJLStats
indexOfMax - Field in PAS.FJOStats
indexOfMin() - Method in ParallelArray.SummaryStatistics
Returns the index of the minimum element, or -1 if empty
indexOfMin() - Method in ParallelDoubleArray.SummaryStatistics
Returns the index of the minimum element, or -1 if empty
indexOfMin() - Method in ParallelLongArray.SummaryStatistics
Returns the index of the minimum element, or -1 if empty
indexOfMin - Field in PAS.FJDStats
indexOfMin - Field in PAS.FJLStats
indexOfMin - Field in PAS.FJOStats
indices - Field in PAS.FJRemoveAll
indices - Field in PAS.FJRemoveAllDriver
indices - Field in PAS.FJSelectAllDriver
inequalityPredicate() - Method in CommonOps
Returns a predicate evaluating to true if the first argument !
init(ASTNode) - Method in AsyncFunASTTransformation
initialize(Closure) - Method in AbstractLoopingActor
Builds the async messaging core using the supplied code handler
initialOffset - Field in PAS.FJSelectAllDriver
initialSegmentCapacity - Field in CustomConcurrentHashMap
The initial size of Segment tables when they are first constructed
initialValue() - Method in ThreadLocalPools
initiateShutdown() - Method in GracefulShutdownListener
Starts the shutdown phase by turning shutdownFlag on
inorderMove(FJRemoveAll, int) - Method in PAS.FJRemoveAllDriver
Inorder traversal to move indexed elements across reachable nodes.
inputQueue - Field in SequentialProcessingActor
Stored incoming messages.
inputQueueUpdater - Field in SequentialProcessingActor
INPUTS - Field in DataflowProcessor
inputs - Field in DataflowProcessorActor
inputs - Property in ProcessingNode
insertElementAt(int, Object) - Method in ParallelArray
insertElementAt(int, double) - Method in ParallelDoubleArray
insertElementAt(int, long) - Method in ParallelLongArray
INSERTION_SORT_THRESHOLD - Field in PAS
Cutoff for when to use insertion-sort instead of quicksort
insertSlotsAt(int, int) - Method in ParallelArray
Makes len slots available at index.
insertSlotsAt(int, int) - Method in ParallelDoubleArray
Makes len slots available at index.
insertSlotsAt(int, int) - Method in ParallelLongArray
Makes len slots available at index.
inside - Field in DefaultMessageQueue
inside - Field in FQMessageQueue
instance - Field in NettyTransportProvider.MyThreadFactory
instanceofPredicate(Class) - Method in CommonOps
Returns a predicate evaluating to true if its argument is an instance of (see java.lang.Class#isInstance the given type (class).
INT_STRING - Field in CustomConcurrentHashMap
Config string for int maps
intAdder() - Method in CommonOps
Returns a reducer that adds two int elements
intEqualityPredicate() - Method in CommonOps
Returns a predicate evaluating to true if the first argument == the second
intern(Object) - Method in CustomConcurrentHashMap.KeySet
Returns an element equivalent to the given element with respect to this set's Equivalence, if such an element exists, else adds and returns the given element.
INTERNAL_ACTIVE_OBJECT_ACTOR - Field in ActiveObject
InternalActor - Class in groovyx.gpars.activeobject
Backs active objects and invokes all object's active methods.
InternalActor() - Constructor in InternalActor
Just like DynamicDispatchActor, except that the actual method dispatch is static through the closure passed to the initialize() method.
internalCompute(int, int, int) - Method in PAS.FJBase
internalPhase0() - Method in PAS.FJSelectAll
internalPhase1() - Method in PAS.FJSelectAll
intInequalityPredicate() - Method in CommonOps
Returns a predicate evaluating to true if the first argument !
into(PGroup, Map, DataflowWriteChannel) - Method in DataflowExpression
into(PGroup, Map, DataflowWriteChannel) - Method in DataflowQueue
into(PGroup, Map, DataflowWriteChannel) - Method in DataflowReadChannel
Makes the output of the current channel to be an input for the specified channel
into(PGroup, Map, DataflowWriteChannel) - Method in DataflowStreamReadAdapter
into(Map, DataflowWriteChannel) - Method in Pipeline
Makes the output of the pipeline to be an input for the specified channel
intRandom(int, int) - Method in CommonOps
Returns a generator producing uniform random values between the given least value (inclusive) and bound (exclusive)
inverse(Closure) - Method in KanbanFlow
Helper method that inverses the sequence of Closure parameters
invokeMethod(String, Object) - Method in DataflowExpression
Invokes the method on itself or creates an expression, which will invoke the method n the bound value, once it is available.
invokeMethod(String, Object) - Method in Dataflows
Invokes the given method.
invokeMethod(String, Object) - Method in ForwardingDelegate
invokeMethod(String, Object) - Method in RunnableBackedBlockingActor.RunnableBackedPooledActorDelegate
isActive() - Method in AbstractLoopingActor
isActive() - Method in Actor
Checks the current status of the Actor.
isActive() - Method in Actor.RemoteActor
isActive() - Method in SequentialProcessingActor
Checks the current status of the Actor.
isActorThread() - Method in Actor
Checks whether the current thread is the actor's current thread.
isAssignablePredicate(Class) - Method in CommonOps
Returns a predicate evaluating to true if its argument is assignable from (see java.lang.Class#isAssignableFrom the given type (class).
isBound() - Method in DataflowExpression
Check if value has been set already for this expression
isBound() - Method in DataflowQueue
Check if value has been set already for this expression
isBound() - Method in DataflowReadChannel
Check if value has been set already for this expression
isBound() - Method in DataflowStreamReadAdapter
isBound() - Method in Promise
Check if value has been set already for this expression
isBound() - Method in SyncDataflowStreamReadAdapter
isComplete() - Method in Pipeline
isConcurrencyActive() - Method in TransparentParallel
Indicates, whether the iterative methods like each() or collect() should have a concurrent or a sequential semantics.
isConcurrent(Object) - Method in GParsPoolUtil
Indicates whether the iterative methods like each() or collect() work have been altered to work concurrently.
isConcurrent() - Method in Parallel
Indicates, whether the iterative methods like each() or collect() have been made parallel.
isConcurrent() - Method in TransparentParallel
Indicates, whether the iterative methods like each() or collect() have been made parallel.
isConnected() - Method in RemoteHost
isControlMessage(Object) - Method in DataflowProcessorActor
isEmpty() - Method in AbstractParallelAnyArray
Returns true if there are no elements
isEmpty() - Method in CustomConcurrentHashMap
Returns true if this map contains no key-value mappings.
isEmpty() - Method in CustomConcurrentHashMap.EntrySet
isEmpty() - Method in CustomConcurrentHashMap.KeySet
Returns true if this set contains no elements.
isEmpty() - Method in CustomConcurrentHashMap.KeySetView
isEmpty() - Method in CustomConcurrentHashMap.Values
isEmpty() - Method in DefaultMessageQueue
isEmpty() - Method in FList
isEmpty() - Method in FQMessageQueue
isEmpty() - Method in FQMessageQueue.EmptyNode
isEmpty() - Method in FQMessageQueue.Node
isEmpty() - Method in MessageQueue
isEmpty() - Method in ParallelArray.AsList
isEmpty() - Method in ParallelDoubleArray.AsList
isEmpty() - Method in ParallelLongArray.AsList
isEmpty() - Method in StreamCore
Indicates, whether the first element in the stream is an eos
isEmptyWithRespectToSync() - Method in SyncDataflowStream
isError() - Method in DataflowVariable
Checks if the promise is bound to an error
isError() - Method in Promise
Checks if the promise is bound to an error
isFair() - Method in AbstractLoopingActor
Retrieves the actor's fairness flag Fair actors give up the thread after processing each message, non-fair actors keep a thread until their message queue is empty.
isFair() - Method in AgentCore
Retrieves the agent's fairness flag Fair agents give up the thread after processing each message, non-fair agents keep a thread until their message queue is empty.
isFair() - Method in AsyncMessagingCore
Retrieves the agent's fairness flag Fair agents give up the thread after processing each message, non-fair agents keep a thread until their message queue is empty.
isIdle() - Method in GracefulShutdownListener
A quick check on, whether the operator/selector is in the Idle state
isIdleAndNoIncomingMessages() - Method in GracefulShutdownListener
A more sophisticated test for being Idle
isImmediate() - Method in PoisonPill
isInternal - Field in PAS.FJSelectAll
isListAccepting(Closure) - Method in PGroup
isNonNullPredicate() - Method in CommonOps
Returns a predicate evaluating to true if its argument is non-null
isNullPredicate() - Method in CommonOps
Returns a predicate evaluating to true if its argument is null
isReleasedFlag() - Method in ResizeableCountDownLatch
isRootActiveObject(ClassNode) - Method in ActiveObjectASTTransformation
isSelected(int) - Method in AbstractParallelAnyArray
isSelected(int) - Method in AbstractParallelAnyArray.DFDCPap
isSelected(int) - Method in AbstractParallelAnyArray.DFDMPap
isSelected(int) - Method in AbstractParallelAnyArray.DFLCPap
isSelected(int) - Method in AbstractParallelAnyArray.DFLMPap
isSelected(int) - Method in AbstractParallelAnyArray.DFOCPap
isSelected(int) - Method in AbstractParallelAnyArray.DFOMPap
isSelected(int) - Method in AbstractParallelAnyArray.DFPap
isSelected(int) - Method in AbstractParallelAnyArray.DRDCPap
isSelected(int) - Method in AbstractParallelAnyArray.DRDMPap
isSelected(int) - Method in AbstractParallelAnyArray.DRLCPap
isSelected(int) - Method in AbstractParallelAnyArray.DRLMPap
isSelected(int) - Method in AbstractParallelAnyArray.DROCPap
isSelected(int) - Method in AbstractParallelAnyArray.DROMPap
isSelected(int) - Method in AbstractParallelAnyArray.DRPap
isSelected(int) - Method in AbstractParallelAnyArray.LFDCPap
isSelected(int) - Method in AbstractParallelAnyArray.LFDMPap
isSelected(int) - Method in AbstractParallelAnyArray.LFLCPap
isSelected(int) - Method in AbstractParallelAnyArray.LFLMPap
isSelected(int) - Method in AbstractParallelAnyArray.LFOCPap
isSelected(int) - Method in AbstractParallelAnyArray.LFOMPap
isSelected(int) - Method in AbstractParallelAnyArray.LFPap
isSelected(int) - Method in AbstractParallelAnyArray.LRDCPap
isSelected(int) - Method in AbstractParallelAnyArray.LRDMPap
isSelected(int) - Method in AbstractParallelAnyArray.LRLCPap
isSelected(int) - Method in AbstractParallelAnyArray.LRLMPap
isSelected(int) - Method in AbstractParallelAnyArray.LROCPap
isSelected(int) - Method in AbstractParallelAnyArray.LROMPap
isSelected(int) - Method in AbstractParallelAnyArray.LRPap
isSelected(int) - Method in AbstractParallelAnyArray.OFDCPap
isSelected(int) - Method in AbstractParallelAnyArray.OFDMPap
isSelected(int) - Method in AbstractParallelAnyArray.OFLCPap
isSelected(int) - Method in AbstractParallelAnyArray.OFLMPap
isSelected(int) - Method in AbstractParallelAnyArray.OFOCPap
isSelected(int) - Method in AbstractParallelAnyArray.OFOMPap
isSelected(int) - Method in AbstractParallelAnyArray.OFPap
isSelected(int) - Method in AbstractParallelAnyArray.ORDCPap
isSelected(int) - Method in AbstractParallelAnyArray.ORDMPap
isSelected(int) - Method in AbstractParallelAnyArray.ORLCPap
isSelected(int) - Method in AbstractParallelAnyArray.ORLMPap
isSelected(int) - Method in AbstractParallelAnyArray.OROCPap
isSelected(int) - Method in AbstractParallelAnyArray.OROMPap
isSelected(int) - Method in AbstractParallelAnyArray.ORPap
isSet - Field in MessageStream.ResultWaiter
issues - Field in ActorReplyException
iterator() - Method in AbstractParallelAnyArray.Sequentially
iterator() - Method in AbstractParallelAnyArray.SequentiallyAsDouble
iterator() - Method in AbstractParallelAnyArray.SequentiallyAsLong
iterator() - Method in CustomConcurrentHashMap.EntrySet
iterator() - Method in CustomConcurrentHashMap.KeySet
Returns a weakly consistent iterator over the elements in this set, that may reflect some, all or none of the changes made to the set after the iterator was created.
iterator() - Method in CustomConcurrentHashMap.KeySetView
iterator() - Method in CustomConcurrentHashMap.Values
iterator() - Method in DataflowQueue
Returns an iterator over a current snapshot of the buffer's content.
iterator() - Method in Dataflows
Convenience method to play nicely with Groovy object iteration methods.
iterator() - Method in DataflowStreamReadAdapter
iterator() - Method in ParallelArray
Returns an iterator stepping through each element of the array up to the current limit.
iterator() - Method in ParallelArray.AsList
iterator() - Method in ParallelDoubleArray
Returns an iterator stepping through each element of the array up to the current limit.
iterator() - Method in ParallelDoubleArray.AsList
iterator() - Method in ParallelLongArray
Returns an iterator stepping through each element of the array up to the current limit.
iterator() - Method in ParallelLongArray.AsList
iterator() - Method in StreamCore
Builds an iterator to iterate over the stream
iterator() - Method in SyncDataflowStreamReadAdapter

J

JCSPCopy - Interface in groovyx.gpars.csp
join(BaseDuration) - Method in Actor
Joins the actor.
join(long, TimeUnit) - Method in CountingPoisonPill
Blocks until the number of terminated operators reaches the number specified in the constructor
join(long, TimeUnit) - Method in DataflowExpression
Blocks, if the value has not been assigned yet to the DataflowVariable
join() - Method in DataflowProcessor
Joins the processor waiting for it to finish
join(long, TimeUnit) - Method in ImmediateCountingPoisonPill
Blocks until the number of terminated operators reaches the number specified in the constructor
join(long, TimeUnit) - Method in PoisonTrackCounter
Blocks until the number of terminated operators reaches the number specified in the constructor
join(long, TimeUnit) - Method in Promise
Blocks, if the value has not been assigned yet to the DataflowVariable
joinLatch - Field in Actor
joinLatch - Field in Actor.MyRemoteHandle

K

KanbanFlow - Class in groovyx.gpars.dataflow
A KanbanFlow is a network of dataflow connections made up from KanbanLinks.
KanbanFlow() - Constructor in KanbanFlow
KanbanLink - Class in groovyx.gpars.dataflow
A KanbanLink is the simplest possible producer-consumer pair in a kanban-like scenario as described in KanbanLink() - Constructor in KanbanLink
KanbanTray - Class in groovyx.gpars.dataflow
A KanbanTray is a container for passing a product around a {@KanbanLink}.
KanbanTray() - Constructor in KanbanTray
KEEP_ALIVE_TIME - Field in ResizeablePool
key - Field in CustomConcurrentHashMap.IntKeyNode
key - Field in CustomConcurrentHashMap.StrongKeyNode
key - Field in CustomConcurrentHashMap.WriteThroughEntry
keyEquivalence - Field in CustomConcurrentHashMap
Equivalence object for keys
keyIterator() - Method in CustomConcurrentHashMap
keySet - Field in CustomConcurrentHashMap
klazz - Field in DefaultRemoteHandle

L

lastIndexOf(Object) - Method in ParallelArray.AsList
lastIndexOf(Object) - Method in ParallelDoubleArray.AsList
lastIndexOf(Object) - Method in ParallelLongArray.AsList
lastKey - Field in CustomConcurrentHashMap.HashIterator
lastRet - Field in ParallelArray.ListIter
lastRet - Field in ParallelDoubleArray.ListIter
lastRet - Field in ParallelLongArray.ListIter
lastTaskPoke - Field in Scheduler
leafApply(int, int, LongProcedure) - Method in AbstractParallelAnyArray
leafApply(int, int, DoubleProcedure) - Method in AbstractParallelAnyArray.DFDCPap
leafApply(int, int, DoubleProcedure) - Method in AbstractParallelAnyArray.DFDMPap
leafApply(int, int, LongProcedure) - Method in AbstractParallelAnyArray.DFLCPap
leafApply(int, int, LongProcedure) - Method in AbstractParallelAnyArray.DFLMPap
leafApply(int, int, Procedure) - Method in AbstractParallelAnyArray.DFOCPap
leafApply(int, int, Procedure) - Method in AbstractParallelAnyArray.DFOMPap
leafApply(int, int, DoubleProcedure) - Method in AbstractParallelAnyArray.DFPap
leafApply(int, int, DoubleProcedure) - Method in AbstractParallelAnyArray.DRDCPap
leafApply(int, int, DoubleProcedure) - Method in AbstractParallelAnyArray.DRDMPap
leafApply(int, int, LongProcedure) - Method in AbstractParallelAnyArray.DRLCPap
leafApply(int, int, LongProcedure) - Method in AbstractParallelAnyArray.DRLMPap
leafApply(int, int, Procedure) - Method in AbstractParallelAnyArray.DROCPap
leafApply(int, int, Procedure) - Method in AbstractParallelAnyArray.DROMPap
leafApply(int, int, DoubleProcedure) - Method in AbstractParallelAnyArray.DRPap
leafApply(int, int, DoubleProcedure) - Method in AbstractParallelAnyArray.DUDCPap
leafApply(int, int, DoubleProcedure) - Method in AbstractParallelAnyArray.DUDMPap
leafApply(int, int, LongProcedure) - Method in AbstractParallelAnyArray.DULCPap
leafApply(int, int, LongProcedure) - Method in AbstractParallelAnyArray.DULMPap
leafApply(int, int, Procedure) - Method in AbstractParallelAnyArray.DUOCPap
leafApply(int, int, Procedure) - Method in AbstractParallelAnyArray.DUOMPap
leafApply(int, int, DoubleProcedure) - Method in AbstractParallelAnyArray.DUPap
leafApply(int, int, DoubleProcedure) - Method in AbstractParallelAnyArray.LFDCPap
leafApply(int, int, DoubleProcedure) - Method in AbstractParallelAnyArray.LFDMPap
leafApply(int, int, LongProcedure) - Method in AbstractParallelAnyArray.LFLCPap
leafApply(int, int, LongProcedure) - Method in AbstractParallelAnyArray.LFLMPap
leafApply(int, int, Procedure) - Method in AbstractParallelAnyArray.LFOCPap
leafApply(int, int, Procedure) - Method in AbstractParallelAnyArray.LFOMPap
leafApply(int, int, LongProcedure) - Method in AbstractParallelAnyArray.LFPap
leafApply(int, int, DoubleProcedure) - Method in AbstractParallelAnyArray.LRDCPap
leafApply(int, int, DoubleProcedure) - Method in AbstractParallelAnyArray.LRDMPap
leafApply(int, int, LongProcedure) - Method in AbstractParallelAnyArray.LRLCPap
leafApply(int, int, LongProcedure) - Method in AbstractParallelAnyArray.LRLMPap
leafApply(int, int, Procedure) - Method in AbstractParallelAnyArray.LROCPap
leafApply(int, int, Procedure) - Method in AbstractParallelAnyArray.LROMPap
leafApply(int, int, LongProcedure) - Method in AbstractParallelAnyArray.LRPap
leafApply(int, int, DoubleProcedure) - Method in AbstractParallelAnyArray.LUDCPap
leafApply(int, int, DoubleProcedure) - Method in AbstractParallelAnyArray.LUDMPap
leafApply(int, int, LongProcedure) - Method in AbstractParallelAnyArray.LULCPap
leafApply(int, int, LongProcedure) - Method in AbstractParallelAnyArray.LULMPap
leafApply(int, int, Procedure) - Method in AbstractParallelAnyArray.LUOCPap
leafApply(int, int, Procedure) - Method in AbstractParallelAnyArray.LUOMPap
leafApply(int, int, LongProcedure) - Method in AbstractParallelAnyArray.LUPap
leafApply(int, int, DoubleProcedure) - Method in AbstractParallelAnyArray.OFDCPap
leafApply(int, int, DoubleProcedure) - Method in AbstractParallelAnyArray.OFDMPap
leafApply(int, int, LongProcedure) - Method in AbstractParallelAnyArray.OFLCPap
leafApply(int, int, LongProcedure) - Method in AbstractParallelAnyArray.OFLMPap
leafApply(int, int, Procedure) - Method in AbstractParallelAnyArray.OFOCPap
leafApply(int, int, Procedure) - Method in AbstractParallelAnyArray.OFOMPap
leafApply(int, int, Procedure) - Method in AbstractParallelAnyArray.OFPap
leafApply(int, int, DoubleProcedure) - Method in AbstractParallelAnyArray.ORDCPap
leafApply(int, int, DoubleProcedure) - Method in AbstractParallelAnyArray.ORDMPap
leafApply(int, int, LongProcedure) - Method in AbstractParallelAnyArray.ORLCPap
leafApply(int, int, LongProcedure) - Method in AbstractParallelAnyArray.ORLMPap
leafApply(int, int, Procedure) - Method in AbstractParallelAnyArray.OROCPap
leafApply(int, int, Procedure) - Method in AbstractParallelAnyArray.OROMPap
leafApply(int, int, Procedure) - Method in AbstractParallelAnyArray.ORPap
leafApply(int, int, DoubleProcedure) - Method in AbstractParallelAnyArray.OUDCPap
leafApply(int, int, DoubleProcedure) - Method in AbstractParallelAnyArray.OUDMPap
leafApply(int, int, LongProcedure) - Method in AbstractParallelAnyArray.OULCPap
leafApply(int, int, LongProcedure) - Method in AbstractParallelAnyArray.OULMPap
leafApply(int, int, Procedure) - Method in AbstractParallelAnyArray.OUOCPap
leafApply(int, int, Procedure) - Method in AbstractParallelAnyArray.OUOMPap
leafApply(int, int, Procedure) - Method in AbstractParallelAnyArray.OUPap
leafBinaryIndexMap(int, int, IntAndLongToLong) - Method in AbstractParallelAnyArray
leafBinaryIndexMap(int, int, IntAndDoubleToDouble) - Method in AbstractParallelAnyArray.DFPap
leafBinaryIndexMap(int, int, IntAndDoubleToDouble) - Method in AbstractParallelAnyArray.DRPap
leafBinaryIndexMap(int, int, IntAndDoubleToDouble) - Method in AbstractParallelAnyArray.DUPap
leafBinaryIndexMap(int, int, IntAndLongToLong) - Method in AbstractParallelAnyArray.LFPap
leafBinaryIndexMap(int, int, IntAndLongToLong) - Method in AbstractParallelAnyArray.LRPap
leafBinaryIndexMap(int, int, IntAndLongToLong) - Method in AbstractParallelAnyArray.LUPap
leafBinaryIndexMap(int, int, IntAndObjectToObject) - Method in AbstractParallelAnyArray.OFPap
leafBinaryIndexMap(int, int, IntAndObjectToObject) - Method in AbstractParallelAnyArray.ORPap
leafBinaryIndexMap(int, int, IntAndObjectToObject) - Method in AbstractParallelAnyArray.OUPap
leafCombineInPlace(int, int, ParallelLongArrayWithLongMapping, int, BinaryLongOp) - Method in AbstractParallelAnyArray
leafCombineInPlace(int, int, ParallelDoubleArrayWithDoubleMapping, int, BinaryDoubleOp) - Method in AbstractParallelAnyArray.DFPap
leafCombineInPlace(int, int, ParallelDoubleArrayWithDoubleMapping, int, BinaryDoubleOp) - Method in AbstractParallelAnyArray.DRPap
leafCombineInPlace(int, int, ParallelDoubleArrayWithDoubleMapping, int, BinaryDoubleOp) - Method in AbstractParallelAnyArray.DUPap
leafCombineInPlace(int, int, ParallelLongArrayWithLongMapping, int, BinaryLongOp) - Method in AbstractParallelAnyArray.LFPap
leafCombineInPlace(int, int, ParallelLongArrayWithLongMapping, int, BinaryLongOp) - Method in AbstractParallelAnyArray.LRPap
leafCombineInPlace(int, int, ParallelLongArrayWithLongMapping, int, BinaryLongOp) - Method in AbstractParallelAnyArray.LUPap
leafCombineInPlace(int, int, ParallelArrayWithMapping, int, BinaryOp) - Method in AbstractParallelAnyArray.OFPap
leafCombineInPlace(int, int, ParallelArrayWithMapping, int, BinaryOp) - Method in AbstractParallelAnyArray.ORPap
leafCombineInPlace(int, int, ParallelArrayWithMapping, int, BinaryOp) - Method in AbstractParallelAnyArray.OUPap
leafFill(int, int, long) - Method in AbstractParallelAnyArray
leafFill(int, int, double) - Method in AbstractParallelAnyArray.DFPap
leafFill(int, int, double) - Method in AbstractParallelAnyArray.DRPap
leafFill(int, int, double) - Method in AbstractParallelAnyArray.DUPap
leafFill(int, int, long) - Method in AbstractParallelAnyArray.LFPap
leafFill(int, int, long) - Method in AbstractParallelAnyArray.LRPap
leafFill(int, int, long) - Method in AbstractParallelAnyArray.LUPap
leafFill(int, int, Object) - Method in AbstractParallelAnyArray.OFPap
leafFill(int, int, Object) - Method in AbstractParallelAnyArray.ORPap
leafFill(int, int, Object) - Method in AbstractParallelAnyArray.OUPap
leafGenerate(int, int, LongGenerator) - Method in AbstractParallelAnyArray
leafGenerate(int, int, DoubleGenerator) - Method in AbstractParallelAnyArray.DFPap
leafGenerate(int, int, DoubleGenerator) - Method in AbstractParallelAnyArray.DRPap
leafGenerate(int, int, DoubleGenerator) - Method in AbstractParallelAnyArray.DUPap
leafGenerate(int, int, LongGenerator) - Method in AbstractParallelAnyArray.LFPap
leafGenerate(int, int, LongGenerator) - Method in AbstractParallelAnyArray.LRPap
leafGenerate(int, int, LongGenerator) - Method in AbstractParallelAnyArray.LUPap
leafGenerate(int, int, Generator) - Method in AbstractParallelAnyArray.OFPap
leafGenerate(int, int, Generator) - Method in AbstractParallelAnyArray.ORPap
leafGenerate(int, int, Generator) - Method in AbstractParallelAnyArray.OUPap
leafIndexMap(int, int, IntToLong) - Method in AbstractParallelAnyArray
leafIndexMap(int, int, IntToDouble) - Method in AbstractParallelAnyArray.DFPap
leafIndexMap(int, int, IntToDouble) - Method in AbstractParallelAnyArray.DRPap
leafIndexMap(int, int, IntToDouble) - Method in AbstractParallelAnyArray.DUPap
leafIndexMap(int, int, IntToLong) - Method in AbstractParallelAnyArray.LFPap
leafIndexMap(int, int, IntToLong) - Method in AbstractParallelAnyArray.LRPap
leafIndexMap(int, int, IntToLong) - Method in AbstractParallelAnyArray.LUPap
leafIndexMap(int, int, IntToObject) - Method in AbstractParallelAnyArray.OFPap
leafIndexMap(int, int, IntToObject) - Method in AbstractParallelAnyArray.ORPap
leafIndexMap(int, int, IntToObject) - Method in AbstractParallelAnyArray.OUPap
leafIndexSelected(int, int, boolean, int[]) - Method in AbstractParallelAnyArray
leafMoveByIndex(int[], int, int, int) - Method in AbstractParallelAnyArray
leafMoveByIndex(int[], int, int, int) - Method in AbstractParallelAnyArray.DPap
leafMoveByIndex(int[], int, int, int) - Method in AbstractParallelAnyArray.LPap
leafMoveByIndex(int[], int, int, int) - Method in AbstractParallelAnyArray.OPap
leafMoveSelected(int, int, int, boolean) - Method in AbstractParallelAnyArray
leafMoveSelected(int, int, int, boolean) - Method in AbstractParallelAnyArray.DPap
leafMoveSelected(int, int, int, boolean) - Method in AbstractParallelAnyArray.LPap
leafMoveSelected(int, int, int, boolean) - Method in AbstractParallelAnyArray.OPap
leafPhase1(int, int, int) - Method in PAS.FJDAppendAllDriver
leafPhase1(int, int, int) - Method in PAS.FJDSelectAllDriver
leafPhase1(int, int, int) - Method in PAS.FJLAppendAllDriver
leafPhase1(int, int, int) - Method in PAS.FJLSelectAllDriver
leafPhase1(int, int, int) - Method in PAS.FJOAppendAllDriver
leafPhase1(int, int, int) - Method in PAS.FJOSelectAllDriver
leafPhase1(int, int, int) - Method in PAS.FJSelectAllDriver
leafReduce(int, int, LongReducer, long) - Method in AbstractParallelAnyArray
leafReduce(int, int, DoubleReducer, double) - Method in AbstractParallelAnyArray.DFDCPap
leafReduce(int, int, DoubleReducer, double) - Method in AbstractParallelAnyArray.DFDMPap
leafReduce(int, int, LongReducer, long) - Method in AbstractParallelAnyArray.DFLCPap
leafReduce(int, int, LongReducer, long) - Method in AbstractParallelAnyArray.DFLMPap
leafReduce(int, int, Reducer, Object) - Method in AbstractParallelAnyArray.DFOCPap
leafReduce(int, int, Reducer, Object) - Method in AbstractParallelAnyArray.DFOMPap
leafReduce(int, int, DoubleReducer, double) - Method in AbstractParallelAnyArray.DFPap
leafReduce(int, int, DoubleReducer, double) - Method in AbstractParallelAnyArray.DRDCPap
leafReduce(int, int, DoubleReducer, double) - Method in AbstractParallelAnyArray.DRDMPap
leafReduce(int, int, LongReducer, long) - Method in AbstractParallelAnyArray.DRLCPap
leafReduce(int, int, LongReducer, long) - Method in AbstractParallelAnyArray.DRLMPap
leafReduce(int, int, Reducer, Object) - Method in AbstractParallelAnyArray.DROCPap
leafReduce(int, int, Reducer, Object) - Method in AbstractParallelAnyArray.DROMPap
leafReduce(int, int, DoubleReducer, double) - Method in AbstractParallelAnyArray.DRPap
leafReduce(int, int, DoubleReducer, double) - Method in AbstractParallelAnyArray.DUDCPap
leafReduce(int, int, DoubleReducer, double) - Method in AbstractParallelAnyArray.DUDMPap
leafReduce(int, int, LongReducer, long) - Method in AbstractParallelAnyArray.DULCPap
leafReduce(int, int, LongReducer, long) - Method in AbstractParallelAnyArray.DULMPap
leafReduce(int, int, Reducer, Object) - Method in AbstractParallelAnyArray.DUOCPap
leafReduce(int, int, Reducer, Object) - Method in AbstractParallelAnyArray.DUOMPap
leafReduce(int, int, DoubleReducer, double) - Method in AbstractParallelAnyArray.DUPap
leafReduce(int, int, DoubleReducer, double) - Method in AbstractParallelAnyArray.LFDCPap
leafReduce(int, int, DoubleReducer, double) - Method in AbstractParallelAnyArray.LFDMPap
leafReduce(int, int, LongReducer, long) - Method in AbstractParallelAnyArray.LFLCPap
leafReduce(int, int, LongReducer, long) - Method in AbstractParallelAnyArray.LFLMPap
leafReduce(int, int, Reducer, Object) - Method in AbstractParallelAnyArray.LFOCPap
leafReduce(int, int, Reducer, Object) - Method in AbstractParallelAnyArray.LFOMPap
leafReduce(int, int, LongReducer, long) - Method in AbstractParallelAnyArray.LFPap
leafReduce(int, int, DoubleReducer, double) - Method in AbstractParallelAnyArray.LRDCPap
leafReduce(int, int, DoubleReducer, double) - Method in AbstractParallelAnyArray.LRDMPap
leafReduce(int, int, LongReducer, long) - Method in AbstractParallelAnyArray.LRLCPap
leafReduce(int, int, LongReducer, long) - Method in AbstractParallelAnyArray.LRLMPap
leafReduce(int, int, Reducer, Object) - Method in AbstractParallelAnyArray.LROCPap
leafReduce(int, int, Reducer, Object) - Method in AbstractParallelAnyArray.LROMPap
leafReduce(int, int, LongReducer, long) - Method in AbstractParallelAnyArray.LRPap
leafReduce(int, int, DoubleReducer, double) - Method in AbstractParallelAnyArray.LUDCPap
leafReduce(int, int, DoubleReducer, double) - Method in AbstractParallelAnyArray.LUDMPap
leafReduce(int, int, LongReducer, long) - Method in AbstractParallelAnyArray.LULCPap
leafReduce(int, int, LongReducer, long) - Method in AbstractParallelAnyArray.LULMPap
leafReduce(int, int, Reducer, Object) - Method in AbstractParallelAnyArray.LUOCPap
leafReduce(int, int, Reducer, Object) - Method in AbstractParallelAnyArray.LUOMPap
leafReduce(int, int, LongReducer, long) - Method in AbstractParallelAnyArray.LUPap
leafReduce(int, int, DoubleReducer, double) - Method in AbstractParallelAnyArray.OFDCPap
leafReduce(int, int, DoubleReducer, double) - Method in AbstractParallelAnyArray.OFDMPap
leafReduce(int, int, LongReducer, long) - Method in AbstractParallelAnyArray.OFLCPap
leafReduce(int, int, LongReducer, long) - Method in AbstractParallelAnyArray.OFLMPap
leafReduce(int, int, Reducer, Object) - Method in AbstractParallelAnyArray.OFOCPap
leafReduce(int, int, Reducer, Object) - Method in AbstractParallelAnyArray.OFOMPap
leafReduce(int, int, Reducer, Object) - Method in AbstractParallelAnyArray.OFPap
leafReduce(int, int, DoubleReducer, double) - Method in AbstractParallelAnyArray.ORDCPap
leafReduce(int, int, DoubleReducer, double) - Method in AbstractParallelAnyArray.ORDMPap
leafReduce(int, int, LongReducer, long) - Method in AbstractParallelAnyArray.ORLCPap
leafReduce(int, int, LongReducer, long) - Method in AbstractParallelAnyArray.ORLMPap
leafReduce(int, int, Reducer, Object) - Method in AbstractParallelAnyArray.OROCPap
leafReduce(int, int, Reducer, Object) - Method in AbstractParallelAnyArray.OROMPap
leafReduce(int, int, Reducer, Object) - Method in AbstractParallelAnyArray.ORPap
leafReduce(int, int, DoubleReducer, double) - Method in AbstractParallelAnyArray.OUDCPap
leafReduce(int, int, DoubleReducer, double) - Method in AbstractParallelAnyArray.OUDMPap
leafReduce(int, int, LongReducer, long) - Method in AbstractParallelAnyArray.OULCPap
leafReduce(int, int, LongReducer, long) - Method in AbstractParallelAnyArray.OULMPap
leafReduce(int, int, Reducer, Object) - Method in AbstractParallelAnyArray.OUOCPap
leafReduce(int, int, Reducer, Object) - Method in AbstractParallelAnyArray.OUOMPap
leafReduce(int, int, Reducer, Object) - Method in AbstractParallelAnyArray.OUPap
leafTransfer(int, int, long[], int) - Method in AbstractParallelAnyArray
leafTransfer(int, int, double[], int) - Method in AbstractParallelAnyArray.DDCPap
leafTransfer(int, int, double[], int) - Method in AbstractParallelAnyArray.DDMPap
leafTransfer(int, int, long[], int) - Method in AbstractParallelAnyArray.DLCPap
leafTransfer(int, int, long[], int) - Method in AbstractParallelAnyArray.DLMPap
leafTransfer(int, int, Object, int) - Method in AbstractParallelAnyArray.DOCPap
leafTransfer(int, int, Object, int) - Method in AbstractParallelAnyArray.DOMPap
leafTransfer(int, int, double[], int) - Method in AbstractParallelAnyArray.LDCPap
leafTransfer(int, int, double[], int) - Method in AbstractParallelAnyArray.LDMPap
leafTransfer(int, int, long[], int) - Method in AbstractParallelAnyArray.LLCPap
leafTransfer(int, int, long[], int) - Method in AbstractParallelAnyArray.LLMPap
leafTransfer(int, int, Object, int) - Method in AbstractParallelAnyArray.LOCPap
leafTransfer(int, int, Object, int) - Method in AbstractParallelAnyArray.LOMPap
leafTransfer(int, int, double[], int) - Method in AbstractParallelAnyArray.ODCPap
leafTransfer(int, int, double[], int) - Method in AbstractParallelAnyArray.ODMPap
leafTransfer(int, int, long[], int) - Method in AbstractParallelAnyArray.OLCPap
leafTransfer(int, int, long[], int) - Method in AbstractParallelAnyArray.OLMPap
leafTransfer(int, int, Object, int) - Method in AbstractParallelAnyArray.OOCPap
leafTransfer(int, int, Object, int) - Method in AbstractParallelAnyArray.OOMPap
leafTransfer(int, int, Object, int) - Method in ParallelArrayWithFilter
leafTransfer(int, int, double[], int) - Method in ParallelDoubleArrayWithFilter
leafTransfer(int, int, long[], int) - Method in ParallelLongArrayWithFilter
leafTransferByIndex(int[], int, int, long[], int) - Method in AbstractParallelAnyArray
leafTransferByIndex(int[], int, int, double[], int) - Method in AbstractParallelAnyArray.DDCPap
leafTransferByIndex(int[], int, int, double[], int) - Method in AbstractParallelAnyArray.DDMPap
leafTransferByIndex(int[], int, int, long[], int) - Method in AbstractParallelAnyArray.DLCPap
leafTransferByIndex(int[], int, int, long[], int) - Method in AbstractParallelAnyArray.DLMPap
leafTransferByIndex(int[], int, int, Object, int) - Method in AbstractParallelAnyArray.DOCPap
leafTransferByIndex(int[], int, int, Object, int) - Method in AbstractParallelAnyArray.DOMPap
leafTransferByIndex(int[], int, int, double[], int) - Method in AbstractParallelAnyArray.LDCPap
leafTransferByIndex(int[], int, int, double[], int) - Method in AbstractParallelAnyArray.LDMPap
leafTransferByIndex(int[], int, int, long[], int) - Method in AbstractParallelAnyArray.LLCPap
leafTransferByIndex(int[], int, int, long[], int) - Method in AbstractParallelAnyArray.LLMPap
leafTransferByIndex(int[], int, int, Object, int) - Method in AbstractParallelAnyArray.LOCPap
leafTransferByIndex(int[], int, int, Object, int) - Method in AbstractParallelAnyArray.LOMPap
leafTransferByIndex(int[], int, int, double[], int) - Method in AbstractParallelAnyArray.ODCPap
leafTransferByIndex(int[], int, int, double[], int) - Method in AbstractParallelAnyArray.ODMPap
leafTransferByIndex(int[], int, int, long[], int) - Method in AbstractParallelAnyArray.OLCPap
leafTransferByIndex(int[], int, int, long[], int) - Method in AbstractParallelAnyArray.OLMPap
leafTransferByIndex(int[], int, int, Object, int) - Method in AbstractParallelAnyArray.OOCPap
leafTransferByIndex(int[], int, int, Object, int) - Method in AbstractParallelAnyArray.OOMPap
leafTransferByIndex(int[], int, int, Object, int) - Method in ParallelArrayWithFilter
leafTransferByIndex(int[], int, int, double[], int) - Method in ParallelDoubleArrayWithFilter
leafTransferByIndex(int[], int, int, long[], int) - Method in ParallelLongArrayWithFilter
leafTransform(int, int, LongOp) - Method in AbstractParallelAnyArray
leafTransform(int, int, DoubleOp) - Method in AbstractParallelAnyArray.DFPap
leafTransform(int, int, DoubleOp) - Method in AbstractParallelAnyArray.DRPap
leafTransform(int, int, DoubleOp) - Method in AbstractParallelAnyArray.DUPap
leafTransform(int, int, LongOp) - Method in AbstractParallelAnyArray.LFPap
leafTransform(int, int, LongOp) - Method in AbstractParallelAnyArray.LRPap
leafTransform(int, int, LongOp) - Method in AbstractParallelAnyArray.LUPap
leafTransform(int, int, Op) - Method in AbstractParallelAnyArray.OFPap
leafTransform(int, int, Op) - Method in AbstractParallelAnyArray.ORPap
leafTransform(int, int, Op) - Method in AbstractParallelAnyArray.OUPap
least - Field in CommonOps.DoubleIntervalRandomGenerator
least - Field in CommonOps.IntIntervalRandomGenerator
least - Field in CommonOps.LongIntervalRandomGenerator
leave() - Method in SerialContext
Leave this context
left - Field in PAS.FJScan
left - Field in PAS.FJSelectAll
left - Field in PAS.FJSubSorter
leftShift(Object) - Method in AgentCore
Adds the message to the agent\s message queue
leftShift(Object) - Method in DataflowQueue
Adds a DataflowVariable representing the passed in value to the buffer.
leftShift(DataflowReadChannel) - Method in DataflowStreamWriteAdapter
leftShift(DataflowReadChannel) - Method in DataflowVariable
Assigns a value from one DataflowVariable instance to this variable.
leftShift(DataflowReadChannel) - Method in DataflowWriteChannel
Assigns a value from one DataflowVariable instance to this variable.
leftShift(ExecutorService, Closure) - Method in GParsExecutorsPoolUtil
Submits the task for asynchronous processing returning the Future received from the executor service.
leftShift(ForkJoinPool, Closure) - Method in GParsPoolUtil
Submits the task for asynchronous processing returning the Future received from the executor service.
leftShift(def) - Method in KanbanTray
Alias for KanbanTray#bind#bind in order to write tray << product *
leftShift(Object) - Method in MessageStream
Same as send
leftShift(Object) - Method in StreamCore
Adds a value to the stream
leftShift(Object) - Method in ThreadLocalPools
Adds a new element
length() - Method in DataflowExpression
length() - Method in DataflowQueue
Returns the current size of the buffer
length() - Method in DataflowReadChannel
Reports the current number of elements in the channel
length() - Method in DataflowStreamReadAdapter
Returns the current size of the buffer
lget(int) - Method in AbstractParallelAnyArray
lget(int) - Method in AbstractParallelAnyArray.DDCPap
lget(int) - Method in AbstractParallelAnyArray.DDMPap
lget(int) - Method in AbstractParallelAnyArray.DLCPap
lget(int) - Method in AbstractParallelAnyArray.DLMPap
lget(int) - Method in AbstractParallelAnyArray.DOCPap
lget(int) - Method in AbstractParallelAnyArray.DOMPap
lget(int) - Method in AbstractParallelAnyArray.DPap
lget(int) - Method in AbstractParallelAnyArray.LDCPap
lget(int) - Method in AbstractParallelAnyArray.LDMPap
lget(int) - Method in AbstractParallelAnyArray.LLCPap
lget(int) - Method in AbstractParallelAnyArray.LLMPap
lget(int) - Method in AbstractParallelAnyArray.LOCPap
lget(int) - Method in AbstractParallelAnyArray.LOMPap
lget(int) - Method in AbstractParallelAnyArray.ODCPap
lget(int) - Method in AbstractParallelAnyArray.ODMPap
lget(int) - Method in AbstractParallelAnyArray.OLCPap
lget(int) - Method in AbstractParallelAnyArray.OLMPap
lget(int) - Method in AbstractParallelAnyArray.OOCPap
lget(int) - Method in AbstractParallelAnyArray.OOMPap
lget(int) - Method in AbstractParallelAnyArray.OPap
lget(int) - Method in ParallelLongArrayWithFilter
lgetArray() - Method in AbstractParallelAnyArray
lgetArray() - Method in AbstractParallelAnyArray.LPap
lgetIn() - Method in PAS.FJLScan
lgetIn() - Method in PAS.FJScan
lgetOut() - Method in PAS.FJLScan
lgetOut() - Method in PAS.FJScan
link(ProcessingNode) - Method in KanbanFlow
First part of the sequence link producer to consumer.
link - Property in KanbanTray
linkage - Field in CustomConcurrentHashMap.LinkedIntKeyIntValueNode
linkage - Field in CustomConcurrentHashMap.LinkedIntKeySelfValueNode
linkage - Field in CustomConcurrentHashMap.LinkedIntKeySoftValueNode
linkage - Field in CustomConcurrentHashMap.LinkedIntKeyStrongValueNode
linkage - Field in CustomConcurrentHashMap.LinkedIntKeyWeakValueNode
linkage - Field in CustomConcurrentHashMap.LinkedSoftKeyIntValueNode
linkage - Field in CustomConcurrentHashMap.LinkedSoftKeySelfValueNode
linkage - Field in CustomConcurrentHashMap.LinkedSoftKeySoftValueNode
linkage - Field in CustomConcurrentHashMap.LinkedSoftKeyStrongValueNode
linkage - Field in CustomConcurrentHashMap.LinkedSoftKeyWeakValueNode
linkage - Field in CustomConcurrentHashMap.LinkedStrongKeyIntValueNode
linkage - Field in CustomConcurrentHashMap.LinkedStrongKeySelfValueNode
linkage - Field in CustomConcurrentHashMap.LinkedStrongKeySoftValueNode
linkage - Field in CustomConcurrentHashMap.LinkedStrongKeyStrongValueNode
linkage - Field in CustomConcurrentHashMap.LinkedStrongKeyWeakValueNode
linkage - Field in CustomConcurrentHashMap.LinkedWeakKeyIntValueNode
linkage - Field in CustomConcurrentHashMap.LinkedWeakKeySelfValueNode
linkage - Field in CustomConcurrentHashMap.LinkedWeakKeySoftValueNode
linkage - Field in CustomConcurrentHashMap.LinkedWeakKeyStrongValueNode
linkage - Field in CustomConcurrentHashMap.LinkedWeakKeyWeakValueNode
links - Field in KanbanFlow
list1GEList2(def, def) - Method in TestUtilities
listContains(def, def) - Method in TestUtilities
listeners - Field in AgentBase
Holds all listeners interested in state updates A listener should be a closure accepting the old and the new value in this order.
listeners - Field in DataflowChannelEventOrchestrator
listeners - Field in DataflowProcessor
listeners - Field in GracefulShutdownMonitor
All listeners that watch the operators/selectors in the network
listeners - Field in LocalNode
listIterator(int) - Method in ParallelArray.AsList
listIterator(int) - Method in ParallelDoubleArray.AsList
listIterator(int) - Method in ParallelLongArray.AsList
listView - Field in ParallelArray
Lazily constructed list view
listView - Field in ParallelDoubleArray
listView - Field in ParallelLongArray
ln - Field in PAS.FJDCMerger
ln - Field in PAS.FJDMerger
ln - Field in PAS.FJLCMerger
ln - Field in PAS.FJLMerger
ln - Field in PAS.FJOCMerger
ln - Field in PAS.FJOMerger
lo - Field in PAS.FJBase
lo - Field in PAS.FJDCMerger
lo - Field in PAS.FJDMerger
lo - Field in PAS.FJLCMerger
lo - Field in PAS.FJLMerger
lo - Field in PAS.FJOCMerger
lo - Field in PAS.FJOMerger
lo - Field in PAS.FJRemoveAll
lo - Field in PAS.FJRemoveAllDriver
lo - Field in PAS.FJScan
lo - Field in PAS.FJSearchBase
lo - Field in PAS.FJSelectAll
LocalHandle - Class in groovyx.gpars.serial
@author Alex Tkachman
LocalHandle(UUID) - Constructor in LocalHandle
localHandles - Field in SerialHandles
Table of local objects serialized out to remote nodes
LocalHost - Class in groovyx.gpars.remote
Represents communication point with other local hosts.
LocalHost() - Constructor in LocalHost
localHost - Field in LocalNode
localHost - Field in RemoteConnection
localHost - Field in SerialContext
LocalHostRegistry - Class in groovyx.gpars.remote
Registry of local hosts
LocalHostRegistry() - Constructor in LocalHostRegistry
localHosts - Field in LocalHostRegistry
LocalNode - Class in groovyx.gpars.remote
Representation of local node
LocalNode(LocalHost, Runnable) - Constructor in LocalNode
localNodes - Field in LocalHost
Local nodes known to the provider
locator - Field in CustomConcurrentHashMap.SoftKeyNode
locator - Field in CustomConcurrentHashMap.StrongKeyNode
locator - Field in CustomConcurrentHashMap.WeakKeyNode
lock - Field in AgentBase
Allows reads not to wait in the message queue.
lock - Field in Dataflows
longAdder() - Method in CommonOps
Returns a reducer that adds two long elements
longEqualityPredicate() - Method in CommonOps
Returns a predicate evaluating to true if the first argument == the second
longInequalityPredicate() - Method in CommonOps
Returns a predicate evaluating to true if the first argument == the second
longMaxReducer(LongComparator) - Method in CommonOps
Returns a reducer returning the maximum of two long elements, using the given comparator
longMinReducer(LongComparator) - Method in CommonOps
Returns a reducer returning the minimum of two long elements, using the given comparator
longRandom(long, long) - Method in CommonOps
Returns a generator producing uniform random values between the given least value (inclusive) and bound (exclusive).
lookupActorFieldName(AnnotationNode) - Method in ActiveObjectASTTransformation
lookupActorGroupName(AnnotationNode) - Method in ActiveObjectASTTransformation
loop(Closure, Closure, Runnable) - Method in DefaultActor
Ensures that the supplied closure will be invoked repeatedly in a loop.
loop(Runnable) - Method in Scheduler
loopClosure - Field in DefaultActor
loopCode - Field in DefaultActor
Misused also for the code to run at start-up
loopCondition - Field in DefaultActor
lquickSort(long[], LongComparator, int, int) - Method in PAS
LRUProtectionStorage - Class in groovyx.gpars.memoize
Protects stored resources from eviction from memory following the LRU (Last Recently Used) strategy.
LRUProtectionStorage(int) - Constructor in LRUProtectionStorage
lsetIn(long) - Method in PAS.FJLScan
lsetIn(long) - Method in PAS.FJScan
lsetOut(long) - Method in PAS.FJLScan
lsetOut(long) - Method in PAS.FJScan

M

MAGIC - Field in BroadcastDiscovery
mainActor - Field in LocalNode
mainActor - Field in NodeConnectedMsg
mainActor - Field in RemoteNode
makeConcurrent(Object) - Method in GParsPoolUtil
Overrides the iterative methods like each(), collect() and such, so that they call their parallel variants from the GParsPoolUtil class like eachParallel(), collectParallel() and such.
makeConcurrent(Object) - Method in GParsPoolUtilHelper
Overrides the iterative methods like each(), collect() and such, so that they call their parallel variants from the GParsPoolUtil class like eachParallel(), collectParallel() and such.
makeConcurrent(Object) - Method in Parallel
Overrides the iterative methods like each(), collect() and such, so that they call their parallel variants from the GParsPoolUtil class like eachParallel(), collectParallel() and such.
makeFair() - Method in AbstractLoopingActor
Makes the actor fair.
makeFair() - Method in AgentCore
Makes the agent fair.
makeFair() - Method in AsyncMessagingCore
Makes the agent fair.
makeSequential(Object) - Method in GParsPoolUtil
Gives the iterative methods like each() or find() the original sequential semantics.
makeSequential(Object) - Method in GParsPoolUtilHelper
Gives the iterative methods like each() or find() the original sequential semantics.
makeSequential(Object) - Method in Parallel
Gives the iterative methods like each() or find() the original sequential semantics.
manager - Field in SerialHandle
map(Closure) - Method in AbstractPAWrapper
Applies concurrently the supplied function to all elements in the collection, returning a collection containing the transformed values.
map(Object) - Method in CustomConcurrentHashMap.MappingFunction
Returns a value for the given key, or null if there is no mapping.
map(Closure) - Method in FList
map(FList, Closure, StreamCore) - Method in StreamCore
MappedPAWrapper - Class in groovyx.gpars.pa
The ParallelArray wrapper used after the map() operation
MappedPAWrapper(ParallelArrayWithMapping) - Constructor in MappedPAWrapper
mask - Field in GuardedSelectRequest
matchesMask(int) - Method in GuardedSelectRequest
Detects, whether the channel at the given index is guarded or not.
matchesMask(int) - Method in SelectRequest
Checks, whether the given index should be queried for value or not.
max(Closure) - Method in AbstractPAWrapper
Finds in parallel the maximum of all values in the collection.
max - Field in CommonOps.NaturalDoubleMaxReducer
max - Field in CommonOps.NaturalLongMaxReducer
max - Field in CommonOps.RawMaxReducer
MAX_FORKS - Field in DataflowProcessor
max() - Method in ParallelArray
Returns the maximum element, or null if empty assuming that all elements are Comparables
max() - Method in ParallelArray.SummaryStatistics
Returns the maximum element, or null if empty
max(DoubleComparator) - Method in ParallelArrayWithDoubleMapping
Returns the maximum element, or -Double.MAX_VALUE if empty
max(LongComparator) - Method in ParallelArrayWithLongMapping
Returns the maximum element, or Long.MIN_VALUE if empty
max() - Method in ParallelArrayWithMapping
Returns the maximum element, or null if empty assuming that all elements are Comparables
max() - Method in ParallelDoubleArray
Returns the maximum element, or -Double.MAX_VALUE if empty
max() - Method in ParallelDoubleArray.SummaryStatistics
Returns the maximum element, or -Double.MAX_VALUE if empty
max(DoubleComparator) - Method in ParallelDoubleArrayWithDoubleMapping
Returns the maximum element, or -Double.MAX_VALUE if empty
max(LongComparator) - Method in ParallelDoubleArrayWithLongMapping
Returns the maximum element, or Long.MIN_VALUE if empty
max() - Method in ParallelDoubleArrayWithMapping
Returns the maximum mapped element, or null if empty assuming that all elements are Comparables
max() - Method in ParallelLongArray
Returns the maximum element, or Long.MIN_VALUE if empty
max() - Method in ParallelLongArray.SummaryStatistics
Returns the maximum element, or Long.MIN_VALUE if empty
max(DoubleComparator) - Method in ParallelLongArrayWithDoubleMapping
Returns the maximum element, or -Double.MAX_VALUE if empty
max(LongComparator) - Method in ParallelLongArrayWithLongMapping
Returns the maximum element, or Long.MIN_VALUE if empty
max() - Method in ParallelLongArrayWithMapping
Returns the maximum mapped element, or null if empty assuming that all elements are Comparables
max - Field in PAS.FJDStats
max - Field in PAS.FJLStats
max - Field in PAS.FJOStats
MAX_SEGMENT_CAPACITY - Field in CustomConcurrentHashMap
max() - Method in TransparentParallel
maxForks - Field in ForkingDataflowOperatorActor
maxForks - Field in ForkingDataflowSelectorActor
maxForks - Property in ProcessingNode
maxParallel(Object) - Method in GParsPoolUtil
Creates a Parallel Array out of the supplied collection/object and invokes its max() method using the default comparator.
maxParallel() - Method in Parallel
Creates a Parallel Array out of the supplied collection/object and invokes its max() method using the default comparator.
maxReducer(Comparator) - Method in CommonOps
Returns a reducer returning the maximum of two elements, using the given comparator, and treating null as less than any non-null element.
maxSize - Field in LRUProtectionStorage
memberHasValue(AnnotationNode, String, Object) - Method in AsyncFunASTTransformation
MEMOIZE_NULL - Property in GParsPoolUtilHelper
merge(CombineHolder, Closure, Closure) - Method in CombineHolder
merge(PGroup, Map, List, Closure) - Method in DataflowExpression
merge(PGroup, Map, List, Closure) - Method in DataflowQueue
merge(PGroup, Map, List, Closure) - Method in DataflowReadChannel
Merges channels together as inputs for a single dataflow operator.
merge(PGroup, Map, List, Closure) - Method in DataflowStreamReadAdapter
merge(Map, List, Closure) - Method in Pipeline
Merges channels together as inputs for a single dataflow operator.
merge(PGroup, List, Closure) - Method in SyncDataflowQueue
merge(PGroup, List, Closure) - Method in SyncDataflowStreamReadAdapter
merge(PGroup, List, Closure) - Method in SyncDataflowVariable
merger - Field in PAS.FJSubSorter
message - Field in DataflowExpression.BindDataflow
message - Field in MessageStream.SendTo
messageArrived(DataflowProcessor, DataflowReadChannel, int, Object) - Method in DataflowEventAdapter
Invoked when a message becomes available in an input channel.
messageArrived(DataflowProcessor, DataflowReadChannel, int, Object) - Method in DataflowEventListener
Invoked when a message becomes available in an input channel.
messageArrived(DataflowProcessor, DataflowReadChannel, int, Object) - Method in GracefulShutdownListener
Entering a non-idle state, so a notification needs to be sent to the monitor.
messageHandler(Closure) - Method in Actors
Creates an instance of DynamicDispatchActor.
messageHandler(Closure) - Method in PGroup
Creates an instance of DynamicDispatchActor.
MessageQueue - Interface in groovyx.gpars.util
The high-performance actor message queue
messageReceived(ChannelHandlerContext, MessageEvent) - Method in NettyHandler
messageSentOut(DataflowProcessor, DataflowWriteChannel, int, Object) - Method in DataflowEventAdapter
Invoked when a message is being bound to an output channel.
messageSentOut(DataflowProcessor, DataflowWriteChannel, int, Object) - Method in DataflowEventListener
Invoked when a message is being bound to an output channel.
messagesInChannels - Field in GracefulShutdownListener
MessageStream - Class in groovyx.gpars.actor.impl
Represents a stream of messages and forms the base class for actors
MessageStream.RemoteMessageStream - Class in groovyx.gpars.actor.impl
MessageStream.RemoteMessageStream(RemoteHost) - Constructor in MessageStream.RemoteMessageStream
MessageStream.ResultWaiter - Class in groovyx.gpars.actor.impl
Represents a pending request for a reply from an actor.
MessageStream.ResultWaiter() - Constructor in MessageStream.ResultWaiter
MessageStream.SendTo - Class in groovyx.gpars.actor.impl
MessageStream.SendTo(MessageStream, ActorMessage) - Constructor in MessageStream.SendTo
MessageStream() - Constructor in MessageStream
MESSAGING_RUNNABLE_NEED_EXACTLY_ONE_ARGUMENT_TO_RUN - Field in MessagingRunnable
MessagingRunnable - Class in groovyx.gpars
Represents a single-argument Closure when using GPars agents, actors or dataflow concurrency through the Java API.
MessagingRunnable(Object) - Constructor in MessagingRunnable
metaClass - Field in DataflowExpression
The current metaclass
METHOD_NAME_PREFIX - Field in InternalActor
methodName - Field in DataflowInvocationExpression
min(Closure) - Method in AbstractPAWrapper
Finds in parallel the minimum of all values in the collection.
min - Field in CommonOps.NaturalDoubleMinReducer
min - Field in CommonOps.NaturalLongMinReducer
min - Field in CommonOps.RawMinReducer
min() - Method in ParallelArray
Returns the minimum element, or null if empty, assuming that all elements are Comparables
min() - Method in ParallelArray.SummaryStatistics
Returns the minimum element, or null if empty
min(DoubleComparator) - Method in ParallelArrayWithDoubleMapping
Returns the minimum element, or Double.MAX_VALUE if empty
min(LongComparator) - Method in ParallelArrayWithLongMapping
Returns the minimum element, or Long.MAX_VALUE if empty
min() - Method in ParallelArrayWithMapping
Returns the minimum element, or null if empty, assuming that all elements are Comparables
min() - Method in ParallelDoubleArray
Returns the minimum element, or Double.MAX_VALUE if empty,
min() - Method in ParallelDoubleArray.SummaryStatistics
Returns the minimum element, or Double.MAX_VALUE if empty
min(DoubleComparator) - Method in ParallelDoubleArrayWithDoubleMapping
Returns the minimum element, or Double.MAX_VALUE if empty
min(LongComparator) - Method in ParallelDoubleArrayWithLongMapping
Returns the minimum element, or Long.MAX_VALUE if empty
min() - Method in ParallelDoubleArrayWithMapping
Returns the minimum mapped element, or null if empty, assuming that all elements are Comparables
min() - Method in ParallelLongArray
Returns the minimum element, or Long.MAX_VALUE if empty,
min() - Method in ParallelLongArray.SummaryStatistics
Returns the minimum element, or Long.MAX_VALUE if empty
min(DoubleComparator) - Method in ParallelLongArrayWithDoubleMapping
Returns the minimum element, or Double.MAX_VALUE if empty
min(LongComparator) - Method in ParallelLongArrayWithLongMapping
Returns the minimum element, or Long.MAX_VALUE if empty
min() - Method in ParallelLongArrayWithMapping
Returns the minimum mapped element, or null if empty, assuming that all elements are Comparables
min - Field in PAS.FJDStats
min - Field in PAS.FJLStats
min - Field in PAS.FJOStats
MIN_SEGMENT_CAPACITY - Field in CustomConcurrentHashMap
min() - Method in TransparentParallel
minParallel(Object) - Method in GParsPoolUtil
Creates a Parallel Array out of the supplied collection/object and invokes its min() method using the default comparator.
minParallel() - Method in Parallel
Creates a Parallel Array out of the supplied collection/object and invokes its min() method using the default comparator.
minReducer(Comparator) - Method in CommonOps
Returns a reducer returning the minimum of two elements, using the given comparator, and treating null as greater than any non-null element.
minus(def) - Method in ChannelInputList
minus(def) - Method in ChannelOutputList
MobileAgent - Interface in groovyx.gpars.csp
monitor - Field in GracefulShutdownListener
moveAsyncHead() - Method in DataflowStreamReadAdapter
moveHead() - Method in DataflowStreamReadAdapter
msg - Field in SequentialProcessingActor.Node
Multiplexer - Class in groovyx.gpars.csp.util
Multiplexer() - Constructor in Multiplexer
MY_TYPE - Field in AsyncFunASTTransformation
myActor - Field in DefaultActorClosure
myThread - Field in GParsPool.MyCancellableRecursiveTask

N

n - Field in PAS.FJDCSorter
n - Field in PAS.FJDSorter
n - Field in PAS.FJLCSorter
n - Field in PAS.FJLSorter
n - Field in PAS.FJOCSorter
n - Field in PAS.FJOSorter
name - Field in CustomConcurrentHashMap.Strength
A java.util.ConcurrentMap supporting user-defined equivalence comparisons, soft, weak, or strong keys and values, and user-supplied computational methods for setting and updating values.
name - Field in DataflowGetPropertyExpression
naturalComparator(Class) - Method in CommonOps
Returns a Comparator for Comparable objects
naturalDoubleComparator() - Method in CommonOps
Returns a comparator for doubles relying on natural ordering
naturalDoubleMaxReducer() - Method in CommonOps
Returns a reducer returning the maximum of two double elements, using natural comparator
naturalDoubleMinReducer() - Method in CommonOps
Returns a reducer returning the minimum of two double elements, using natural comparator
naturalLongComparator() - Method in CommonOps
Returns a comparator for longs relying on natural ordering
naturalLongMaxReducer() - Method in CommonOps
Returns a reducer returning the maximum of two long elements, using natural comparator
naturalLongMinReducer() - Method in CommonOps
A reducer returning the minimum of two long elements, using natural comparator
naturalMaxReducer(Class) - Method in CommonOps
Returns a reducer returning the maximum of two Comparable elements, treating null as less than any non-null element.
naturalMinReducer(Class) - Method in CommonOps
Returns a reducer returning the minimum of two Comparable elements, treating null as greater than any non-null element.
NettyHandler - Class in groovyx.gpars.remote.netty
@author Alex Tkachman
NettyHandler(NettyTransportProvider) - Constructor in NettyHandler
NettyRemoteConnection - Class in groovyx.gpars.remote.netty
Connection using Netty
NettyRemoteConnection.MyChannelFutureListener - Class in groovyx.gpars.remote.netty
NettyRemoteConnection.MyChannelFutureListener() - Constructor in NettyRemoteConnection.MyChannelFutureListener
NettyRemoteConnection(NettyTransportProvider, NettyHandler) - Constructor in NettyRemoteConnection
NettyTransportProvider - Class in groovyx.gpars.remote.netty
Transport provider using Netty
NettyTransportProvider.Client - Class in groovyx.gpars.remote.netty
NettyTransportProvider.Client(NettyTransportProvider, SocketAddress, UUID) - Constructor in NettyTransportProvider.Client
NettyTransportProvider.ClientHandler - Class in groovyx.gpars.remote.netty
NettyTransportProvider.ClientHandler(NettyTransportProvider, UUID) - Constructor in NettyTransportProvider.ClientHandler
NettyTransportProvider.MyThreadFactory - Class in groovyx.gpars.remote.netty
NettyTransportProvider.MyThreadFactory() - Constructor in NettyTransportProvider.MyThreadFactory
NettyTransportProvider.Server - Class in groovyx.gpars.remote.netty
NettyTransportProvider.Server() - Constructor in NettyTransportProvider.Server
NettyTransportProvider.ServerPipelineFactory - Class in groovyx.gpars.remote.netty
NettyTransportProvider.ServerPipelineFactory(NettyTransportProvider) - Constructor in NettyTransportProvider.ServerPipelineFactory
NettyTransportProvider() - Constructor in NettyTransportProvider
newIntKeyIntValueMap(int) - Method in CustomConcurrentHashMap
Returns a new map using Integer keys and values
newIntKeyMap(CustomConcurrentHashMap.Strength, CustomConcurrentHashMap.Equivalence, int) - Method in CustomConcurrentHashMap
Returns a new map using Integer keys and the given value parameters
newIntValueMap(CustomConcurrentHashMap.Strength, CustomConcurrentHashMap.Equivalence, int) - Method in CustomConcurrentHashMap
Returns a new map using the given key parameters and Integer values
newNode(int, Object, Object, CustomConcurrentHashMap, Node) - Method in CustomConcurrentHashMap.IntKeyIntValueNodeFactory
newNode(int, Object, Object, CustomConcurrentHashMap, Node) - Method in CustomConcurrentHashMap.IntKeySelfValueNodeFactory
newNode(int, Object, Object, CustomConcurrentHashMap, Node) - Method in CustomConcurrentHashMap.IntKeySoftValueNodeFactory
newNode(int, Object, Object, CustomConcurrentHashMap, Node) - Method in CustomConcurrentHashMap.IntKeyStrongValueNodeFactory
newNode(int, Object, Object, CustomConcurrentHashMap, Node) - Method in CustomConcurrentHashMap.IntKeyWeakValueNodeFactory
newNode(int, Object, Object, CustomConcurrentHashMap, Node) - Method in CustomConcurrentHashMap.NodeFactory
Creates and returns a Node using the given parameters.
newNode(int, Object, Object, CustomConcurrentHashMap, Node) - Method in CustomConcurrentHashMap.SoftKeyIntValueNodeFactory
newNode(int, Object, Object, CustomConcurrentHashMap, Node) - Method in CustomConcurrentHashMap.SoftKeySelfValueNodeFactory
newNode(int, Object, Object, CustomConcurrentHashMap, Node) - Method in CustomConcurrentHashMap.SoftKeySoftValueNodeFactory
newNode(int, Object, Object, CustomConcurrentHashMap, Node) - Method in CustomConcurrentHashMap.SoftKeyStrongValueNodeFactory
newNode(int, Object, Object, CustomConcurrentHashMap, Node) - Method in CustomConcurrentHashMap.SoftKeyWeakValueNodeFactory
newNode(int, Object, Object, CustomConcurrentHashMap, Node) - Method in CustomConcurrentHashMap.StrongKeyIntValueNodeFactory
newNode(int, Object, Object, CustomConcurrentHashMap, Node) - Method in CustomConcurrentHashMap.StrongKeySelfValueNodeFactory
newNode(int, Object, Object, CustomConcurrentHashMap, Node) - Method in CustomConcurrentHashMap.StrongKeySoftValueNodeFactory
newNode(int, Object, Object, CustomConcurrentHashMap, Node) - Method in CustomConcurrentHashMap.StrongKeyStrongValueNodeFactory
newNode(int, Object, Object, CustomConcurrentHashMap, Node) - Method in CustomConcurrentHashMap.StrongKeyWeakValueNodeFactory
newNode(int, Object, Object, CustomConcurrentHashMap, Node) - Method in CustomConcurrentHashMap.WeakKeyIntValueNodeFactory
newNode(int, Object, Object, CustomConcurrentHashMap, Node) - Method in CustomConcurrentHashMap.WeakKeySelfValueNodeFactory
newNode(int, Object, Object, CustomConcurrentHashMap, Node) - Method in CustomConcurrentHashMap.WeakKeySoftValueNodeFactory
newNode(int, Object, Object, CustomConcurrentHashMap, Node) - Method in CustomConcurrentHashMap.WeakKeyStrongValueNodeFactory
newNode(int, Object, Object, CustomConcurrentHashMap, Node) - Method in CustomConcurrentHashMap.WeakKeyWeakValueNodeFactory
newSubtask(int, int, FJBase) - Method in PAS.FJBase
Factory method to create new subtask, normally of current type
newSubtask(int, int, FJBase) - Method in PAS.FJCountSelected
newSubtask(int, int, FJBase) - Method in PAS.FJDApply
newSubtask(int, int, FJBase) - Method in PAS.FJDBinaryIndexMap
newSubtask(int, int, FJBase) - Method in PAS.FJDCombineInPlace
newSubtask(int, int, FJBase) - Method in PAS.FJDFill
newSubtask(int, int, FJBase) - Method in PAS.FJDGenerate
newSubtask(int, int, FJBase) - Method in PAS.FJDIndexMap
newSubtask(int, int, FJSearchBase) - Method in PAS.FJDIndexOf
newSubtask(int, int, FJBase) - Method in PAS.FJDMap
newSubtask(int, int, FJBase) - Method in PAS.FJDPACombineInPlace
newSubtask(int, int, FJBase) - Method in PAS.FJDReduce
newSubtask(FJScan, int, int) - Method in PAS.FJDScanOp
newSubtask(FJScan, int, int) - Method in PAS.FJDScanPlusOp
newSubtask(int, int, FJBase) - Method in PAS.FJDStats
newSubtask(int, int, FJBase) - Method in PAS.FJDTransform
newSubtask(int, int, FJBase) - Method in PAS.FJDUniquifier
newSubtask(int, int, FJBase) - Method in PAS.FJLApply
newSubtask(int, int, FJBase) - Method in PAS.FJLBinaryIndexMap
newSubtask(int, int, FJBase) - Method in PAS.FJLCombineInPlace
newSubtask(int, int, FJBase) - Method in PAS.FJLFill
newSubtask(int, int, FJBase) - Method in PAS.FJLGenerate
newSubtask(int, int, FJBase) - Method in PAS.FJLIndexMap
newSubtask(int, int, FJSearchBase) - Method in PAS.FJLIndexOf
newSubtask(int, int, FJBase) - Method in PAS.FJLMap
newSubtask(int, int, FJBase) - Method in PAS.FJLPACombineInPlace
newSubtask(int, int, FJBase) - Method in PAS.FJLReduce
newSubtask(FJScan, int, int) - Method in PAS.FJLScanOp
newSubtask(FJScan, int, int) - Method in PAS.FJLScanPlusOp
newSubtask(int, int, FJBase) - Method in PAS.FJLStats
newSubtask(int, int, FJBase) - Method in PAS.FJLTransform
newSubtask(int, int, FJBase) - Method in PAS.FJLUniquifier
newSubtask(int, int, FJBase) - Method in PAS.FJOApply
newSubtask(int, int, FJBase) - Method in PAS.FJOBinaryIndexMap
newSubtask(int, int, FJBase) - Method in PAS.FJOCombineInPlace
newSubtask(int, int, FJBase) - Method in PAS.FJOFill
newSubtask(int, int, FJBase) - Method in PAS.FJOGenerate
newSubtask(int, int, FJBase) - Method in PAS.FJOIndexMap
newSubtask(int, int, FJSearchBase) - Method in PAS.FJOIndexOf
newSubtask(int, int, FJBase) - Method in PAS.FJOMap
newSubtask(int, int, FJBase) - Method in PAS.FJOPACombineInPlace
newSubtask(int, int, FJBase) - Method in PAS.FJOReduce
newSubtask(FJScan, int, int) - Method in PAS.FJOScanOp
newSubtask(int, int, FJBase) - Method in PAS.FJOStats
newSubtask(int, int, FJBase) - Method in PAS.FJOTransform
newSubtask(int, int, FJBase) - Method in PAS.FJOUniquifier
newSubtask(FJScan, int, int) - Method in PAS.FJScanOp
newSubtask(int, int, FJSearchBase) - Method in PAS.FJSearchBase
newSubtask(int, int, FJSearchBase) - Method in PAS.FJSelectAny
newThread(Runnable) - Method in AgentThreadFactory
newThread(Runnable) - Method in NettyTransportProvider.MyThreadFactory
next - Field in AbstractParallelAnyArray.FilteredAsDoubleIterator
next - Field in AbstractParallelAnyArray.FilteredAsLongIterator
next - Field in AbstractParallelAnyArray.FilteredIterator
next() - Method in AbstractParallelAnyArray.UnfilteredAsDoubleIterator
next() - Method in AbstractParallelAnyArray.UnfilteredAsLongIterator
next() - Method in AbstractParallelAnyArray.UnfilteredIterator
next() - Method in CustomConcurrentHashMap.EntryIterator
next() - Method in CustomConcurrentHashMap.KeyIterator
next() - Method in CustomConcurrentHashMap.ValueIterator
next() - Method in FListIterator
next - Field in FQMessageQueue.Node
next() - Method in ParallelArray.ListIter
next() - Method in ParallelArray.ParallelArrayIterator
next() - Method in ParallelDoubleArray.ListIter
next() - Method in ParallelDoubleArray.ParallelDoubleArrayIterator
next() - Method in ParallelLongArray.ListIter
next() - Method in ParallelLongArray.ParallelLongArrayIterator
next - Field in PAS.FJBase
next - Field in PAS.FJDCMerger
next - Field in PAS.FJDMerger
next - Field in PAS.FJLCMerger
next - Field in PAS.FJLMerger
next - Field in PAS.FJOCMerger
next - Field in PAS.FJOMerger
next - Field in PAS.FJRemoveAll
next - Field in PAS.FJSearchBase
next - Field in SequentialProcessingActor.Node
nextContinuation - Field in DefaultActor
nextEntry() - Method in CustomConcurrentHashMap.HashIterator
nextIndex() - Method in ParallelArray.ListIter
nextIndex() - Method in ParallelDoubleArray.ListIter
nextIndex() - Method in ParallelLongArray.ListIter
nextKey - Field in CustomConcurrentHashMap.HashIterator
nextNode - Field in CustomConcurrentHashMap.HashIterator
nextSegmentIndex - Field in CustomConcurrentHashMap.HashIterator
nextTableIndex - Field in CustomConcurrentHashMap.HashIterator
nextValue - Field in CustomConcurrentHashMap.HashIterator
No_ARGS - Field in InternalActor
node(Closure) - Method in ProcessingNode
Convenience factory method
NodeConnectedMsg - Class in groovyx.gpars.remote.message
Message sent when local node connected to remote host
NodeConnectedMsg(LocalNode) - Constructor in NodeConnectedMsg
NodeDisconnectedMsg - Class in groovyx.gpars.remote.message
Message sent when local node disconnected from remote host
NodeDisconnectedMsg(LocalNode) - Constructor in NodeDisconnectedMsg
nodeId - Field in NodeConnectedMsg
Id of node connected
nodeId - Field in NodeDisconnectedMsg
Id of node disconnected
NonDaemonPGroup - Class in groovyx.gpars.group
Provides logical grouping for actors, agents and dataflow tasks and operators.
NonDaemonPGroup(int) - Constructor in NonDaemonPGroup
Creates a group for actors, agents, tasks and operators.
nonGeneric(ClassNode) - Method in ActiveObjectASTTransformation.MyClassCodeExpressionTransformer
nonidentityPredicate() - Method in CommonOps
Returns a predicate evaluating to true if the first argument !
notificationArrivedFlag - Field in GracefulShutdownMonitor
Indicates, whether some activity has been reported since last time
notifyRemote(UUID) - Method in DataflowExpression
Sends notifications to all subscribers
notPredicate(LongPredicate) - Method in CommonOps
Returns a predicate evaluating to the negation of its contained predicate
NSEGMENTS - Field in CustomConcurrentHashMap
NullProtectionStorage - Class in groovyx.gpars.memoize
Doesn't protect any resources.
NullProtectionStorage() - Constructor in NullProtectionStorage
NullValue - Class in groovyx.gpars.memoize
Represents a null or void return value in the cache.
NullValue() - Constructor in NullValue
numberOfChannels - Field in SelectBase
numberOfParameters - Field in DataflowMessagingRunnable

O

offset - Field in PAS.FJDMap
offset - Field in PAS.FJLMap
offset - Field in PAS.FJOMap
offset - Field in PAS.FJRemoveAllDriver
offset - Field in PAS.FJSelectAll
oget(int) - Method in AbstractParallelAnyArray
oget(int) - Method in AbstractParallelAnyArray.DDCPap
oget(int) - Method in AbstractParallelAnyArray.DDMPap
oget(int) - Method in AbstractParallelAnyArray.DLCPap
oget(int) - Method in AbstractParallelAnyArray.DLMPap
oget(int) - Method in AbstractParallelAnyArray.DOCPap
oget(int) - Method in AbstractParallelAnyArray.DOMPap
oget(int) - Method in AbstractParallelAnyArray.DPap
oget(int) - Method in AbstractParallelAnyArray.LDCPap
oget(int) - Method in AbstractParallelAnyArray.LDMPap
oget(int) - Method in AbstractParallelAnyArray.LLCPap
oget(int) - Method in AbstractParallelAnyArray.LLMPap
oget(int) - Method in AbstractParallelAnyArray.LOCPap
oget(int) - Method in AbstractParallelAnyArray.LOMPap
oget(int) - Method in AbstractParallelAnyArray.LPap
oget(int) - Method in AbstractParallelAnyArray.ODCPap
oget(int) - Method in AbstractParallelAnyArray.ODMPap
oget(int) - Method in AbstractParallelAnyArray.OLCPap
oget(int) - Method in AbstractParallelAnyArray.OLMPap
oget(int) - Method in AbstractParallelAnyArray.OOCPap
oget(int) - Method in AbstractParallelAnyArray.OOMPap
oget(int) - Method in ParallelArrayWithFilter
ogetArray() - Method in AbstractParallelAnyArray
Access methods for ref, double, long.
ogetArray() - Method in AbstractParallelAnyArray.OPap
ogetIn() - Method in PAS.FJOScan
ogetIn() - Method in PAS.FJScan
ogetOut() - Method in PAS.FJOScan
ogetOut() - Method in PAS.FJScan
ON_DELIVERY_ERROR - Field in Actor
onConnect(RemoteNode) - Method in LocalNode
onConnect() - Method in RemoteConnection
onConnect(RemoteNode) - Method in RemoteNodeDiscoveryListener
onConnect(RemoteNode) - Method in RemoteNodeDiscoveryListener.RemoteNodeDiscoveryListenerClosure
onDeliveryError(Object) - Method in MessageStream.ResultWaiter
Handle cases when the message sent to the actor doesn't get delivered
onDisconnect(SerialContext) - Method in LocalHost
onDisconnect(RemoteNode) - Method in LocalNode
onDisconnect() - Method in RemoteConnection
onDisconnect(RemoteNode) - Method in RemoteNodeDiscoveryListener
onDisconnect(RemoteNode) - Method in RemoteNodeDiscoveryListener.RemoteNodeDiscoveryListenerClosure
onDisconnectForLocalNodes(RemoteNode) - Method in LocalHost
onDiscovery(UUID, SocketAddress) - Method in BroadcastDiscovery
onException(DataflowProcessor, Throwable) - Method in DataflowEventAdapter
Invoked if an exception occurs.
onException(DataflowProcessor, Throwable) - Method in DataflowEventListener
Invoked if an exception occurs.
onException(Throwable) - Method in DataflowProcessorActor
onException(Throwable) - Method in RemoteConnection
ongoingThreadTermination - Field in SequentialProcessingActor
onMessage(Object) - Method in AgentBase
Other messages than closures are accepted as new values for the internal state
onMessage(Object) - Method in DataflowChannelListener
onMessage(Object) - Method in DataflowOperatorActor
onMessage(Object) - Method in DataflowProcessorActor
All messages unhandled by sub-classes will result in an exception being thrown
onMessage(Object) - Method in DataflowSelectorActor
onMessage(Object) - Method in DefaultActor
Handles all incoming messages
onMessage(Object) - Method in InternalActor
Handles incoming messages
onMessage(SerialMsg) - Method in RemoteConnection
onMessage(Object) - Method in StaticDispatchActor
Handles the incoming messages.
onReclamation() - Method in CustomConcurrentHashMap.EmbeddedSoftReference
onReclamation() - Method in CustomConcurrentHashMap.EmbeddedWeakReference
onReclamation() - Method in CustomConcurrentHashMap.IntKeyIntValueNode
onReclamation() - Method in CustomConcurrentHashMap.IntKeySelfValueNode
onReclamation() - Method in CustomConcurrentHashMap.IntKeySoftValueNode
onReclamation() - Method in CustomConcurrentHashMap.IntKeyStrongValueNode
onReclamation() - Method in CustomConcurrentHashMap.IntKeyWeakValueNode
onReclamation() - Method in CustomConcurrentHashMap.Reclaimable
The action taken upon removal of this object from a ReferenceQueue.
onReclamation() - Method in CustomConcurrentHashMap.SoftKeyNode
onReclamation() - Method in CustomConcurrentHashMap.StrongKeyIntValueNode
onReclamation() - Method in CustomConcurrentHashMap.StrongKeySelfValueNode
onReclamation() - Method in CustomConcurrentHashMap.StrongKeySoftValueNode
onReclamation() - Method in CustomConcurrentHashMap.StrongKeyStrongValueNode
onReclamation() - Method in CustomConcurrentHashMap.StrongKeyWeakValueNode
onReclamation() - Method in CustomConcurrentHashMap.WeakKeyNode
onReduce(FJBase) - Method in PAS.FJBase
Operation performed after joining right subtask -- default noop
onReduce(FJBase) - Method in PAS.FJCountSelected
onReduce(FJBase) - Method in PAS.FJDReduce
onReduce(FJBase) - Method in PAS.FJDStats
onReduce(FJBase) - Method in PAS.FJDUniquifier
onReduce(FJBase) - Method in PAS.FJLReduce
onReduce(FJBase) - Method in PAS.FJLStats
onReduce(FJBase) - Method in PAS.FJLUniquifier
onReduce(FJBase) - Method in PAS.FJOReduce
onReduce(FJBase) - Method in PAS.FJOStats
onReduce(FJBase) - Method in PAS.FJOUniquifier
onStop - Field in Actor
onTimer() - Method in GracefulShutdownMonitor
Checks, whether the network is no longer active.
op(Object) - Method in AbstractParallelAnyArray.AndPredicate
op - Field in AbstractParallelAnyArray.DDCPap
op - Field in AbstractParallelAnyArray.DDMPap
op - Field in AbstractParallelAnyArray.DLCPap
op - Field in AbstractParallelAnyArray.DLMPap
op - Field in AbstractParallelAnyArray.DOCPap
op - Field in AbstractParallelAnyArray.DOMPap
op - Field in AbstractParallelAnyArray.LDCPap
op - Field in AbstractParallelAnyArray.LDMPap
op - Field in AbstractParallelAnyArray.LLCPap
op - Field in AbstractParallelAnyArray.LLMPap
op - Field in AbstractParallelAnyArray.LOCPap
op - Field in AbstractParallelAnyArray.LOMPap
op - Field in AbstractParallelAnyArray.ODCPap
op - Field in AbstractParallelAnyArray.ODMPap
op - Field in AbstractParallelAnyArray.OLCPap
op - Field in AbstractParallelAnyArray.OLMPap
op - Field in AbstractParallelAnyArray.OOCPap
op - Field in AbstractParallelAnyArray.OOMPap
op(Object) - Method in ClosureMapper
op(Object) - Method in ClosureNegationPredicate
op(Object) - Method in ClosurePredicate
op(Object, Object) - Method in ClosureReducer
op(double, double) - Method in CommonOps.DoubleAdder
op() - Method in CommonOps.DoubleBoundedRandomGenerator
op(double, double) - Method in CommonOps.DoubleEqualityPredicate
op(double, double) - Method in CommonOps.DoubleInequalityPredicate
op() - Method in CommonOps.DoubleIntervalRandomGenerator
op() - Method in CommonOps.DoubleRandomGenerator
op(Object, Object) - Method in CommonOps.EqualityPredicate
op(Object, Object) - Method in CommonOps.IdentityPredicate
op(Object, Object) - Method in CommonOps.InequalityPredicate
op(int, int) - Method in CommonOps.IntAdder
op() - Method in CommonOps.IntBoundedRandomGenerator
op(int, int) - Method in CommonOps.IntEqualityPredicate
op(int, int) - Method in CommonOps.IntInequalityPredicate
op() - Method in CommonOps.IntIntervalRandomGenerator
op() - Method in CommonOps.IntRandomGenerator
op(Object) - Method in CommonOps.IsNonNullPredicate
op(Object) - Method in CommonOps.IsNullPredicate
op(long, long) - Method in CommonOps.LongAdder
op() - Method in CommonOps.LongBoundedRandomGenerator
op(long, long) - Method in CommonOps.LongEqualityPredicate
op(long, long) - Method in CommonOps.LongInequalityPredicate
op() - Method in CommonOps.LongIntervalRandomGenerator
op() - Method in CommonOps.LongRandomGenerator
op(double, double) - Method in CommonOps.NaturalDoubleMaxReducer
op(double, double) - Method in CommonOps.NaturalDoubleMinReducer
op(long, long) - Method in CommonOps.NaturalLongMaxReducer
op(long, long) - Method in CommonOps.NaturalLongMinReducer
op(Object, Object) - Method in CommonOps.NonidentityPredicate
op(Object, Object) - Method in CommonOps.RawMaxReducer
op(Object, Object) - Method in CommonOps.RawMinReducer
op() - Method in Ops.Action
op(double, double) - Method in Ops.BinaryDoubleOp
op(double, double) - Method in Ops.BinaryDoublePredicate
op(int, int) - Method in Ops.BinaryIntOp
op(int, int) - Method in Ops.BinaryIntPredicate
op(long, long) - Method in Ops.BinaryLongOp
op(long, long) - Method in Ops.BinaryLongPredicate
op(A, B) - Method in Ops.BinaryOp
op(A, B) - Method in Ops.BinaryPredicate
op(double, double) - Method in Ops.DoubleAndDoubleProcedure
op(double, double) - Method in Ops.DoubleAndDoubleToInt
op(double, double) - Method in Ops.DoubleAndDoubleToLong
op(double, double) - Method in Ops.DoubleAndDoubleToObject
op(double, int) - Method in Ops.DoubleAndIntPredicate
op(double, int) - Method in Ops.DoubleAndIntProcedure
op(double, int) - Method in Ops.DoubleAndIntToDouble
op(double, int) - Method in Ops.DoubleAndIntToInt
op(double, int) - Method in Ops.DoubleAndIntToLong
op(double, int) - Method in Ops.DoubleAndIntToObject
op(double, long) - Method in Ops.DoubleAndLongPredicate
op(double, long) - Method in Ops.DoubleAndLongProcedure
op(double, long) - Method in Ops.DoubleAndLongToDouble
op(double, long) - Method in Ops.DoubleAndLongToInt
op(double, long) - Method in Ops.DoubleAndLongToLong
op(double, long) - Method in Ops.DoubleAndLongToObject
op(double, A) - Method in Ops.DoubleAndObjectPredicate
op(double, A) - Method in Ops.DoubleAndObjectProcedure
op(double, A) - Method in Ops.DoubleAndObjectToDouble
op(double, A) - Method in Ops.DoubleAndObjectToInt
op(double, A) - Method in Ops.DoubleAndObjectToLong
op(double, A) - Method in Ops.DoubleAndObjectToObject
op() - Method in Ops.DoubleGenerator
op(double) - Method in Ops.DoubleOp
op(double) - Method in Ops.DoublePredicate
op(double) - Method in Ops.DoubleProcedure
op(double) - Method in Ops.DoubleToInt
op(double) - Method in Ops.DoubleToLong
op(double) - Method in Ops.DoubleToObject
op() - Method in Ops.Generator
op(int, double) - Method in Ops.IntAndDoublePredicate
op(int, double) - Method in Ops.IntAndDoubleProcedure
op(int, double) - Method in Ops.IntAndDoubleToDouble
op(int, double) - Method in Ops.IntAndDoubleToInt
op(int, double) - Method in Ops.IntAndDoubleToLong
op(int, double) - Method in Ops.IntAndDoubleToObject
op(int, int) - Method in Ops.IntAndIntProcedure
op(int, int) - Method in Ops.IntAndIntToDouble
op(int, int) - Method in Ops.IntAndIntToLong
op(int, int) - Method in Ops.IntAndIntToObject
op(int, long) - Method in Ops.IntAndLongPredicate
op(int, long) - Method in Ops.IntAndLongProcedure
op(int, long) - Method in Ops.IntAndLongToDouble
op(int, long) - Method in Ops.IntAndLongToInt
op(int, long) - Method in Ops.IntAndLongToLong
op(int, long) - Method in Ops.IntAndLongToObject
op(int, A) - Method in Ops.IntAndObjectPredicate
op(int, A) - Method in Ops.IntAndObjectProcedure
op(int, A) - Method in Ops.IntAndObjectToDouble
op(int, A) - Method in Ops.IntAndObjectToInt
op(int, A) - Method in Ops.IntAndObjectToLong
op(int, A) - Method in Ops.IntAndObjectToObject
op() - Method in Ops.IntGenerator
op(int) - Method in Ops.IntOp
op(int) - Method in Ops.IntPredicate
op(int) - Method in Ops.IntProcedure
op(int) - Method in Ops.IntToDouble
op(int) - Method in Ops.IntToLong
op(int) - Method in Ops.IntToObject
op(long, double) - Method in Ops.LongAndDoublePredicate
op(long, double) - Method in Ops.LongAndDoubleProcedure
op(long, double) - Method in Ops.LongAndDoubleToDouble
op(long, double) - Method in Ops.LongAndDoubleToInt
op(long, double) - Method in Ops.LongAndDoubleToLong
op(long, double) - Method in Ops.LongAndDoubleToObject
op(long, int) - Method in Ops.LongAndIntPredicate
op(long, int) - Method in Ops.LongAndIntProcedure
op(long, int) - Method in Ops.LongAndIntToDouble
op(long, int) - Method in Ops.LongAndIntToInt
op(long, int) - Method in Ops.LongAndIntToLong
op(long, int) - Method in Ops.LongAndIntToObject
op(long, long) - Method in Ops.LongAndLongProcedure
op(long, long) - Method in Ops.LongAndLongToDouble
op(long, long) - Method in Ops.LongAndLongToInt
op(long, long) - Method in