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_DATAFLOW_VARIABLE_CAN_ONLY_BE_ASSIGNED_ONCE_ONLY_RE_ASSIGNMENTS_TO_AN_EQUAL_VALUE_ARE_ALLOWED - Field in DataflowExpression
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
Handles all incoming messages
act() - Method in RunnableBackedBlockingActor
act() - Method in SequentialProcessingActor
action - Field in RunnableBackedBlockingActor
active - Field in AsyncMessagingCore
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
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
actor - Field in ActorTimerTask
actor - Field in DataflowProcessor
ACTOR_HAS_ALREADY_BEEN_STARTED - Field in Actor
actor(Runnable) - Method in PGroup
Creates a new instance of BlockingActor, using the passed-in 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
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
Returns true if this set contains no elements.
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
addAllBindErrorListeners(Collection) - Method in BindErrorListenerManager
addAllBindErrorListeners(Collection) - Method in DataflowChannelEventOrchestrator
addAllDataflowChannelListeners(Collection) - Method in DataflowChannelEventListenerManager
addAllDataflowChannelListeners(Collection) - Method in DataflowChannelEventOrchestrator
addBindErrorListener(BindErrorListener) - Method in BindErrorListenerManager
addBindErrorListener(BindErrorListener) - Method in DataflowChannelEventOrchestrator
addConnection(RemoteConnection) - Method in RemoteHost
addDataflowChannelListener(DataflowChannelListener) - Method in DataflowChannelEventListenerManager
addDataflowChannelListener(DataflowChannelListener) - Method in DataflowChannelEventOrchestrator
addDataflowEventListener(DataflowEventListener) - Method in DataflowProcessor
Registers the provided handler to all input channels
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 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.
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
Only two-argument closures are allowed
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 fireCustomEvent() method is triggered manually on a dataflow operator/selector.
afterRun(DataflowProcessor, List) - Method in DataflowEventListener
afterRun(DataflowProcessor, List) - Method in GracefulShutdownListener
If shutdown is in progress, we'll notify the monitor
afterStart(DataflowProcessor) - Method in DataflowEventAdapter
afterStart(DataflowProcessor) - Method in DataflowEventListener
afterStart() - Method in DataflowOperatorActor
afterStart() - Method in DataflowProcessorActor
Registers the provided handler to all input channels
afterStart() - Method in DataflowSelectorActor
afterStop(DataflowProcessor) - Method in DataflowEventAdapter
afterStop(DataflowProcessor) - Method in DataflowEventListener
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
agent(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.
AgentBase - Class in groovyx.gpars.agent
Implements most of Agent's public method in Java
AgentBase.AwaitClosure - Class in groovyx.gpars.agent
AgentBase.AwaitClosure() - Constructor in AgentBase.AwaitClosure
AgentBase(Object, Closure) - Constructor in AgentBase
Accepts a NullObject instance and sets the internal state to null
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
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
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
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
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
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
Adds a dataflow variable value to the stream, once the value is available
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
Indicates whether the iterative methods like each() or collect() work have been altered to work concurrently.
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 and composable variant of the supplied closure, which, when invoked returns a DataflowVariable 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
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(TxnExecutor, Closure) - Method in GParsStm
Performs the supplied code atomically within a transaction.
atomicWithBoolean(TxnExecutor, Closure) - Method in GParsStm
atomicWithDouble(TxnExecutor, Closure) - Method in GParsStm
atomicWithInt(TxnExecutor, Closure) - Method in GParsStm
atomicWithLong(TxnExecutor, Closure) - Method in GParsStm
atomicWithVoid(TxnExecutor, Closure) - Method in GParsStm
ATTACHMENT - Field in DataflowExpression
attachment - Field in DataflowExpression.WaitingThread
attachToThreadPool(Pool) - Method in AgentCore
Informs about a new thread being assigned to process the next message
attachToThreadPool(Pool) - 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.
attemptToCountDownAndAwait(long) - Method in ResizeableCountDownLatch
average() - Method in ParallelDoubleArray.SummaryStatistics
average() - Method in ParallelLongArray.SummaryStatistics
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
Attempts to atomically count down the latch and await release with a timeout.
awaitClosure - Field in AgentBase
awaitingParties() - Method in SyncDataflowVariable
awaitNextMessage(long) - Method in SequentialProcessingActor
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
beforeRun(DataflowProcessor, List) - Method in DataflowEventAdapter
Invoked when the operator completes a single run.
beforeRun(DataflowProcessor, List) - Method in DataflowEventListener
beforeRun(DataflowProcessor, List) - Method in GracefulShutdownListener
Enters an 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
binaryChoice(PGroup, Map, DataflowWriteChannel, DataflowWriteChannel, Closure) - Method in DataflowStreamReadAdapter
binaryChoice(Map, DataflowWriteChannel, DataflowWriteChannel, Closure) - Method in Pipeline
Directs the output to one of the output channels depending on the int 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
bind(Object) - Method in DataflowQueue
Hooks the registered when bound handlers to the supplied dataflow expression
bind(Object) - Method in DataflowStreamWriteAdapter
bind(Object) - Method in DataflowWriteChannel
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
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, while guaranteeing atomicity of the operation and preventing other calls to bindAllOutputsAtomically() from interfering with one another.
bindAllOutputValuesAtomically(Object) - Method in DataflowProcessor
bindDFV(DataflowReadChannel) - Method in DataflowVariable
bindError(Throwable) - Method in DataflowExpression
BindErrorAdapter - Class in groovyx.gpars.dataflow
An empty implementation of BindErrorListener
BindErrorAdapter() - Constructor in BindErrorAdapter
BindErrorDistributor - Interface in groovyx.gpars.dataflow.impl
Fires requested events
BindErrorListener - Interface in groovyx.gpars.dataflow
Gets notified about errors when binding values to DataflowVariables
BindErrorListener - Field in DataflowChannelEventOrchestrator
BindErrorListenerManager - Interface in groovyx.gpars.dataflow.impl
@author Vaclav Pech
bindOutput(Object) - Method in DataflowProcessor
bindSafely(Object) - Method in DataflowExpression
Assigns a value to the variable.
bindUnique(Object) - Method in DataflowExpression
Performs the actual bind operation, unblocks all blocked threads and informs all asynchronously waiting actors.
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 PooledActor, 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 DefaultActor, using the passed-in runnable/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, SelectableChannel) - 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
buildClosureForMaps(Closure) - Method in PAUtils
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
Dynamically dispatches the method call
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(Txn) - Method in GParsAtomicBooleanBlock
call(Txn) - Method in GParsAtomicDoubleBlock
call(Txn) - Method in GParsAtomicIntBlock
call(Txn) - Method in GParsAtomicLongBlock
call(Txn) - Method in GParsAtomicVoidBlock
call(Txn) - Method in GParsTxnExecutor
call(def) - Method in KanbanTray
Alias for KanbanTray#bind#bind in order to write tray product *
call(Object) - Method in MessageStream
call(Object) - Method in MessagingRunnable
call(Object) - Method in ReactorMessagingRunnable
call(MessageStream, List) - Method in Select
Invokes the internal select base with a SelectRequest instance ensuring a message is sent, once a value has been selected
call(Object) - Method in SelectCallback
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
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
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 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
Submits the task for asynchronous processing returning the Future received from the executor service.
cancel() - Method in ActorTimerTask
cancel(boolean) - Method in GParsPool.MyCancellableRecursiveTask
cancelCurrentTimeoutTask() - Method in AbstractLoopingActor
cancelled - Field in ActorTimerTask
CANNOT_CREATE_AN_ATOMIC_BLOCK_SOME_OF_THE_SPECIFIED_PARAMETERS_ARE_NOT_SUPPORTED - Field in GParsStm
CANNOT_FIRE_BIND_ERRORS_THE_THREAD_HAS_BEEN_INTERRUPTED - Field in DataflowExpression
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
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
Returns the current value of the Agent's state
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
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
choice(PGroup, Map, List, Closure) - Method in DataflowExpression
choice(PGroup, Map, List, Closure) - Method in DataflowQueue
choice(PGroup, Map, List, Closure) - Method in DataflowReadChannel
choice(PGroup, Map, List, Closure) - Method in DataflowStreamReadAdapter
choice(Map, List, Closure) - Method in Pipeline
Allows the closure to output different values to different output channels.
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
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
close() - Method in SyncDataflowStreamReadAdapter
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 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 GParsTxnExecutor
code - Field in SeparationClosure
collect(Closure) - Method in TransparentParallel
collectingMessages - Field in GracefulShutdownListener
collectMany(Closure) - Method in TransparentParallel
collectManyParallel(Map, Closure) - Method in GParsPoolUtil
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
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
Utility class to sort half a partitioned array
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
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(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
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.
contains(Object) - Method in CustomConcurrentHashMap.KeySetView
contains(Object) - Method in CustomConcurrentHashMap.Values
contains(Object) - Method in Dataflows
Convenience method to play nicely with Groovy object iteration methods.
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
content - Field in CombineHolder
context - Field in SerialHandle
Construct handle for object with given id to it
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 message is being bound to an output channel.
controlMessageArrived(DataflowProcessor, DataflowReadChannel, int, Object) - Method in DataflowEventListener
controlMessageArrived(DataflowProcessor, DataflowReadChannel, int, Object) - Method in GracefulShutdownListener
Entering a different non-idle state, so a notification needs to be sent to the monitor.
convertToBoolean(def) - Method in GParsPoolUtilHelper
copy - Field in AgentBase
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
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
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
countInputChannels(Map) - Method in DataflowOperator
countInputChannels(Map) - Method in DataflowSelector
countParallel(Object, Closure) - Method in GParsPoolUtil
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
createCollection(Object) - Method in PAGroovyUtils
createCollection(Iterator) - Method in PAUtils
createComparator(Closure) - Method in PAUtils
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.
createEventManager() - Method in DataflowExpression
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
createGroupByClosure(Closure, ConcurrentMap) - Method in PAUtils
Creates a closure that will insert elements in the appropriate group
createNewStream() - Method in DataflowStream
createNewStream() - Method in StreamCore
createNewStream() - Method in SyncDataflowStream
createObject(SerialContext) - Method in Actor.MyRemoteHandle
createObject(SerialContext) - Method in DefaultRemoteHandle
createObject(SerialContext) - Method in RemoteHandle
createPA(Map, ForkJoinPool) - 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.
createPA(Object, ForkJoinPool) - Method in GParsPoolUtilHelper
createPAFromArray(Object, ForkJoinPool) - Method in GParsPoolUtilHelper
createPAFromCollection(def, ForkJoinPool) - Method in GParsPoolUtilHelper
createPool(boolean, int) - Method in DefaultPool
createPool(int) - Method in FJPool
createPool(int, ThreadFactory) - Method in GParsExecutorsPool
createPool(int, UncaughtExceptionHandler) - Method in GParsPool
createPool(boolean, int) - Method in PoolFactory
createReadChannel() - Method in DataflowBroadcast
createReadChannel() - Method in SyncDataflowBroadcast
Un-registers the supplied read channel from the broadcast.
createRemoteHandle(SerialHandle, SerialContext) - Method in Actor
createRemoteHandle(SerialHandle, SerialContext) - Method in WithSerialId
createResizeablePool(boolean, int) - Method in ResizeablePool
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
createThreadName() - Method in DefaultPool
Created a JVM-unique name for Actors' threads.
createTimeout(long) - Method in Select
createTimer(String, boolean) - Method in TimerFactory
createTxnExecutor(Map) - Method in GParsStm
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
Retrieves the value at the head of the buffer.
createVariable() - Method in SyncDataflowQueue
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
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
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
currentThread - Field in AgentCore
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
Creates a set with the given parameters.
CustomConcurrentHashMap.KeySet(Strength, Equivalence, int) - Constructor in CustomConcurrentHashMap.KeySet
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
customEvent(DataflowProcessor, Object) - Method in DataflowEventListener
cycleAllowed - Property in KanbanFlow
If adapted, this must be set before calling link()

D

data - Field in AgentBase
DATA_FLOW_GROUP - Field in Dataflow
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
Sends a message back to the DataCallback.
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
Sends a message back to the DataCallback.
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
DataflowChannel - Interface in groovyx.gpars.dataflow
A common interface for all dataflow variables, streams or queues
DataflowChannelEventDistributor - 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
DataflowExpression.BindDataflow(DataflowExpression, Object, UUID) - Constructor in DataflowExpression.BindDataflow
DataflowExpression.DataflowExpressionsCollector - Class in groovyx.gpars.dataflow.expression
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
DataflowExpression.WaitingThread(Thread, WaitingThread, Object, MessageStream) - Constructor in DataflowExpression.WaitingThread
A request chain terminator
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
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
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
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
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
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
DataflowStreamWriteAdapter - Class in groovyx.gpars.dataflow.stream
Adapts a DataflowStream to accommodate for the DataflowWriteChannel interface.
DataflowStreamWriteAdapter(StreamCore) - Constructor in DataflowStreamWriteAdapter
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
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
Constructs a CountDownLatch initialized with the given count.
decrementCount() - Method in CustomConcurrentHashMap.Segment
decrementParties() - Method in StreamCore
decrementParties() - Method in SyncDataflowStream
decrementParties() - Method in SyncDataflowVariable
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
If no parameter is provided at construction time, the act() method becomes the actor's body
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
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
DefaultPool - Class in groovyx.gpars.scheduler
Represents the actors' thread pool, which performs tasks on behalf of the actors.
DefaultPool(ThreadPoolExecutor) - Constructor in DefaultPool
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
defaultTxnExecutor - Field in GParsStm
delay - Property in GFixedDelay
delay - Property in GParPrint
delay - Property in GPrint
delay - Field in GracefulShutdownMonitor
deregisterCurrentActorWithThread() - Method in Actor
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
Stores the input channel and registers for the wheneverBound() event on each
disableDFV(int, SelectableChannel) - 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
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
doPut(Object, Object, boolean) - Method in CustomConcurrentHashMap
doRun(Object) - Method in DataflowMessagingRunnable
doRun(Object) - Method in MessagingRunnable
doRun(Object) - Method in ReactorMessagingRunnable
doRun(Object) - Method in ThenMessagingRunnable
doSelect() - Method in DataflowPrioritySelector
doSelect() - Method in DataflowSelector
Indicates, whether the selector has some guards enabled and so can select a value from the input channels
doSelect(int, SelectRequest) - Method in SelectBase
Invoked whenever the Select is asked for the next value.
doStart() - Method in AbstractLoopingActor
doThenForkAndJoin(PGroup, Pool, Closure) - Method in DataflowExpression
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 {@code !
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
Check if value has been set already for this expression
DynamicDispatchActor - Class in groovyx.gpars.actor
A pooled actor allowing for an alternative structure of the message handling code.
DynamicDispatchActor() - Constructor in DynamicDispatchActor

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
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
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
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
Retrieves a message from the message queue, waiting, if necessary, for a message to arrive.
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
Utility method extracted just to help JIT
enter() - Method in SerialContext
Leave this 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
Adds the message to the agent\s message queue
eval(Object) - Method in StreamCore
evalLoopCondition() - Method in DefaultActor
Schedules an ActorAction to take the next message off the message queue and to pass it on to the supplied closure.
evaluate() - Method in DataflowComplexExpression
evaluate() - Method in DataflowExpression
Returns either standard property of the expression or creates an expression, which will request given property when the receiver becomes available
evaluate() - Method in DataflowExpression.TransformMany
evaluate() - Method in DataflowExpression.TransformOne
evaluate() - Method in DataflowGetPropertyExpression
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
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
execute(Runnable) - Method in DefaultPool
Retrieves the internal executor service.
execute(Runnable) - Method in FJPool
Retrieves the internal executor service.
execute(RemoteConnection) - Method in MessageStream.SendTo
execute(RemoteConnection) - Method in NodeConnectedMsg
execute(RemoteConnection) - Method in NodeDisconnectedMsg
execute(Runnable) - Method in PGroup
execute(Runnable) - Method in 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
factory - Field in NettyTransportProvider.Client
factory - Field in NettyTransportProvider.Server
fair - Field in AsyncMessagingCore
fairActor(Runnable) - Method in Actors
Creates a reactor around the supplied code.
fairActor(Runnable) - Method in PGroup
fairAgent(Object, Closure) - Method in Agent
fairAgent(Object, Closure) - Method in PGroup
Creates a new task assigned to a thread from the current parallel group.
fairMessageHandler(Closure) - Method in Actors
fairMessageHandler(Closure) - Method in PGroup
Creates an instance of StaticDispatchActor.
FairMultiplex - Class in groovyx.gpars.csp.util
FairMultiplex() - Constructor in FairMultiplex
fairReactor(Closure) - Method in Actors
Creates an instance of DynamicDispatchActor.
fairReactor(Closure) - Method in PGroup
Creates an instance of DynamicDispatchActor.
fairStaticMessageHandler(Closure) - Method in Actors
fairStaticMessageHandler(Closure) - Method in PGroup
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
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
Makes the output of the pipeline to be an input for the specified channel
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
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
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
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
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
fireBindError(Throwable, Throwable) - Method in BindErrorDistributor
fireBindError(Throwable, Throwable) - Method in DataflowChannelEventOrchestrator
fireBindError(Throwable) - Method in DataflowExpression
fireControlMessageArrived(DataflowReadChannel, int, Object) - Method in DataflowProcessor
fireCustomEvent(Object) - Method in DataflowProcessor
fireEvent() - Method in GracefulShutdownListener
A quick check on, whether the operator/selector is in the Idle state
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 DataflowChannelEventDistributor
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 a fork/join pool of given size.
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
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
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
get() - Method in CustomConcurrentHashMap.IntKeyNode
get() - Method in CustomConcurrentHashMap.Node
get() - Method in CustomConcurrentHashMap.StrongKeyNode
get(long, TimeUnit) - Method in DataflowVariable
get(int) - Method in ParallelArray
get(int) - Method in ParallelArray.AsList
get(int) - Method in ParallelDoubleArray
get(int) - Method in ParallelDoubleArray.AsList
get(int) - Method in ParallelLongArray
get(int) - Method in ParallelLongArray.AsList
get(long, TimeUnit) - Method in Promise
get(UUID) - Method in SerialContext
get(UUID) - Method in SerialHandles
getAddress() - Method in NettyTransportProvider.Server
getArray() - Method in ParallelArray
getArray() - Method in ParallelDoubleArray
getArray() - Method in ParallelLongArray
getAt(def) - Method in ChannelInputList
getAt(def) - Method in ChannelOutputList
getAt(int) - Method in Dataflows
Binds the value to the DataflowVariable that is associated with the property "index".
getBindErrorListeners() - Method in BindErrorListenerManager
getBindErrorListeners() - Method in DataflowChannelEventOrchestrator
getBindErrorManager() - Method in DataflowExpression
getChannel() - Method in NettyHandler
getChildrenResults() - Method in AbstractForkJoinWorker
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
getCount() - Method in ResizeableCountDownLatch.Sync
getCurrent() - Method in ThreadLocalPools
Indicates whether the stack is empty
getError() - Method in DataflowVariable
getError() - Method in LazyDataflowVariable
Schedule closure to be executed after data became available.
getError() - Method in Promise
getErrors() - Method in AgentCore
Indicates whether there have been exception thrown within the agent's body.
getEventManager() - Method in DataflowExpression
getEventManager() - Method in DataflowQueue
getEventManager() - Method in DataflowReadChannel
Reports the current number of elements in the channel
getEventManager() - Method in DataflowStreamReadAdapter
getExecutor() - Method in ParallelArray
Returns the executor used for computations.
getExecutor() - Method in ParallelDoubleArray
getExecutor() - Method in ParallelLongArray
getExecutorService() - Method in DefaultPool
getFirst() - Method in FList
getFirst() - Method in StreamCore
Retrieves a DataflowStream representing the rest of this Stream after removing the first element
getFirstDFV() - Method in StreamCore
getForkJoinPool() - Method in FJPool
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
getImmediateInstance() - Method in PoisonPill
getIndex() - Method in SelectResult
getInstance() - Method in ActiveObjectRegistry
getInstance() - Method in PoisonPill
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
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
getOutput() - Method in DataflowProcessor
getOutput() - Method in Pipeline
getOutputs() - Method in DataflowProcessor
getOwningProcessor() - Method in DataflowMessagingRunnable
Returns types expected by the Runnable.
getParallel(Object) - Method in GParsPoolUtil
Creates 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
getParallelGroup() - Method in Actor
getParameterTypes() - Method in BinaryChoiceClosure
getParameterTypes() - Method in ChainWithClosure
getParameterTypes() - Method in ChoiceClosure
getParameterTypes() - Method in CopyChannelsClosure
getParameterTypes() - Method in DataflowMessagingRunnable
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
schedules a new task for processing with the pool
getPoolSize() - Method in FJPool
schedules a new task for processing with the pool
getPoolSize() - Method in PGroup
Gently stops the pool
getPoolSize() - Method in Pool
Gently stops the pool
getPoolSize() - Method in Scheduler
getProperty(String) - Method in DataflowExpression
Listener for availability of data flow expressions we depend on.
getProperty(String) - Method in Dataflows
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
getRemoteClass() - Method in DataflowVariable
getRemoteClass() - Method in MessageStream
getRemoteClass() - Method in WithSerialId
Replace object by handle for serialization
getRemoteHost() - Method in RemoteNode
getRest() - Method in DataflowStream
A factory method to create new instances of the correct class when needed
getRest() - Method in FList
getRest() - Method in StreamCore
Indicates, whether the first element in the stream is an eos
getRest() - Method in SyncDataflowStream
A factory method to create new instances of the correct class when needed
getResult(long, TimeUnit) - Method in MessageStream.ResultWaiter
getScheduler() - Method in LocalNode
getSegmentForAdd(int) - Method in CustomConcurrentHashMap
getSegmentForTraversal(int) - Method in CustomConcurrentHashMap
Returns the segment for possibly inserting into the table associated with given hash, constructing it if necessary.
getSender() - Method in AbstractLoopingActor
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
Getter for subscribers
getSourceUnit() - Method in ActiveObjectASTTransformation.MyClassCodeExpressionTransformer
getStateObject() - Method in DataflowProcessor
getSubscribers() - Method in SerialHandle
getTableForAdd(CustomConcurrentHashMap) - Method in CustomConcurrentHashMap.Segment
getTableForTraversal() - Method in CustomConcurrentHashMap.Segment
getTermination() - Method in CountingPoisonPill
getTermination() - Method in ImmediateCountingPoisonPill
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
getVal() - Method in AgentBase
A shorthand method for safe asynchronous 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
getVal(long, TimeUnit) - Method in DataflowReadChannel
getVal(long, TimeUnit) - Method in DataflowStreamReadAdapter
getVal(long, TimeUnit) - Method in LazyDataflowVariable
getVal(long, TimeUnit) - Method in SyncDataflowStreamReadAdapter
getVal(long, TimeUnit) - Method in SyncDataflowVariable
getValAsync(Object, MessageStream) - Method in DataflowExpression
getValAsync(Object, MessageStream) - Method in DataflowQueue
Schedule closure to be executed by pooled actor after data became available.
getValAsync(Object, MessageStream) - Method in DataflowReadChannel
Reads the current value of the channel.
getValAsync(Object, MessageStream) - Method in DataflowStreamReadAdapter
getValAsync(Object, MessageStream) - Method in LazyDataflowVariable
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
gmemoizeAtLeast(Closure, int) - Method in GParsPoolUtil
gmemoizeAtMost(Closure, int) - Method in GParsPoolUtil
gmemoizeBetween(Closure, int, int) - Method in GParsPoolUtil
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
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(Closure) - 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
GParsTxnExecutor - Class in groovyx.gpars.stm
A default implementation of org.multiverse.api.closures.AtomicClosure properly handling exception propagation
GParsTxnExecutor(Closure) - Constructor in GParsTxnExecutor
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
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
Invoked whenever a processor changes state
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 collection/object 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 LazyDataflowVariable
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
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
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
Creates an agent instance initialized with the given state.
handleMessage(Object) - Method in AgentCore
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
handleTermination() - Method in Actor
Set on stop handler for this 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
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
hashCode() - Method in CustomConcurrentHashMap.WriteThroughEntry
hashCode() - Method in NullValue
hashCode() - Method in SelectResult
hashCode() - Method in StreamCore
A factory method to create new instances of the correct class when needed
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
Takes the first unsatisfied value request and binds a value on it.
hookWheneverBoundListeners(DataflowExpression) - Method in StreamCore
Increases the number of parties required to perform the data exchange
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

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
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
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
incrementParties() - Method in SyncDataflowStream
Decreases the number of parties required to perform the data exchange
incrementParties() - Method in SyncDataflowVariable
Decreases 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
indexOfMax() - Method in ParallelDoubleArray.SummaryStatistics
Returns the arithmetic average of all elements
indexOfMax() - Method in ParallelLongArray.SummaryStatistics
Returns the sum of all elements
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 maximum element, or -1 if empty
indexOfMin() - Method in ParallelDoubleArray.SummaryStatistics
Returns the sum of all elements
indexOfMin() - Method in ParallelLongArray.SummaryStatistics
Returns the index of the maximum 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 {@code !
init(ASTNode) - Method in AsyncFunASTTransformation
initializationStarted - Field in LazyDataflowVariable
initialize(Closure) - Method in AbstractLoopingActor
initialize() - Method in LazyDataflowVariable
initializer - Field in LazyDataflowVariable
initialOffset - Field in PAS.FJSelectAllDriver
initialSegmentCapacity - Field in CustomConcurrentHashMap
initialValue() - Method in ThreadLocalPools
initiateShutdown() - Method in GracefulShutdownListener
inject(def, Closure) - Method in TransparentParallel
injectParallel(Object, Object, Closure) - Method in GParsPoolUtil
Creates a PAWrapper around a ParallelArray wrapping the elements of the original collection.
injectParallel(Object, def, Closure) - Method in GParsPoolUtilHelper
injectParallel(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.
inorderMove(FJRemoveAll, int) - Method in PAS.FJRemoveAllDriver
Inorder traversal to move indexed elements across reachable nodes.
inputQueue - Field in SequentialProcessingActor
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 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.
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
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 {@code !
into(PGroup, Map, DataflowWriteChannel) - Method in DataflowExpression
into(PGroup, Map, DataflowWriteChannel) - Method in DataflowQueue
into(PGroup, Map, DataflowWriteChannel) - Method in DataflowReadChannel
Splits the output of the current channel to be an input for the specified channels
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
invokeMethod(String, Object) - Method in Dataflows
invokeMethod(String, Object) - Method in ForwardingDelegate
invokeMethod(String, Object) - Method in RunnableBackedBlockingActor.RunnableBackedPooledActorDelegate
isActive() - Method in AbstractLoopingActor
Removes the head of the message queue
isActive() - Method in Actor
isActive() - Method in Actor.RemoteActor
isActive() - Method in SequentialProcessingActor
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
isBound() - Method in DataflowQueue
Checks whether there's a DFV waiting in the queue and retrieves it.
isBound() - Method in DataflowReadChannel
isBound() - Method in DataflowStreamReadAdapter
isBound() - Method in Promise
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
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 the sum of the hash codes of each element, as computed by this set's Equivalence.
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
isEmpty() - Method in ThreadLocalPools
isEmptyWithRespectToSync() - Method in SyncDataflowStream
Increases the number of parties required to perform the data exchange
isError() - Method in DataflowVariable
isError() - Method in LazyDataflowVariable
Returns the error bound to the promise
isError() - Method in Promise
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
Makes the agent fair.
isFair() - Method in AsyncMessagingCore
Makes the agent fair.
isIdle() - Method in GracefulShutdownListener
isIdleAndNoIncomingMessages() - Method in GracefulShutdownListener
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
Removes an element equivalent to the given element with respect to this set's Equivalence, if one is present.
iterator() - Method in CustomConcurrentHashMap.KeySetView
iterator() - Method in CustomConcurrentHashMap.Values
iterator() - Method in DataflowQueue
iterator() - Method in Dataflows
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
iterator() - Method in SyncDataflowStreamReadAdapter

J

JCSPCopy - Interface in groovyx.gpars.csp
join(BaseDuration) - Method in Actor
Join-point for this actor
join(long, TimeUnit) - Method in CountingPoisonPill
Retrieves the promise for termination
join(long, TimeUnit) - Method in DataflowExpression
join() - Method in DataflowProcessor
join(long, TimeUnit) - Method in ImmediateCountingPoisonPill
Retrieves the promise for termination
join(long, TimeUnit) - Method in PoisonTrackCounter
join(long, TimeUnit) - Method in Promise
Schedule closure to be executed after data became available.
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
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
LazyDataflowVariable - Class in groovyx.gpars.dataflow
Represents a thread-safe single-assignment, multi-read variable with delayed initialization.
LazyDataflowVariable(PGroup, Closure) - Constructor in LazyDataflowVariable
lazyTask(Callable) - Method in Dataflow
Creates an operator using the default dataflow parallel group
lazyTask(Callable) - Method in PGroup
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
Shared support for select/map all -- probe filter, map, and type to start selection driver, or do parallel mapping, or just copy.
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
left - Field in PAS.FJScan
left - Field in PAS.FJSelectAll
left - Field in PAS.FJSubSorter
leftShift(Object) - Method in AgentCore
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
leftShift(DataflowReadChannel) - Method in DataflowWriteChannel
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
Creates an asynchronous variant of the supplied closure, which, when invoked returns a future for the potential return value
leftShift(def) - Method in KanbanTray
Alias for KanbanTray#bind#bind in order to write tray << product *
leftShift(Object) - Method in MessageStream
leftShift(Object) - Method in StreamCore
leftShift(Object) - Method in ThreadLocalPools
Removes the top (last) element
length() - Method in DataflowExpression
length() - Method in DataflowQueue
length() - Method in DataflowReadChannel
length() - Method in DataflowStreamReadAdapter
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
listeners - Field in DataflowChannelEventOrchestrator
listeners - Field in DataflowProcessor
listeners - Field in GracefulShutdownMonitor
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
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
locator - Field in CustomConcurrentHashMap.SoftKeyNode
locator - Field in CustomConcurrentHashMap.StrongKeyNode
locator - Field in CustomConcurrentHashMap.WeakKeyNode
lock - Field in AgentBase
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
loop(Runnable) - Method in Scheduler
loopClosure - Field in DefaultActor
loopCode - Field in DefaultActor
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
Gives the iterative methods like each() or find() the original sequential semantics.
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
makeFair() - Method in AgentCore
Adds the message to the agent\s message queue
makeFair() - Method in AsyncMessagingCore
Indicates, whether there's an active thread handling a message inside the agent's body
makeSequential(Object) - Method in GParsPoolUtil
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
matchesMask(int) - Method in SelectRequest
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 index of the minimum element, or -1 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 index of the maximum element, or -1 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 index of the minimum element, or -1 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 summarizes its elements using the foldParallel() method with the + operator and the reduction operation.
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
merge(PGroup, Map, List, Closure) - Method in DataflowStreamReadAdapter
merge(Map, List, Closure) - Method in Pipeline
Directs the output to one of the two output channels depending on the boolean result of the provided closure.
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 control message (instances of ControlMessage) becomes available in an input channel.
messageArrived(DataflowProcessor, DataflowReadChannel, int, Object) - Method in DataflowEventListener
messageArrived(DataflowProcessor, DataflowReadChannel, int, Object) - Method in GracefulShutdownListener
messageHandler(Closure) - Method in Actors
messageHandler(Closure) - Method in PGroup
Creates an instance of DynamicDispatchActor, which will cooperate in thread sharing with other actors sharing the same thread pool
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 all messages required to trigger the operator become available in the input channels.
messageSentOut(DataflowProcessor, DataflowWriteChannel, int, Object) - Method in DataflowEventListener
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
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
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 maximum 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 index of the minimum element, or -1 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 maximum element, or Long.MIN_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
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
newIntKeyMap(CustomConcurrentHashMap.Strength, CustomConcurrentHashMap.Equivalence, int) - Method in CustomConcurrentHashMap
newIntValueMap(CustomConcurrentHashMap.Strength, CustomConcurrentHashMap.Equivalence, int) - Method in CustomConcurrentHashMap
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
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
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
nodeId - Field in NodeDisconnectedMsg
NonDaemonPGroup - Class in groovyx.gpars.group
Provides logical grouping for actors, agents and dataflow tasks and operators.
NonDaemonPGroup(int) - Constructor in NonDaemonPGroup
nonGeneric(ClassNode) - Method in ActiveObjectASTTransformation.MyClassCodeExpressionTransformer
nonidentityPredicate() - Method in CommonOps
Returns a predicate evaluating to true if the first argument {@code !
notificationArrivedFlag - Field in GracefulShutdownMonitor
Uses the default timer delay
notifyRemote(UUID) - Method in DataflowExpression
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
onBindError(Throwable, Throwable) - Method in BindErrorAdapter
onBindError(Throwable, Throwable) - Method in BindErrorListener
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
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 when a message becomes available in an input channel.
onException(DataflowProcessor, Throwable) - Method in DataflowEventListener
onException(Throwable) - Method in DataflowProcessorActor
onException(Throwable) - Method in RemoteConnection
ongoingThreadTermination - Field in SequentialProcessingActor
onMessage(Object) - Method in AgentBase
Allows closures to set the new internal state as a whole Do not call this method directly from the outside.
onMessage(Object) - Method in DataflowChannelListener
onMessage(Object) - Method in DataflowOperatorActor
onMessage(Object) - Method in DataflowProcessorActor
Handles the poisson message.
onMessage(Object) - Method in DataflowSelectorActor
onMessage(Object) - Method in DefaultActor
onMessage(Object) - Method in InternalActor
onMessage(SerialMsg) - Method in RemoteConnection
onMessage(Object) - Method in StaticDispatchActor
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
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
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
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 Ops.LongAndLongToObject
op(long, A) - Method in Ops.LongAndObjectPredicate
op(long, A) - Method in Ops.LongAndObjectProcedure
op(long, A) - Method in Ops.LongAndObjectToDouble
op(long, A) - Method in Ops.LongAndObjectToInt
op(long, A) - Method in Ops.LongAndObjectToLong
op(long, A) - Method in Ops.LongAndObjectToObject
op() - Method in Ops.LongGenerator
op(long) - Method in Ops.LongOp
op(long) - Method in Ops.LongPredicate
op(long) - Method in Ops.LongProcedure
op(long) - Method in Ops.LongToDouble
op(long) - Method in Ops.LongToInt
op(long) - Method in Ops.LongToObject
op(A, double) - Method in Ops.ObjectAndDoublePredicate
op(A, double) - Method in Ops.ObjectAndDoubleProcedure
op(A, double) - Method in Ops.ObjectAndDoubleToDouble
op(A, double) - Method in Ops.ObjectAndDoubleToInt
op(A, double) - Method in Ops.ObjectAndDoubleToLong
op(A, double) - Method in Ops.ObjectAndDoubleToObject
op(A, int) - Method in Ops.ObjectAndIntPredicate
op(A, int) - Method in Ops.ObjectAndIntProcedure
op(A, int) - Method in