Index (gpars 1.2.1)

A B C D E F G H I J K L M N O P Q R S T U V W

A

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

B

base - Variable in class groovyx.gpars.extra166y.PAS.FJDScanOp
base - Variable in class groovyx.gpars.extra166y.PAS.FJLScanOp
base - Variable in class groovyx.gpars.extra166y.PAS.FJOScanOp
become(Closure) - Method in class groovyx.gpars.actor.DynamicDispatchActor: Executes the supplied closure in the context of the actor to set all when() handlers
beforeRun(DataflowProcessor, List<Object>) - Method in class groovyx.gpars.dataflow.operator.component.GracefulShutdownListener: Entering a different non-idle state, so a notification needs to be sent to the monitor.
beforeRun(DataflowProcessor, List<Object>) - Method in class groovyx.gpars.dataflow.operator.component.ProcessorPauseResume
beforeRun(DataflowProcessor, List<Object>) - Method in class groovyx.gpars.dataflow.operator.DataflowEventAdapter: Invoked when all messages required to trigger the operator become available in the input channels.
beforeRun(DataflowProcessor, List<Object>) - Method in interface groovyx.gpars.dataflow.operator.DataflowEventListener: Invoked when all messages required to trigger the operator become available in the input channels.
binaryChoice(DataflowWriteChannel<T>, DataflowWriteChannel<T>, Closure<Boolean>) - Method in class groovyx.gpars.dataflow.DataflowQueue
binaryChoice(Pool, DataflowWriteChannel<T>, DataflowWriteChannel<T>, Closure<Boolean>) - Method in class groovyx.gpars.dataflow.DataflowQueue
binaryChoice(PGroup, DataflowWriteChannel<T>, DataflowWriteChannel<T>, Closure<Boolean>) - Method in class groovyx.gpars.dataflow.DataflowQueue
binaryChoice(Map<String, Object>, DataflowWriteChannel<T>, DataflowWriteChannel<T>, Closure<Boolean>) - Method in class groovyx.gpars.dataflow.DataflowQueue
binaryChoice(Pool, Map<String, Object>, DataflowWriteChannel<T>, DataflowWriteChannel<T>, Closure<Boolean>) - Method in class groovyx.gpars.dataflow.DataflowQueue
binaryChoice(PGroup, Map<String, Object>, DataflowWriteChannel<T>, DataflowWriteChannel<T>, Closure<Boolean>) - Method in class groovyx.gpars.dataflow.DataflowQueue
binaryChoice(DataflowWriteChannel<T>, DataflowWriteChannel<T>, Closure<Boolean>) - Method in interface groovyx.gpars.dataflow.DataflowReadChannel: Directs the output to one of the two output channels depending on the boolean result of the provided closure.
binaryChoice(Pool, DataflowWriteChannel<T>, DataflowWriteChannel<T>, Closure<Boolean>) - Method in interface groovyx.gpars.dataflow.DataflowReadChannel: Directs the output to one of the two output channels depending on the boolean result of the provided closure.
binaryChoice(PGroup, DataflowWriteChannel<T>, DataflowWriteChannel<T>, Closure<Boolean>) - Method in interface groovyx.gpars.dataflow.DataflowReadChannel: Directs the output to one of the two output channels depending on the boolean result of the provided closure.
binaryChoice(Map<String, Object>, DataflowWriteChannel<T>, DataflowWriteChannel<T>, Closure<Boolean>) - Method in interface groovyx.gpars.dataflow.DataflowReadChannel: Directs the output to one of the two output channels depending on the boolean result of the provided closure.
binaryChoice(Pool, Map<String, Object>, DataflowWriteChannel<T>, DataflowWriteChannel<T>, Closure<Boolean>) - Method in interface groovyx.gpars.dataflow.DataflowReadChannel: Directs the output to one of the two output channels depending on the boolean result of the provided closure.
binaryChoice(PGroup, Map<String, Object>, DataflowWriteChannel<T>, DataflowWriteChannel<T>, Closure<Boolean>) - Method in interface groovyx.gpars.dataflow.DataflowReadChannel: Directs the output to one of the two output channels depending on the boolean result of the provided closure.
binaryChoice(DataflowWriteChannel<T>, DataflowWriteChannel<T>, Closure<Boolean>) - Method in class groovyx.gpars.dataflow.expression.DataflowExpression
binaryChoice(Pool, DataflowWriteChannel<T>, DataflowWriteChannel<T>, Closure<Boolean>) - Method in class groovyx.gpars.dataflow.expression.DataflowExpression
binaryChoice(PGroup, DataflowWriteChannel<T>, DataflowWriteChannel<T>, Closure<Boolean>) - Method in class groovyx.gpars.dataflow.expression.DataflowExpression
binaryChoice(Map<String, Object>, DataflowWriteChannel<T>, DataflowWriteChannel<T>, Closure<Boolean>) - Method in class groovyx.gpars.dataflow.expression.DataflowExpression
binaryChoice(Pool, Map<String, Object>, DataflowWriteChannel<T>, DataflowWriteChannel<T>, Closure<Boolean>) - Method in class groovyx.gpars.dataflow.expression.DataflowExpression
binaryChoice(PGroup, Map<String, Object>, DataflowWriteChannel<T>, DataflowWriteChannel<T>, Closure<Boolean>) - Method in class groovyx.gpars.dataflow.expression.DataflowExpression
binaryChoice(DataflowWriteChannel<T>, DataflowWriteChannel<T>, Closure<Boolean>) - Method in class groovyx.gpars.dataflow.operator.Pipeline: Directs the output to one of the two output channels depending on the boolean result of the provided closure.
binaryChoice(Map<String, Object>, DataflowWriteChannel<T>, DataflowWriteChannel<T>, Closure<Boolean>) - Method in class groovyx.gpars.dataflow.operator.Pipeline: Directs the output to one of the two output channels depending on the boolean result of the provided closure.
binaryChoice(DataflowWriteChannel<T>, DataflowWriteChannel<T>, Closure<Boolean>) - Method in class groovyx.gpars.dataflow.stream.DataflowStreamReadAdapter
binaryChoice(Pool, DataflowWriteChannel<T>, DataflowWriteChannel<T>, Closure<Boolean>) - Method in class groovyx.gpars.dataflow.stream.DataflowStreamReadAdapter
binaryChoice(PGroup, DataflowWriteChannel<T>, DataflowWriteChannel<T>, Closure<Boolean>) - Method in class groovyx.gpars.dataflow.stream.DataflowStreamReadAdapter
binaryChoice(Map<String, Object>, DataflowWriteChannel<T>, DataflowWriteChannel<T>, Closure<Boolean>) - Method in class groovyx.gpars.dataflow.stream.DataflowStreamReadAdapter
binaryChoice(Pool, Map<String, Object>, DataflowWriteChannel<T>, DataflowWriteChannel<T>, Closure<Boolean>) - Method in class groovyx.gpars.dataflow.stream.DataflowStreamReadAdapter
binaryChoice(PGroup, Map<String, Object>, DataflowWriteChannel<T>, DataflowWriteChannel<T>, Closure<Boolean>) - Method in class groovyx.gpars.dataflow.stream.DataflowStreamReadAdapter
BinaryChoiceClosure - Class in groovyx.gpars.dataflow.operator: Used by the chainWith() method to wrap the supplied closure inside the operator's body.
BinaryChoiceClosure(Closure<Boolean>) - Constructor for class groovyx.gpars.dataflow.operator.BinaryChoiceClosure
binarySearch(double) - Method in class groovyx.gpars.extra166y.AbstractParallelAnyArray.DUPap
binarySearch(double, Ops.DoubleComparator) - Method in class groovyx.gpars.extra166y.AbstractParallelAnyArray.DUPap
binarySearch(long) - Method in class groovyx.gpars.extra166y.AbstractParallelAnyArray.LUPap
binarySearch(long, Ops.LongComparator) - Method in class groovyx.gpars.extra166y.AbstractParallelAnyArray.LUPap
binarySearch(T) - Method in class groovyx.gpars.extra166y.AbstractParallelAnyArray.OUPap
binarySearch(T, Comparator<? super T>) - Method in class groovyx.gpars.extra166y.AbstractParallelAnyArray.OUPap
binarySearch(T) - Method in class groovyx.gpars.extra166y.ParallelArray: Assuming this array is sorted, returns the index of an element equal to given target, or -1 if not present.
binarySearch(T, Comparator<? super T>) - Method in class groovyx.gpars.extra166y.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(T) - Method in class groovyx.gpars.extra166y.ParallelArrayWithBounds: Assuming this array is sorted, returns the index of an element equal to given target, or -1 if not present.
binarySearch(T, Comparator<? super T>) - Method in class groovyx.gpars.extra166y.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) - Method in class groovyx.gpars.extra166y.ParallelDoubleArray: Assuming this array is sorted, returns the index of an element equal to given target, or -1 if not present.
binarySearch(double, Ops.DoubleComparator) - Method in class groovyx.gpars.extra166y.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) - Method in class groovyx.gpars.extra166y.ParallelDoubleArrayWithBounds: Assuming this array is sorted, returns the index of an element equal to given target, or -1 if not present.
binarySearch(double, Ops.DoubleComparator) - Method in class groovyx.gpars.extra166y.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) - Method in class groovyx.gpars.extra166y.ParallelLongArray: Assuming this array is sorted, returns the index of an element equal to given target, or -1 if not present.
binarySearch(long, Ops.LongComparator) - Method in class groovyx.gpars.extra166y.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) - Method in class groovyx.gpars.extra166y.ParallelLongArrayWithBounds: Assuming this array is sorted, returns the index of an element equal to given target, or -1 if not present.
binarySearch(long, Ops.LongComparator) - Method in class groovyx.gpars.extra166y.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(T) - Method in class groovyx.gpars.dataflow.DataflowQueue: Adds a DataflowVariable representing the passed in value to the buffer.
bind(T) - Method in interface groovyx.gpars.dataflow.DataflowWriteChannel: Assigns a value to the variable.
bind(T) - Method in class groovyx.gpars.dataflow.expression.DataflowExpression: Assigns a value to the variable.
bind(T) - Method in class groovyx.gpars.dataflow.stream.DataflowStreamWriteAdapter
bind(T) - Method in class groovyx.gpars.dataflow.stream.StreamCore
bindAllOutputs(Object) - Method in class groovyx.gpars.dataflow.operator.DataflowProcessor: Used by the processor's body to send a value to all output channels.
bindAllOutputsAtomically(Object) - Method in class groovyx.gpars.dataflow.operator.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 class groovyx.gpars.dataflow.operator.DataflowProcessor: Used by the processor's body to send a value to all output channels.
bindAllOutputValuesAtomically(Object...) - Method in class groovyx.gpars.dataflow.operator.DataflowProcessor: Used by the processor's body to send a value to all output channels, while guaranteeing atomicity of the operation and preventing other calls to bindAllOutputsAtomically() from interfering with one another.
bindDFV(DataflowReadChannel<T>) - Method in class groovyx.gpars.dataflow.DataflowVariable
bindError(Throwable) - Method in class groovyx.gpars.dataflow.expression.DataflowExpression
BindErrorAdapter<T> - Class in groovyx.gpars.dataflow: An empty implementation of BindErrorListener
BindErrorAdapter() - Constructor for class groovyx.gpars.dataflow.BindErrorAdapter
BindErrorDistributor<T> - Interface in groovyx.gpars.dataflow.impl: Fires requested events
BindErrorListener<T> - Interface in groovyx.gpars.dataflow: Gets notified about errors when binding values to DataflowVariables
BindErrorListener - Variable in class groovyx.gpars.dataflow.impl.DataflowChannelEventOrchestrator
BindErrorListenerManager<T> - Interface in groovyx.gpars.dataflow.impl
bindOutput(int, Object) - Method in class groovyx.gpars.dataflow.operator.DataflowProcessor: Used by the processor's body to send a value to the given output channel
bindOutput(Object) - Method in class groovyx.gpars.dataflow.operator.DataflowProcessor: Used by the processor's body to send a value to the first / only output channel
bindSafely(T) - Method in class groovyx.gpars.dataflow.expression.DataflowExpression: Assigns a value to the variable.
bindUnique(T) - Method in class groovyx.gpars.dataflow.expression.DataflowExpression: Assigns a value to the variable.
blockingActor(Runnable) - Static method in class groovyx.gpars.actor.Actors: Creates a new instance of BlockingActor, using the passed-in closure as the body of the actor's act() method.
BlockingActor - Class in groovyx.gpars.actor
BlockingActor() - Constructor for class groovyx.gpars.actor.BlockingActor
blockingActor(Runnable) - Method in class groovyx.gpars.group.PGroup: Creates a new instance of BlockingActor, using the passed-in closure as the body of the actor's act() method.
blockingMandated(String) - Static method in class groovyx.gpars.activeobject.ActiveObjectASTTransformation.MyClassCodeExpressionTransformer
bootstrap - Variable in class groovyx.gpars.remote.netty.NettyTransportProvider.Server
bound - Variable in class groovyx.gpars.extra166y.CommonOps.DoubleBoundedRandomGenerator
bound - Variable in class groovyx.gpars.extra166y.CommonOps.IntBoundedRandomGenerator
bound - Variable in class groovyx.gpars.extra166y.CommonOps.LongBoundedRandomGenerator
boundNotification(int, SelectableChannel<? extends T>) - Method in class groovyx.gpars.dataflow.impl.SelectBase: Invoked by the SelectCallback instances, potentially concurrently to inform about new values being available for read from channels.
boundsCheck(int, int) - Method in class groovyx.gpars.extra166y.AbstractParallelAnyArray
BroadcastDiscovery - Class in groovyx.gpars.remote
BroadcastDiscovery(UUID, InetSocketAddress) - Constructor for class groovyx.gpars.remote.BroadcastDiscovery
broadcastDiscovery - Variable in class groovyx.gpars.remote.netty.NettyTransportProvider
build(T) - Static method in class groovyx.gpars.actor.ActorMessage: Factory method to create instances of ActorMessage with given payload.
buildClosureForMaps(Closure<T>) - Static method in class groovyx.gpars.util.PAUtils: If the passed-in closure expects two arguments, it is considered to be a map-iterative code and is then wrapped with a single-argument closure, which unwraps the key:value pairs for the original closure.
buildClosureForMapsWithIndex(Closure<T>) - Static method in class groovyx.gpars.util.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.
buildMessage() - Method in exception groovyx.gpars.AsyncException
buildResultMap(Collection<Map.Entry<K, V>>) - Static method in class groovyx.gpars.util.PAUtils: Builds a resulting map out of an map entry collection
bundle - Static variable in class groovyx.gpars.serial.SerialHandle
byIdentity - Variable in class groovyx.gpars.extra166y.PAS.UniquifierTable

C

call(Object) - Method in class groovyx.gpars.actor.DefaultActorClosure
call(T) - Method in class groovyx.gpars.actor.impl.MessageStream: Same as send
call(Object) - Method in class groovyx.gpars.agent.AgentBase.AwaitClosure
call(Object) - Method in class groovyx.gpars.agent.AgentCore: Adds the message to the agent\s message queue
call(Object[]) - Method in class groovyx.gpars.dataflow.impl.SelectCallback: Invoked by the channel when a value has been bound to it and is available for consumption
call(Object) - Method in class groovyx.gpars.dataflow.operator.BinaryChoiceClosure
call(Object...) - Method in class groovyx.gpars.dataflow.operator.BinaryChoiceClosure
call() - Method in class groovyx.gpars.dataflow.operator.BinaryChoiceClosure
call(Object) - Method in class groovyx.gpars.dataflow.operator.ChainWithClosure
call(Object...) - Method in class groovyx.gpars.dataflow.operator.ChainWithClosure
call() - Method in class groovyx.gpars.dataflow.operator.ChainWithClosure
call(Object) - Method in class groovyx.gpars.dataflow.operator.ChoiceClosure
call(Object...) - Method in class groovyx.gpars.dataflow.operator.ChoiceClosure
call() - Method in class groovyx.gpars.dataflow.operator.ChoiceClosure
call(Object) - Method in class groovyx.gpars.dataflow.operator.CopyChannelsClosure
call(Object...) - Method in class groovyx.gpars.dataflow.operator.CopyChannelsClosure
call() - Method in class groovyx.gpars.dataflow.operator.CopyChannelsClosure
call() - Method in class groovyx.gpars.dataflow.operator.DataflowProcessorAtomicBoundAllClosure
call(Object[]) - Method in class groovyx.gpars.dataflow.operator.DataflowProcessorAtomicBoundAllClosure
call(Object) - Method in class groovyx.gpars.dataflow.operator.DataflowProcessorAtomicBoundAllClosure
call(Object) - Method in class groovyx.gpars.dataflow.operator.FilterClosure
call(Object...) - Method in class groovyx.gpars.dataflow.operator.FilterClosure
call() - Method in class groovyx.gpars.dataflow.operator.FilterClosure
call(Object) - Method in class groovyx.gpars.dataflow.operator.SeparationClosure
call(Object...) - Method in class groovyx.gpars.dataflow.operator.SeparationClosure
call() - Method in class groovyx.gpars.dataflow.operator.SeparationClosure
call() - Method in class groovyx.gpars.dataflow.Select: Selects a value from a single randomly chosen input channel, which has a value available for read.
call(List<Boolean>) - Method in class groovyx.gpars.dataflow.Select: Selects a value from a single randomly chosen input channel, which has a value available for read.
call(MessageStream) - Method in class groovyx.gpars.dataflow.Select: Selects a value from a single randomly chosen input channel, which has a value available for read.
call(MessageStream, List<Boolean>) - Method in class groovyx.gpars.dataflow.Select: Selects a value from a single randomly chosen input channel, which has a value available for read.
call() - Method in class groovyx.gpars.DataflowMessagingRunnable
call(Object...) - Method in class groovyx.gpars.DataflowMessagingRunnable
call() - Method in class groovyx.gpars.MessagingRunnable
call(Object[]) - Method in class groovyx.gpars.MessagingRunnable
call(Object) - Method in class groovyx.gpars.MessagingRunnable
call(Object[]) - Method in class groovyx.gpars.pa.CallClosure
call() - Method in class groovyx.gpars.pa.CallClosure
call(Object) - Method in class groovyx.gpars.pa.CallClosure
call(Object[]) - Method in class groovyx.gpars.pa.SumClosure
call() - Method in class groovyx.gpars.ReactorMessagingRunnable
call(Object[]) - Method in class groovyx.gpars.ReactorMessagingRunnable
call(Object) - Method in class groovyx.gpars.ReactorMessagingRunnable
call(Txn) - Method in class groovyx.gpars.stm.GParsAtomicBooleanBlock
call(Txn) - Method in class groovyx.gpars.stm.GParsAtomicDoubleBlock
call(Txn) - Method in class groovyx.gpars.stm.GParsAtomicIntBlock
call(Txn) - Method in class groovyx.gpars.stm.GParsAtomicLongBlock
call(Txn) - Method in class groovyx.gpars.stm.GParsAtomicVoidBlock
call(Txn) - Method in class groovyx.gpars.stm.GParsTxnExecutor
callAsync(Closure<T>, Object...) - Static method in class groovyx.gpars.GParsPoolUtil: Calls a closure in a separate thread supplying the given arguments, returning a future for the potential return value.
CallAsyncTask<V> - Class in groovyx.gpars.pa: A helper class to wrap closures for callAsync on GParsPool
CallAsyncTask(Closure<V>) - Constructor for class groovyx.gpars.pa.CallAsyncTask
callback - Variable in class groovyx.gpars.dataflow.expression.DataflowExpression.WaitingThread
CallClosure<V> - Class in groovyx.gpars.pa: A call-forwarding closure
CallClosure(Closure<V>) - Constructor for class groovyx.gpars.pa.CallClosure
callDynamic(String, Object[]) - Method in class groovyx.gpars.actor.Actor
callParallel(Closure<T>) - Static method in class groovyx.gpars.GParsPoolUtil: schedules the supplied closure for processing in the underlying thread pool.
callTimeoutAsync(Closure<T>, long, Object...) - Static method in class groovyx.gpars.GParsPoolUtil: Calls a closure in a separate thread supplying the given arguments, returning a future for the potential return value.
callTimeoutAsync(Closure<T>, Duration, Object...) - Static method in class groovyx.gpars.GParsPoolUtil: Calls a closure in a separate thread supplying the given arguments, returning a future for the potential return value.
cancel() - Method in class groovyx.gpars.actor.ActorTimerTask
cancelCurrentTimeoutTask() - Method in class groovyx.gpars.actor.AbstractLoopingActor
cancelled - Variable in class groovyx.gpars.actor.ActorTimerTask
CANNOT_CREATE_AN_ATOMIC_BLOCK_SOME_OF_THE_SPECIFIED_PARAMETERS_ARE_NOT_SUPPORTED - Static variable in class groovyx.gpars.stm.GParsStm
CANNOT_FIRE_BIND_ERRORS_THE_THREAD_HAS_BEEN_INTERRUPTED - Static variable in class groovyx.gpars.dataflow.expression.DataflowExpression
CANNOT_OBTAIN_THE_SEMAPHORE_TO_FORK_OPERATOR_S_BODY - Static variable in class groovyx.gpars.dataflow.operator.DataflowProcessorActor
CANNOT_SEND_REPLIES_NO_SENDER_HAS_BEEN_REGISTERED - Static variable in class groovyx.gpars.actor.Actor
castedComparator() - Static method in class groovyx.gpars.extra166y.CommonOps: Returns a Comparator that casts its arguments as Comparable on each comparison, throwing ClassCastException on failure.
castedMaxReducer() - Static method in class groovyx.gpars.extra166y.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() - Static method in class groovyx.gpars.extra166y.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 - Variable in class groovyx.gpars.extra166y.CustomConcurrentHashMap.IntKeySoftValueNode
cchm - Variable in class groovyx.gpars.extra166y.CustomConcurrentHashMap.IntKeyWeakValueNode
cchm - Variable in class groovyx.gpars.extra166y.CustomConcurrentHashMap.KeySet
cchm - Variable in class groovyx.gpars.extra166y.CustomConcurrentHashMap.SoftKeyNode
cchm - Variable in class groovyx.gpars.extra166y.CustomConcurrentHashMap.StrongKeySoftValueNode
cchm - Variable in class groovyx.gpars.extra166y.CustomConcurrentHashMap.StrongKeyWeakValueNode
cchm - Variable in class groovyx.gpars.extra166y.CustomConcurrentHashMap.WeakKeyNode
chainWith(Closure<V>) - Method in class groovyx.gpars.dataflow.DataflowQueue
chainWith(Pool, Closure<V>) - Method in class groovyx.gpars.dataflow.DataflowQueue
chainWith(PGroup, Closure<V>) - Method in class groovyx.gpars.dataflow.DataflowQueue
chainWith(Map<String, Object>, Closure<V>) - Method in class groovyx.gpars.dataflow.DataflowQueue
chainWith(Pool, Map<String, Object>, Closure<V>) - Method in class groovyx.gpars.dataflow.DataflowQueue
chainWith(PGroup, Map<String, Object>, Closure<V>) - Method in class groovyx.gpars.dataflow.DataflowQueue
chainWith(Closure<V>) - Method in interface groovyx.gpars.dataflow.DataflowReadChannel: Creates and attaches a new operator processing values from the channel
chainWith(Pool, Closure<V>) - Method in interface groovyx.gpars.dataflow.DataflowReadChannel: Creates and attaches a new operator processing values from the channel
chainWith(PGroup, Closure<V>) - Method in interface groovyx.gpars.dataflow.DataflowReadChannel: Creates and attaches a new operator processing values from the channel
chainWith(Map<String, Object>, Closure<V>) - Method in interface groovyx.gpars.dataflow.DataflowReadChannel: Creates and attaches a new operator processing values from the channel
chainWith(Pool, Map<String, Object>, Closure<V>) - Method in interface groovyx.gpars.dataflow.DataflowReadChannel: Creates and attaches a new operator processing values from the channel
chainWith(PGroup, Map<String, Object>, Closure<V>) - Method in interface groovyx.gpars.dataflow.DataflowReadChannel: Creates and attaches a new operator processing values from the channel
chainWith(Closure<V>) - Method in class groovyx.gpars.dataflow.expression.DataflowExpression
chainWith(Pool, Closure<V>) - Method in class groovyx.gpars.dataflow.expression.DataflowExpression
chainWith(PGroup, Closure<V>) - Method in class groovyx.gpars.dataflow.expression.DataflowExpression
chainWith(Map<String, Object>, Closure<V>) - Method in class groovyx.gpars.dataflow.expression.DataflowExpression
chainWith(Pool, Map<String, Object>, Closure<V>) - Method in class groovyx.gpars.dataflow.expression.DataflowExpression
chainWith(PGroup, Map<String, Object>, Closure<V>) - Method in class groovyx.gpars.dataflow.expression.DataflowExpression
chainWith(Closure<V>) - Method in class groovyx.gpars.dataflow.operator.Pipeline: Creates and attaches a new operator
chainWith(Map<String, Object>, Closure<V>) - Method in class groovyx.gpars.dataflow.operator.Pipeline: Creates and attaches a new operator
chainWith(Closure<V>) - Method in class groovyx.gpars.dataflow.stream.DataflowStreamReadAdapter
chainWith(Pool, Closure<V>) - Method in class groovyx.gpars.dataflow.stream.DataflowStreamReadAdapter
chainWith(PGroup, Closure<V>) - Method in class groovyx.gpars.dataflow.stream.DataflowStreamReadAdapter
chainWith(Map<String, Object>, Closure<V>) - Method in class groovyx.gpars.dataflow.stream.DataflowStreamReadAdapter
chainWith(Pool, Map<String, Object>, Closure<V>) - Method in class groovyx.gpars.dataflow.stream.DataflowStreamReadAdapter
chainWith(PGroup, Map<String, Object>, Closure<V>) - Method in class groovyx.gpars.dataflow.stream.DataflowStreamReadAdapter
chainWith(PGroup, Closure<V>) - Method in class groovyx.gpars.dataflow.SyncDataflowQueue
chainWith(PGroup, Closure<V>) - Method in class groovyx.gpars.dataflow.SyncDataflowStreamReadAdapter
chainWith(PGroup, Closure<V>) - Method in class groovyx.gpars.dataflow.SyncDataflowVariable
ChainWithClosure<V> - Class in groovyx.gpars.dataflow.operator: Used by the chainWith() method to wrap the supplied closure inside the operator's body.
ChainWithClosure(Closure) - Constructor for class groovyx.gpars.dataflow.operator.ChainWithClosure
channel - Variable in class groovyx.gpars.dataflow.impl.SelectCallback
channel - Variable in class groovyx.gpars.remote.netty.NettyHandler
channel - Variable in class groovyx.gpars.remote.netty.NettyTransportProvider.Server
channelConnected(ChannelHandlerContext, ChannelStateEvent) - Method in class groovyx.gpars.remote.netty.NettyHandler
channelDisconnected(ChannelHandlerContext, ChannelStateEvent) - Method in class groovyx.gpars.remote.netty.NettyHandler
channelDisconnected(ChannelHandlerContext, ChannelStateEvent) - Method in class groovyx.gpars.remote.netty.NettyTransportProvider.ClientHandler
channelFuture - Variable in class groovyx.gpars.remote.netty.NettyTransportProvider.Client
channelOpen(ChannelHandlerContext, ChannelStateEvent) - Method in class groovyx.gpars.remote.netty.NettyHandler
channels - Variable in class groovyx.gpars.dataflow.impl.SelectBase
checkBlockingMethod(MethodNode, Iterable<AnnotationNode>) - Method in class groovyx.gpars.activeobject.ActiveObjectASTTransformation.MyClassCodeExpressionTransformer
checkClosed() - Method in class groovyx.gpars.dataflow.SyncDataflowStreamReadAdapter
checkClosure(Closure) - Method in class groovyx.gpars.agent.AgentBase: Only two-argument closures are allowed
checkForBodyArguments(Closure) - Static method in class groovyx.gpars.actor.DefaultActor
checkForMessageHandlerArguments(Closure) - Static method in class groovyx.gpars.actor.DefaultActor
checkForNull(Runnable) - Static method in class groovyx.gpars.actor.DefaultActor
checkMaxForks(Map<?, ?>) - Static method in class groovyx.gpars.dataflow.operator.DataflowProcessor
checkPoison(Object) - Method in class groovyx.gpars.dataflow.operator.DataflowProcessorActor: Handles the poisson message.
checkState() - Method in class groovyx.gpars.dataflow.operator.Pipeline
checkStoppedFlags() - Method in class groovyx.gpars.actor.BlockingActor
checkStopTerminate() - Method in class groovyx.gpars.actor.impl.SequentialProcessingActor
checkValidPoolSize(int) - Static method in class groovyx.gpars.util.PoolUtils
checkWhetherAnyEventsHaveArrived() - Method in class groovyx.gpars.dataflow.operator.component.GracefulShutdownMonitor: Checks the notification flag whether there has been some activity since last timer run.
children - Variable in class groovyx.gpars.forkjoin.AbstractForkJoinWorker: Stores the child workers
choice(List<DataflowWriteChannel<T>>, Closure<Integer>) - Method in class groovyx.gpars.dataflow.DataflowQueue
choice(Pool, List<DataflowWriteChannel<T>>, Closure<Integer>) - Method in class groovyx.gpars.dataflow.DataflowQueue
choice(PGroup, List<DataflowWriteChannel<T>>, Closure<Integer>) - Method in class groovyx.gpars.dataflow.DataflowQueue
choice(Map<String, Object>, List<DataflowWriteChannel<T>>, Closure<Integer>) - Method in class groovyx.gpars.dataflow.DataflowQueue
choice(Pool, Map<String, Object>, List<DataflowWriteChannel<T>>, Closure<Integer>) - Method in class groovyx.gpars.dataflow.DataflowQueue
choice(PGroup, Map<String, Object>, List<DataflowWriteChannel<T>>, Closure<Integer>) - Method in class groovyx.gpars.dataflow.DataflowQueue
choice(List<DataflowWriteChannel<T>>, Closure<Integer>) - Method in interface groovyx.gpars.dataflow.DataflowReadChannel: Directs the output to one of the output channels depending on the int result of the provided closure.
choice(Pool, List<DataflowWriteChannel<T>>, Closure<Integer>) - Method in interface groovyx.gpars.dataflow.DataflowReadChannel: Directs the output to one of the output channels depending on the int result of the provided closure.
choice(PGroup, List<DataflowWriteChannel<T>>, Closure<Integer>) - Method in interface groovyx.gpars.dataflow.DataflowReadChannel: Directs the output to one of the output channels depending on the int result of the provided closure.
choice(Map<String, Object>, List<DataflowWriteChannel<T>>, Closure<Integer>) - Method in interface groovyx.gpars.dataflow.DataflowReadChannel: Directs the output to one of the output channels depending on the int result of the provided closure.
choice(Pool, Map<String, Object>, List<DataflowWriteChannel<T>>, Closure<Integer>) - Method in interface groovyx.gpars.dataflow.DataflowReadChannel: Directs the output to one of the output channels depending on the int result of the provided closure.
choice(PGroup, Map<String, Object>, List<DataflowWriteChannel<T>>, Closure<Integer>) - Method in interface groovyx.gpars.dataflow.DataflowReadChannel: Directs the output to one of the output channels depending on the int result of the provided closure.
choice(List<DataflowWriteChannel<T>>, Closure<Integer>) - Method in class groovyx.gpars.dataflow.expression.DataflowExpression
choice(Pool, List<DataflowWriteChannel<T>>, Closure<Integer>) - Method in class groovyx.gpars.dataflow.expression.DataflowExpression
choice(PGroup, List<DataflowWriteChannel<T>>, Closure<Integer>) - Method in class groovyx.gpars.dataflow.expression.DataflowExpression
choice(Map<String, Object>, List<DataflowWriteChannel<T>>, Closure<Integer>) - Method in class groovyx.gpars.dataflow.expression.DataflowExpression
choice(Pool, Map<String, Object>, List<DataflowWriteChannel<T>>, Closure<Integer>) - Method in class groovyx.gpars.dataflow.expression.DataflowExpression
choice(PGroup, Map<String, Object>, List<DataflowWriteChannel<T>>, Closure<Integer>) - Method in class groovyx.gpars.dataflow.expression.DataflowExpression
choice(List<DataflowWriteChannel<T>>, Closure<Integer>) - Method in class groovyx.gpars.dataflow.operator.Pipeline: Directs the output to one of the output channels depending on the int result of the provided closure.
choice(Map<String, Object>, List<DataflowWriteChannel<T>>, Closure<Integer>) - Method in class groovyx.gpars.dataflow.operator.Pipeline: Directs the output to one of the output channels depending on the int result of the provided closure.
choice(List<DataflowWriteChannel<T>>, Closure<Integer>) - Method in class groovyx.gpars.dataflow.stream.DataflowStreamReadAdapter
choice(Pool, List<DataflowWriteChannel<T>>, Closure<Integer>) - Method in class groovyx.gpars.dataflow.stream.DataflowStreamReadAdapter
choice(PGroup, List<DataflowWriteChannel<T>>, Closure<Integer>) - Method in class groovyx.gpars.dataflow.stream.DataflowStreamReadAdapter
choice(Map<String, Object>, List<DataflowWriteChannel<T>>, Closure<Integer>) - Method in class groovyx.gpars.dataflow.stream.DataflowStreamReadAdapter
choice(Pool, Map<String, Object>, List<DataflowWriteChannel<T>>, Closure<Integer>) - Method in class groovyx.gpars.dataflow.stream.DataflowStreamReadAdapter
choice(PGroup, Map<String, Object>, List<DataflowWriteChannel<T>>, Closure<Integer>) - Method in class groovyx.gpars.dataflow.stream.DataflowStreamReadAdapter
ChoiceClosure - Class in groovyx.gpars.dataflow.operator: Used by the chainWith() method to wrap the supplied closure inside the operator's body.
ChoiceClosure(Closure<Integer>) - Constructor for class groovyx.gpars.dataflow.operator.ChoiceClosure
clear() - Method in class groovyx.gpars.extra166y.CustomConcurrentHashMap: Removes all of the mappings from this map.
clear() - Method in class groovyx.gpars.extra166y.CustomConcurrentHashMap.EntrySet
clear() - Method in class groovyx.gpars.extra166y.CustomConcurrentHashMap.KeySet: Removes all of the elements from this set.
clear() - Method in class groovyx.gpars.extra166y.CustomConcurrentHashMap.KeySetView
clear() - Method in class groovyx.gpars.extra166y.CustomConcurrentHashMap.Values
clear() - Method in class groovyx.gpars.extra166y.ParallelArray.AsList
clear() - Method in class groovyx.gpars.extra166y.ParallelDoubleArray.AsList
clear() - Method in class groovyx.gpars.extra166y.ParallelLongArray.AsList
clearCount() - Method in class groovyx.gpars.extra166y.CustomConcurrentHashMap.Segment
clients - Variable in class groovyx.gpars.remote.netty.NettyTransportProvider
clone() - Method in class groovyx.gpars.memoize.LRUProtectionStorage: Deprecated.

Performs a shallow clone
clone() - Method in class groovyx.gpars.pa.CallClosure
close() - Method in class groovyx.gpars.dataflow.SyncDataflowStreamReadAdapter: Closes the channel so that it cannot be used any longer
closed - Variable in class groovyx.gpars.dataflow.SyncDataflowStreamReadAdapter
closure - Variable in class groovyx.gpars.dataflow.expression.DataflowExpression.TransformMany
closure - Variable in class groovyx.gpars.dataflow.expression.DataflowExpression.TransformOne
closure - Variable in class groovyx.gpars.dataflow.impl.ThenMessagingRunnable
closure - Variable in class groovyx.gpars.remote.RemoteNodeDiscoveryListener.RemoteNodeDiscoveryListenerClosure
ClosureMapper<V> - Class in groovyx.gpars.pa: A PA mapper built around a closure
ClosureMapper(Closure<V>) - Constructor for class groovyx.gpars.pa.ClosureMapper
ClosureNegationPredicate - Class in groovyx.gpars.pa: A PA predicate built around a closure
ClosureNegationPredicate(Closure) - Constructor for class groovyx.gpars.pa.ClosureNegationPredicate
ClosurePredicate - Class in groovyx.gpars.pa: A PA predicate built around a closure
ClosurePredicate(Closure) - Constructor for class groovyx.gpars.pa.ClosurePredicate
ClosureReducer<T> - Class in groovyx.gpars.pa: A PA reducer built around a closure
ClosureReducer(Closure) - Constructor for class groovyx.gpars.pa.ClosureReducer
cmp - Static variable in class groovyx.gpars.extra166y.CommonOps.RawComparator
cmp - Variable in class groovyx.gpars.extra166y.PAS.FJDMerger
cmp - Variable in class groovyx.gpars.extra166y.PAS.FJDSorter
cmp - Variable in class groovyx.gpars.extra166y.PAS.FJLMerger
cmp - Variable in class groovyx.gpars.extra166y.PAS.FJLSorter
cmp - Variable in class groovyx.gpars.extra166y.PAS.FJOMerger
cmp - Variable in class groovyx.gpars.extra166y.PAS.FJOSorter
code - Variable in class groovyx.gpars.dataflow.DataCallback
code - Variable in class groovyx.gpars.dataflow.DataCallbackWithPool
code - Variable in class groovyx.gpars.dataflow.operator.BinaryChoiceClosure
code - Variable in class groovyx.gpars.dataflow.operator.ChainWithClosure
code - Variable in class groovyx.gpars.dataflow.operator.ChoiceClosure
code - Variable in class groovyx.gpars.dataflow.operator.DataflowProcessorActor
code - Variable in class groovyx.gpars.dataflow.operator.SeparationClosure
code - Variable in class groovyx.gpars.forkjoin.FJWorker
code - Variable in class groovyx.gpars.pa.CallAsyncTask
code - Variable in class groovyx.gpars.pa.ClosureMapper
code - Variable in class groovyx.gpars.pa.ClosureNegationPredicate
code - Variable in class groovyx.gpars.pa.ClosurePredicate
code - Variable in class groovyx.gpars.pa.ClosureReducer
code - Variable in class groovyx.gpars.stm.GParsAtomicBooleanBlock
code - Variable in class groovyx.gpars.stm.GParsAtomicDoubleBlock
code - Variable in class groovyx.gpars.stm.GParsAtomicIntBlock
code - Variable in class groovyx.gpars.stm.GParsAtomicLongBlock
code - Variable in class groovyx.gpars.stm.GParsAtomicVoidBlock
code - Variable in class groovyx.gpars.stm.GParsTxnExecutor
collectingMessages - Variable in class groovyx.gpars.dataflow.operator.component.GracefulShutdownListener
collectManyParallel(Collection, Closure<Collection<? extends T>>) - Static method in class groovyx.gpars.GParsPoolUtil: Creates a Parallel Array out of the supplied collection/object and invokes the withMapping() method using the supplied projection closure as the transformation operation.
collectManyParallel(Object, Closure<Collection<? extends T>>) - Static method in class groovyx.gpars.GParsPoolUtil: Creates a Parallel Array out of the supplied collection/object and invokes the withMapping() method using the supplied projection closure as the transformation operation.
collectManyParallel(Map, Closure<Collection<? extends T>>) - Static method in class groovyx.gpars.GParsPoolUtil: Creates a Parallel Array out of the supplied collection/object and invokes the withMapping() method using the supplied projection closure as the transformation operation.
collectParallel(Collection, Closure<? extends T>) - Static method in class groovyx.gpars.GParsPoolUtil: Creates a Parallel Array out of the supplied collection/object and invokes the withMapping() method using the supplied closure as the transformation operation.
collectParallel(Object, Closure<? extends T>) - Static method in class groovyx.gpars.GParsPoolUtil: Creates a Parallel Array out of the supplied collection/object and invokes the withMapping() method using the supplied closure as the transformation operation.
collectParallel(Map, Closure<? extends T>) - Static method in class groovyx.gpars.GParsPoolUtil: Creates a Parallel Array out of the supplied map and invokes the withMapping() method using the supplied closure as the transformation operation.
CombineHolder - Class in groovyx.gpars.pa: Holds a temporary reduce result for groupBy
CombineHolder(Map<Object, Object>) - Constructor for class groovyx.gpars.pa.CombineHolder
combiner - Variable in class groovyx.gpars.extra166y.PAS.FJDCombineInPlace
combiner - Variable in class groovyx.gpars.extra166y.PAS.FJDPACombineInPlace
combiner - Variable in class groovyx.gpars.extra166y.PAS.FJLCombineInPlace
combiner - Variable in class groovyx.gpars.extra166y.PAS.FJLPACombineInPlace
combiner - Variable in class groovyx.gpars.extra166y.PAS.FJOCombineInPlace
combiner - Variable in class groovyx.gpars.extra166y.PAS.FJOPACombineInPlace
CommonOps - Class in groovyx.gpars.extra166y: A collection of static factory methods providing commonly useful implementations of operations.
CommonOps() - Constructor for class groovyx.gpars.extra166y.CommonOps
CommonOps.DoubleAdder - Class in groovyx.gpars.extra166y
CommonOps.DoubleAdder() - Constructor for class groovyx.gpars.extra166y.CommonOps.DoubleAdder
CommonOps.DoubleBoundedRandomGenerator - Class in groovyx.gpars.extra166y
CommonOps.DoubleBoundedRandomGenerator(double) - Constructor for class groovyx.gpars.extra166y.CommonOps.DoubleBoundedRandomGenerator
CommonOps.DoubleEqualityPredicate - Class in groovyx.gpars.extra166y
CommonOps.DoubleEqualityPredicate() - Constructor for class groovyx.gpars.extra166y.CommonOps.DoubleEqualityPredicate
CommonOps.DoubleInequalityPredicate - Class in groovyx.gpars.extra166y
CommonOps.DoubleInequalityPredicate() - Constructor for class groovyx.gpars.extra166y.CommonOps.DoubleInequalityPredicate
CommonOps.DoubleIntervalRandomGenerator - Class in groovyx.gpars.extra166y
CommonOps.DoubleIntervalRandomGenerator(double, double) - Constructor for class groovyx.gpars.extra166y.CommonOps.DoubleIntervalRandomGenerator
CommonOps.DoubleRandomGenerator - Class in groovyx.gpars.extra166y
CommonOps.DoubleRandomGenerator() - Constructor for class groovyx.gpars.extra166y.CommonOps.DoubleRandomGenerator
CommonOps.EqualityPredicate - Class in groovyx.gpars.extra166y
CommonOps.EqualityPredicate() - Constructor for class groovyx.gpars.extra166y.CommonOps.EqualityPredicate
CommonOps.IdentityPredicate - Class in groovyx.gpars.extra166y
CommonOps.IdentityPredicate() - Constructor for class groovyx.gpars.extra166y.CommonOps.IdentityPredicate
CommonOps.InequalityPredicate - Class in groovyx.gpars.extra166y
CommonOps.InequalityPredicate() - Constructor for class groovyx.gpars.extra166y.CommonOps.InequalityPredicate
CommonOps.IntAdder - Class in groovyx.gpars.extra166y
CommonOps.IntAdder() - Constructor for class groovyx.gpars.extra166y.CommonOps.IntAdder
CommonOps.IntBoundedRandomGenerator - Class in groovyx.gpars.extra166y
CommonOps.IntBoundedRandomGenerator(int) - Constructor for class groovyx.gpars.extra166y.CommonOps.IntBoundedRandomGenerator
CommonOps.IntEqualityPredicate - Class in groovyx.gpars.extra166y
CommonOps.IntEqualityPredicate() - Constructor for class groovyx.gpars.extra166y.CommonOps.IntEqualityPredicate
CommonOps.IntInequalityPredicate - Class in groovyx.gpars.extra166y
CommonOps.IntInequalityPredicate() - Constructor for class groovyx.gpars.extra166y.CommonOps.IntInequalityPredicate
CommonOps.IntIntervalRandomGenerator - Class in groovyx.gpars.extra166y
CommonOps.IntIntervalRandomGenerator(int, int) - Constructor for class groovyx.gpars.extra166y.CommonOps.IntIntervalRandomGenerator
CommonOps.IntRandomGenerator - Class in groovyx.gpars.extra166y
CommonOps.IntRandomGenerator() - Constructor for class groovyx.gpars.extra166y.CommonOps.IntRandomGenerator
CommonOps.IsNonNullPredicate - Class in groovyx.gpars.extra166y
CommonOps.IsNonNullPredicate() - Constructor for class groovyx.gpars.extra166y.CommonOps.IsNonNullPredicate
CommonOps.IsNullPredicate - Class in groovyx.gpars.extra166y
CommonOps.IsNullPredicate() - Constructor for class groovyx.gpars.extra166y.CommonOps.IsNullPredicate
CommonOps.LongAdder - Class in groovyx.gpars.extra166y
CommonOps.LongAdder() - Constructor for class groovyx.gpars.extra166y.CommonOps.LongAdder
CommonOps.LongBoundedRandomGenerator - Class in groovyx.gpars.extra166y
CommonOps.LongBoundedRandomGenerator(long) - Constructor for class groovyx.gpars.extra166y.CommonOps.LongBoundedRandomGenerator
CommonOps.LongEqualityPredicate - Class in groovyx.gpars.extra166y
CommonOps.LongEqualityPredicate() - Constructor for class groovyx.gpars.extra166y.CommonOps.LongEqualityPredicate
CommonOps.LongInequalityPredicate - Class in groovyx.gpars.extra166y
CommonOps.LongInequalityPredicate() - Constructor for class groovyx.gpars.extra166y.CommonOps.LongInequalityPredicate
CommonOps.LongIntervalRandomGenerator - Class in groovyx.gpars.extra166y
CommonOps.LongIntervalRandomGenerator(long, long) - Constructor for class groovyx.gpars.extra166y.CommonOps.LongIntervalRandomGenerator
CommonOps.LongRandomGenerator - Class in groovyx.gpars.extra166y
CommonOps.LongRandomGenerator() - Constructor for class groovyx.gpars.extra166y.CommonOps.LongRandomGenerator
CommonOps.NaturalDoubleComparator - Class in groovyx.gpars.extra166y
CommonOps.NaturalDoubleComparator() - Constructor for class groovyx.gpars.extra166y.CommonOps.NaturalDoubleComparator
CommonOps.NaturalDoubleMaxReducer - Class in groovyx.gpars.extra166y
CommonOps.NaturalDoubleMaxReducer() - Constructor for class groovyx.gpars.extra166y.CommonOps.NaturalDoubleMaxReducer
CommonOps.NaturalDoubleMinReducer - Class in groovyx.gpars.extra166y
CommonOps.NaturalDoubleMinReducer() - Constructor for class groovyx.gpars.extra166y.CommonOps.NaturalDoubleMinReducer
CommonOps.NaturalLongComparator - Class in groovyx.gpars.extra166y
CommonOps.NaturalLongComparator() - Constructor for class groovyx.gpars.extra166y.CommonOps.NaturalLongComparator
CommonOps.NaturalLongMaxReducer - Class in groovyx.gpars.extra166y
CommonOps.NaturalLongMaxReducer() - Constructor for class groovyx.gpars.extra166y.CommonOps.NaturalLongMaxReducer
CommonOps.NaturalLongMinReducer - Class in groovyx.gpars.extra166y
CommonOps.NaturalLongMinReducer() - Constructor for class groovyx.gpars.extra166y.CommonOps.NaturalLongMinReducer
CommonOps.NonidentityPredicate - Class in groovyx.gpars.extra166y
CommonOps.NonidentityPredicate() - Constructor for class groovyx.gpars.extra166y.CommonOps.NonidentityPredicate
CommonOps.RawComparator - Class in groovyx.gpars.extra166y
CommonOps.RawComparator() - Constructor for class groovyx.gpars.extra166y.CommonOps.RawComparator
CommonOps.RawMaxReducer - Class in groovyx.gpars.extra166y
CommonOps.RawMaxReducer() - Constructor for class groovyx.gpars.extra166y.CommonOps.RawMaxReducer
CommonOps.RawMinReducer - Class in groovyx.gpars.extra166y
CommonOps.RawMinReducer() - Constructor for class groovyx.gpars.extra166y.CommonOps.RawMinReducer
comparator - Static variable in class groovyx.gpars.extra166y.CommonOps.NaturalDoubleComparator
comparator - Static variable in class groovyx.gpars.extra166y.CommonOps.NaturalLongComparator
comparator - Variable in class groovyx.gpars.extra166y.PAS.FJDStats
comparator - Variable in class groovyx.gpars.extra166y.PAS.FJLStats
comparator - Variable in class groovyx.gpars.extra166y.PAS.FJOStats
compare(double, double) - Method in class groovyx.gpars.extra166y.CommonOps.NaturalDoubleComparator
compare(long, long) - Method in class groovyx.gpars.extra166y.CommonOps.NaturalLongComparator
compare(Object, Object) - Method in class groovyx.gpars.extra166y.CommonOps.RawComparator
compare(double, double) - Method in interface groovyx.gpars.extra166y.Ops.DoubleComparator
compare(int, int) - Method in interface groovyx.gpars.extra166y.Ops.IntComparator
compare(long, long) - Method in interface groovyx.gpars.extra166y.Ops.LongComparator
complete - Variable in class groovyx.gpars.dataflow.operator.Pipeline
compoundIndexedOp(Ops.IntAndObjectToObject<? super T, ? extends U>, Ops.IntAndObjectToObject<? super U, ? extends V>) - Static method in class groovyx.gpars.extra166y.AbstractParallelAnyArray
compoundIndexedOp(Ops.IntAndObjectToObject<? super T, ? extends U>, Ops.IntAndObjectToDouble<? super U>) - Static method in class groovyx.gpars.extra166y.AbstractParallelAnyArray
compoundIndexedOp(Ops.IntAndObjectToObject<? super T, ? extends U>, Ops.IntAndObjectToLong<? super U>) - Static method in class groovyx.gpars.extra166y.AbstractParallelAnyArray
compoundIndexedOp(Ops.IntAndDoubleToObject<? extends U>, Ops.IntAndObjectToObject<? super U, ? extends V>) - Static method in class groovyx.gpars.extra166y.AbstractParallelAnyArray
compoundIndexedOp(Ops.IntAndDoubleToObject<? extends U>, Ops.IntAndObjectToDouble<? super U>) - Static method in class groovyx.gpars.extra166y.AbstractParallelAnyArray
compoundIndexedOp(Ops.IntAndDoubleToObject<? extends U>, Ops.IntAndObjectToLong<? super U>) - Static method in class groovyx.gpars.extra166y.AbstractParallelAnyArray
compoundIndexedOp(Ops.IntAndLongToObject<? extends U>, Ops.IntAndObjectToObject<? super U, ? extends V>) - Static method in class groovyx.gpars.extra166y.AbstractParallelAnyArray
compoundIndexedOp(Ops.IntAndLongToObject<? extends U>, Ops.IntAndObjectToDouble<? super U>) - Static method in class groovyx.gpars.extra166y.AbstractParallelAnyArray
compoundIndexedOp(Ops.IntAndLongToObject<? extends U>, Ops.IntAndObjectToLong<? super U>) - Static method in class groovyx.gpars.extra166y.AbstractParallelAnyArray
compoundIndexedOp(Ops.IntAndObjectToDouble<? super T>, Ops.IntAndDoubleToObject<? extends V>) - Static method in class groovyx.gpars.extra166y.AbstractParallelAnyArray
compoundIndexedOp(Ops.IntAndObjectToDouble<? super T>, Ops.IntAndDoubleToDouble) - Static method in class groovyx.gpars.extra166y.AbstractParallelAnyArray
compoundIndexedOp(Ops.IntAndObjectToLong<? super T>, Ops.IntAndLongToLong) - Static method in class groovyx.gpars.extra166y.AbstractParallelAnyArray
compoundIndexedOp(Ops.IntAndDoubleToLong, Ops.IntAndLongToObject<? extends V>) - Static method in class groovyx.gpars.extra166y.AbstractParallelAnyArray
compoundIndexedOp(Ops.IntAndDoubleToDouble, Ops.IntAndDoubleToDouble) - Static method in class groovyx.gpars.extra166y.AbstractParallelAnyArray
compoundIndexedOp(Ops.IntAndDoubleToDouble, Ops.IntAndDoubleToLong) - Static method in class groovyx.gpars.extra166y.AbstractParallelAnyArray
compoundIndexedOp(Ops.IntAndLongToDouble, Ops.IntAndDoubleToObject<? extends V>) - Static method in class groovyx.gpars.extra166y.AbstractParallelAnyArray
compoundIndexedOp(Ops.IntAndLongToDouble, Ops.IntAndDoubleToDouble) - Static method in class groovyx.gpars.extra166y.AbstractParallelAnyArray
compoundIndexedOp(Ops.IntAndLongToDouble, Ops.IntAndDoubleToLong) - Static method in class groovyx.gpars.extra166y.AbstractParallelAnyArray
compoundIndexedOp(Ops.IntAndObjectToLong<? super T>, Ops.IntAndLongToObject<? extends V>) - Static method in class groovyx.gpars.extra166y.AbstractParallelAnyArray
compoundIndexedOp(Ops.IntAndObjectToLong<? super T>, Ops.IntAndLongToDouble) - Static method in class groovyx.gpars.extra166y.AbstractParallelAnyArray
compoundIndexedOp(Ops.IntAndObjectToDouble<? super T>, Ops.IntAndDoubleToLong) - Static method in class groovyx.gpars.extra166y.AbstractParallelAnyArray
compoundIndexedOp(Ops.IntAndDoubleToDouble, Ops.IntAndDoubleToObject<? extends V>) - Static method in class groovyx.gpars.extra166y.AbstractParallelAnyArray
compoundIndexedOp(Ops.IntAndDoubleToLong, Ops.IntAndLongToDouble) - Static method in class groovyx.gpars.extra166y.AbstractParallelAnyArray
compoundIndexedOp(Ops.IntAndDoubleToLong, Ops.IntAndLongToLong) - Static method in class groovyx.gpars.extra166y.AbstractParallelAnyArray
compoundIndexedOp(Ops.IntAndLongToLong, Ops.IntAndLongToObject<? extends V>) - Static method in class groovyx.gpars.extra166y.AbstractParallelAnyArray
compoundIndexedOp(Ops.IntAndLongToLong, Ops.IntAndLongToDouble) - Static method in class groovyx.gpars.extra166y.AbstractParallelAnyArray
compoundIndexedOp(Ops.IntAndLongToLong, Ops.IntAndLongToLong) - Static method in class groovyx.gpars.extra166y.AbstractParallelAnyArray
compoundIndexedOp(Ops.IntAndObjectToObject<? super T, ? extends U>, Ops.Op<? super U, ? extends V>) - Static method in class groovyx.gpars.extra166y.AbstractParallelAnyArray
compoundIndexedOp(Ops.IntAndObjectToObject<? super T, ? extends U>, Ops.ObjectToDouble<? super U>) - Static method in class groovyx.gpars.extra166y.AbstractParallelAnyArray
compoundIndexedOp(Ops.IntAndObjectToObject<? super T, ? extends U>, Ops.ObjectToLong<? super U>) - Static method in class groovyx.gpars.extra166y.AbstractParallelAnyArray
compoundIndexedOp(Ops.IntAndDoubleToObject<? extends U>, Ops.Op<? super U, ? extends V>) - Static method in class groovyx.gpars.extra166y.AbstractParallelAnyArray
compoundIndexedOp(Ops.IntAndDoubleToObject<? extends U>, Ops.ObjectToDouble<? super U>) - Static method in class groovyx.gpars.extra166y.AbstractParallelAnyArray
compoundIndexedOp(Ops.IntAndDoubleToObject<? extends U>, Ops.ObjectToLong<? super U>) - Static method in class groovyx.gpars.extra166y.AbstractParallelAnyArray
compoundIndexedOp(Ops.IntAndLongToObject<? extends U>, Ops.Op<? super U, ? extends V>) - Static method in class groovyx.gpars.extra166y.AbstractParallelAnyArray
compoundIndexedOp(Ops.IntAndLongToObject<? extends U>, Ops.ObjectToDouble<? super U>) - Static method in class groovyx.gpars.extra166y.AbstractParallelAnyArray
compoundIndexedOp(Ops.IntAndLongToObject<? extends U>, Ops.ObjectToLong<? super U>) - Static method in class groovyx.gpars.extra166y.AbstractParallelAnyArray
compoundIndexedOp(Ops.IntAndObjectToDouble<? super T>, Ops.DoubleToObject<? extends V>) - Static method in class groovyx.gpars.extra166y.AbstractParallelAnyArray
compoundIndexedOp(Ops.IntAndObjectToDouble<? super T>, Ops.DoubleOp) - Static method in class groovyx.gpars.extra166y.AbstractParallelAnyArray
compoundIndexedOp(Ops.IntAndObjectToDouble<? super T>, Ops.DoubleToLong) - Static method in class groovyx.gpars.extra166y.AbstractParallelAnyArray
compoundIndexedOp(Ops.IntAndDoubleToDouble, Ops.DoubleToObject<? extends V>) - Static method in class groovyx.gpars.extra166y.AbstractParallelAnyArray
compoundIndexedOp(Ops.IntAndDoubleToDouble, Ops.DoubleOp) - Static method in class groovyx.gpars.extra166y.AbstractParallelAnyArray
compoundIndexedOp(Ops.IntAndDoubleToDouble, Ops.DoubleToLong) - Static method in class groovyx.gpars.extra166y.AbstractParallelAnyArray
compoundIndexedOp(Ops.IntAndLongToDouble, Ops.DoubleToObject<? extends V>) - Static method in class groovyx.gpars.extra166y.AbstractParallelAnyArray
compoundIndexedOp(Ops.IntAndLongToDouble, Ops.DoubleOp) - Static method in class groovyx.gpars.extra166y.AbstractParallelAnyArray
compoundIndexedOp(Ops.IntAndLongToDouble, Ops.DoubleToLong) - Static method in class groovyx.gpars.extra166y.AbstractParallelAnyArray
compoundIndexedOp(Ops.IntAndObjectToLong<? super T>, Ops.LongToObject<? extends V>) - Static method in class groovyx.gpars.extra166y.AbstractParallelAnyArray
compoundIndexedOp(Ops.IntAndObjectToLong<? super T>, Ops.LongToDouble) - Static method in class groovyx.gpars.extra166y.AbstractParallelAnyArray
compoundIndexedOp(Ops.IntAndObjectToLong<? super T>, Ops.LongOp) - Static method in class groovyx.gpars.extra166y.AbstractParallelAnyArray
compoundIndexedOp(Ops.IntAndDoubleToLong, Ops.LongToObject<? extends V>) - Static method in class groovyx.gpars.extra166y.AbstractParallelAnyArray
compoundIndexedOp(Ops.IntAndDoubleToLong, Ops.LongToDouble) - Static method in class groovyx.gpars.extra166y.AbstractParallelAnyArray
compoundIndexedOp(Ops.IntAndDoubleToLong, Ops.LongOp) - Static method in class groovyx.gpars.extra166y.AbstractParallelAnyArray
compoundIndexedOp(Ops.IntAndLongToLong, Ops.LongToObject<? extends V>) - Static method in class groovyx.gpars.extra166y.AbstractParallelAnyArray
compoundIndexedOp(Ops.IntAndLongToLong, Ops.LongToDouble) - Static method in class groovyx.gpars.extra166y.AbstractParallelAnyArray
compoundIndexedOp(Ops.IntAndLongToLong, Ops.LongOp) - Static method in class groovyx.gpars.extra166y.AbstractParallelAnyArray
compoundIndexedOp(Ops.Op<? super T, ? extends U>, Ops.IntAndObjectToObject<? super U, ? extends V>) - Static method in class groovyx.gpars.extra166y.AbstractParallelAnyArray
compoundIndexedOp(Ops.Op<? super T, ? extends U>, Ops.IntAndObjectToDouble<? super U>) - Static method in class groovyx.gpars.extra166y.AbstractParallelAnyArray
compoundIndexedOp(Ops.Op<? super T, ? extends U>, Ops.IntAndObjectToLong<? super U>) - Static method in class groovyx.gpars.extra166y.AbstractParallelAnyArray
compoundIndexedOp(Ops.DoubleToObject<? extends U>, Ops.IntAndObjectToObject<? super U, ? extends V>) - Static method in class groovyx.gpars.extra166y.AbstractParallelAnyArray
compoundIndexedOp(Ops.DoubleToObject<? extends U>, Ops.IntAndObjectToDouble<? super U>) - Static method in class groovyx.gpars.extra166y.AbstractParallelAnyArray
compoundIndexedOp(Ops.DoubleToObject<? extends U>, Ops.IntAndObjectToLong<? super U>) - Static method in class groovyx.gpars.extra166y.AbstractParallelAnyArray
compoundIndexedOp(Ops.LongToObject<? extends U>, Ops.IntAndObjectToObject<? super U, ? extends V>) - Static method in class groovyx.gpars.extra166y.AbstractParallelAnyArray
compoundIndexedOp(Ops.LongToObject<? extends U>, Ops.IntAndObjectToDouble<? super U>) - Static method in class groovyx.gpars.extra166y.AbstractParallelAnyArray
compoundIndexedOp(Ops.LongToObject<? extends U>, Ops.IntAndObjectToLong<? super U>) - Static method in class groovyx.gpars.extra166y.AbstractParallelAnyArray
compoundIndexedOp(Ops.ObjectToDouble<? super T>, Ops.IntAndDoubleToObject<? extends V>) - Static method in class groovyx.gpars.extra166y.AbstractParallelAnyArray
compoundIndexedOp(Ops.ObjectToDouble<? super T>, Ops.IntAndDoubleToDouble) - Static method in class groovyx.gpars.extra166y.AbstractParallelAnyArray
compoundIndexedOp(Ops.ObjectToDouble<? super T>, Ops.IntAndDoubleToLong) - Static method in class groovyx.gpars.extra166y.AbstractParallelAnyArray
compoundIndexedOp(Ops.DoubleOp, Ops.IntAndDoubleToObject<? extends V>) - Static method in class groovyx.gpars.extra166y.AbstractParallelAnyArray
compoundIndexedOp(Ops.DoubleOp, Ops.IntAndDoubleToDouble) - Static method in class groovyx.gpars.extra166y.AbstractParallelAnyArray
compoundIndexedOp(Ops.DoubleOp, Ops.IntAndDoubleToLong) - Static method in class groovyx.gpars.extra166y.AbstractParallelAnyArray
compoundIndexedOp(Ops.LongToDouble, Ops.IntAndDoubleToObject<? extends V>) - Static method in class groovyx.gpars.extra166y.AbstractParallelAnyArray
compoundIndexedOp(Ops.LongToDouble, Ops.IntAndDoubleToDouble) - Static method in class groovyx.gpars.extra166y.AbstractParallelAnyArray
compoundIndexedOp(Ops.LongToDouble, Ops.IntAndDoubleToLong) - Static method in class groovyx.gpars.extra166y.AbstractParallelAnyArray
compoundIndexedOp(Ops.ObjectToLong<? super T>, Ops.IntAndLongToObject<? extends V>) - Static method in class groovyx.gpars.extra166y.AbstractParallelAnyArray
compoundIndexedOp(Ops.ObjectToLong<? super T>, Ops.IntAndLongToDouble) - Static method in class groovyx.gpars.extra166y.AbstractParallelAnyArray
compoundIndexedOp(Ops.ObjectToLong<? super T>, Ops.IntAndLongToLong) - Static method in class groovyx.gpars.extra166y.AbstractParallelAnyArray
compoundIndexedOp(Ops.DoubleToLong, Ops.IntAndLongToObject<? extends V>) - Static method in class groovyx.gpars.extra166y.AbstractParallelAnyArray
compoundIndexedOp(Ops.DoubleToLong, Ops.IntAndLongToDouble) - Static method in class groovyx.gpars.extra166y.AbstractParallelAnyArray
compoundIndexedOp(Ops.DoubleToLong, Ops.IntAndLongToLong) - Static method in class groovyx.gpars.extra166y.AbstractParallelAnyArray
compoundIndexedOp(Ops.LongOp, Ops.IntAndLongToObject<? extends V>) - Static method in class groovyx.gpars.extra166y.AbstractParallelAnyArray
compoundIndexedOp(Ops.LongOp, Ops.IntAndLongToDouble) - Static method in class groovyx.gpars.extra166y.AbstractParallelAnyArray
compoundIndexedOp(Ops.LongOp, Ops.IntAndLongToLong) - Static method in class groovyx.gpars.extra166y.AbstractParallelAnyArray
compoundIndexedSelector(Ops.Predicate<S>, Ops.IntAndObjectPredicate<? super T>) - Static method in class groovyx.gpars.extra166y.AbstractParallelAnyArray
compoundIndexedSelector(Ops.IntAndObjectPredicate<S>, Ops.IntAndObjectPredicate<? super T>) - Static method in class groovyx.gpars.extra166y.AbstractParallelAnyArray
compoundIndexedSelector(Ops.IntAndObjectPredicate<S>, Ops.Predicate<? super T>) - Static method in class groovyx.gpars.extra166y.AbstractParallelAnyArray
compoundIndexedSelector(Ops.DoublePredicate, Ops.IntAndDoublePredicate) - Static method in class groovyx.gpars.extra166y.AbstractParallelAnyArray
compoundIndexedSelector(Ops.IntAndDoublePredicate, Ops.IntAndDoublePredicate) - Static method in class groovyx.gpars.extra166y.AbstractParallelAnyArray
compoundIndexedSelector(Ops.IntAndDoublePredicate, Ops.DoublePredicate) - Static method in class groovyx.gpars.extra166y.AbstractParallelAnyArray
compoundIndexedSelector(Ops.LongPredicate, Ops.IntAndLongPredicate) - Static method in class groovyx.gpars.extra166y.AbstractParallelAnyArray
compoundIndexedSelector(Ops.IntAndLongPredicate, Ops.IntAndLongPredicate) - Static method in class groovyx.gpars.extra166y.AbstractParallelAnyArray
compoundIndexedSelector(Ops.IntAndLongPredicate, Ops.LongPredicate) - Static method in class groovyx.gpars.extra166y.AbstractParallelAnyArray
compoundOp(Ops.Op<? super T, ? extends U>, Ops.Op<? super U, ? extends V>) - Static method in class groovyx.gpars.extra166y.CommonOps: Returns a composite mapper that applies a second mapper to the results of applying the first one.
compoundOp(Ops.ObjectToDouble<? super T>, Ops.DoubleToObject<? extends V>) - Static method in class groovyx.gpars.extra166y.CommonOps: Returns a composite mapper that applies a second mapper to the results of applying the first one.
compoundOp(Ops.ObjectToLong<? super T>, Ops.LongToObject<? extends V>) - Static method in class groovyx.gpars.extra166y.CommonOps: Returns a composite mapper that applies a second mapper to the results of applying the first one.
compoundOp(Ops.DoubleToObject<? extends T>, Ops.Op<? super T, ? extends V>) - Static method in class groovyx.gpars.extra166y.CommonOps: Returns a composite mapper that applies a second mapper to the results of applying the first one.
compoundOp(Ops.LongToObject<? extends T>, Ops.Op<? super T, ? extends V>) - Static method in class groovyx.gpars.extra166y.CommonOps: Returns a composite mapper that applies a second mapper to the results of applying the first one.
compoundOp(Ops.Op<? super T, ? extends U>, Ops.ObjectToDouble<? super U>) - Static method in class groovyx.gpars.extra166y.CommonOps: Returns a composite mapper that applies a second mapper to the results of applying the first one.
compoundOp(Ops.Op<? super T, ? extends U>, Ops.ObjectToLong<? super U>) - Static method in class groovyx.gpars.extra166y.CommonOps: Returns a composite mapper that applies a second mapper to the results of applying the first one.
compoundOp(Ops.ObjectToDouble<? super T>, Ops.DoubleOp) - Static method in class groovyx.gpars.extra166y.CommonOps: Returns a composite mapper that applies a second mapper to the results of applying the first one.
compoundOp(Ops.ObjectToDouble<? super T>, Ops.DoubleToLong) - Static method in class groovyx.gpars.extra166y.CommonOps: Returns a composite mapper that applies a second mapper to the results of applying the first one.
compoundOp(Ops.ObjectToLong<? super T>, Ops.LongOp) - Static method in class groovyx.gpars.extra166y.CommonOps: Returns a composite mapper that applies a second mapper to the results of applying the first one.
compoundOp(Ops.ObjectToLong<? super T>, Ops.LongToDouble) - Static method in class groovyx.gpars.extra166y.CommonOps: Returns a composite mapper that applies a second mapper to the results of applying the first one.
compoundOp(Ops.DoubleOp, Ops.DoubleOp) - Static method in class groovyx.gpars.extra166y.CommonOps: Returns a composite mapper that applies a second mapper to the results of applying the first one.
compoundOp(Ops.DoubleOp, Ops.DoubleToLong) - Static method in class groovyx.gpars.extra166y.CommonOps: Returns a composite mapper that applies a second mapper to the results of applying the first one.
compoundOp(Ops.DoubleToLong, Ops.LongOp) - Static method in class groovyx.gpars.extra166y.CommonOps: Returns a composite mapper that applies a second mapper to the results of applying the first one.
compoundOp(Ops.DoubleToLong, Ops.LongToObject<? extends T>) - Static method in class groovyx.gpars.extra166y.CommonOps: Returns a composite mapper that applies a second mapper to the results of applying the first one.
compoundOp(Ops.LongToDouble, Ops.DoubleToObject<? extends T>) - Static method in class groovyx.gpars.extra166y.CommonOps: Returns a composite mapper that applies a second mapper to the results of applying the first one.
compoundOp(Ops.LongOp, Ops.LongToDouble) - Static method in class groovyx.gpars.extra166y.CommonOps: Returns a composite mapper that applies a second mapper to the results of applying the first one.
compoundOp(Ops.LongToDouble, Ops.DoubleOp) - Static method in class groovyx.gpars.extra166y.CommonOps: Returns a composite mapper that applies a second mapper to the results of applying the first one.
compoundOp(Ops.DoubleOp, Ops.DoubleToObject<? extends T>) - Static method in class groovyx.gpars.extra166y.CommonOps: Returns a composite mapper that applies a second mapper to the results of applying the first one.
compoundOp(Ops.LongOp, Ops.LongToObject<? extends T>) - Static method in class groovyx.gpars.extra166y.CommonOps: Returns a composite mapper that applies a second mapper to the results of applying the first one.
compoundOp(Ops.DoubleToObject<? extends T>, Ops.ObjectToDouble<? super T>) - Static method in class groovyx.gpars.extra166y.CommonOps: Returns a composite mapper that applies a second mapper to the results of applying the first one.
compoundOp(Ops.LongToObject<? extends T>, Ops.ObjectToDouble<? super T>) - Static method in class groovyx.gpars.extra166y.CommonOps: Returns a composite mapper that applies a second mapper to the results of applying the first one.
compoundOp(Ops.DoubleToObject<? extends T>, Ops.ObjectToLong<? super T>) - Static method in class groovyx.gpars.extra166y.CommonOps: Returns a composite mapper that applies a second mapper to the results of applying the first one.
compoundOp(Ops.LongToObject<? extends T>, Ops.ObjectToLong<? super T>) - Static method in class groovyx.gpars.extra166y.CommonOps: Returns a composite mapper that applies a second mapper to the results of applying the first one.
compoundOp(Ops.LongOp, Ops.LongOp) - Static method in class groovyx.gpars.extra166y.CommonOps: Returns a composite mapper that applies a second mapper to the results of applying the first one.
compoundOp(Ops.DoubleToLong, Ops.LongToDouble) - Static method in class groovyx.gpars.extra166y.CommonOps: Returns a composite mapper that applies a second mapper to the results of applying the first one.
compoundOp(Ops.LongToDouble, Ops.DoubleToLong) - Static method in class groovyx.gpars.extra166y.CommonOps: Returns a composite mapper that applies a second mapper to the results of applying the first one.
compute(K, CustomConcurrentHashMap.RemappingFunction<? super K, V>) - Method in class groovyx.gpars.extra166y.CustomConcurrentHashMap: Updates the mapping for the given key with the result of the given remappingFunction.
compute() - Method in class groovyx.gpars.extra166y.PAS.FJBase
compute() - Method in class groovyx.gpars.extra166y.PAS.FJDCMerger
compute() - Method in class groovyx.gpars.extra166y.PAS.FJDCSorter
compute() - Method in class groovyx.gpars.extra166y.PAS.FJDMerger
compute() - Method in class groovyx.gpars.extra166y.PAS.FJDSorter
compute() - Method in class groovyx.gpars.extra166y.PAS.FJLCMerger
compute() - Method in class groovyx.gpars.extra166y.PAS.FJLCSorter
compute() - Method in class groovyx.gpars.extra166y.PAS.FJLMerger
compute() - Method in class groovyx.gpars.extra166y.PAS.FJLSorter
compute() - Method in class groovyx.gpars.extra166y.PAS.FJOCMerger
compute() - Method in class groovyx.gpars.extra166y.PAS.FJOCSorter
compute() - Method in class groovyx.gpars.extra166y.PAS.FJOMerger
compute() - Method in class groovyx.gpars.extra166y.PAS.FJOSorter
compute() - Method in class groovyx.gpars.extra166y.PAS.FJRemoveAll
compute() - Method in class groovyx.gpars.extra166y.PAS.FJRemoveAllDriver
compute() - Method in class groovyx.gpars.extra166y.PAS.FJSearchBase
compute() - Method in class groovyx.gpars.extra166y.PAS.FJSelectAll
compute() - Method in class groovyx.gpars.extra166y.PAS.FJSelectAllDriver
compute() - Method in class groovyx.gpars.extra166y.PAS.FJSubSorter
compute() - Method in class groovyx.gpars.forkjoin.AbstractForkJoinWorker
compute() - Method in class groovyx.gpars.pa.CallAsyncTask
computeIfAbsent(K, CustomConcurrentHashMap.MappingFunction<? super K, ? extends V>) - Method in class groovyx.gpars.extra166y.CustomConcurrentHashMap: If the specified key is not already associated with a value, computes its value using the given mappingFunction, and if non-null, enters it into the map.
computeTask() - Method in class groovyx.gpars.forkjoin.AbstractForkJoinWorker
computeTask() - Method in class groovyx.gpars.forkjoin.FJWorker
computeThreshold() - Method in class groovyx.gpars.extra166y.AbstractParallelAnyArray: Returns size threshold for splitting into subtask.
concurrentExceptions - Variable in exception groovyx.gpars.AsyncException
configuredPoolSize - Variable in class groovyx.gpars.scheduler.FJPool
connect(LocalNode) - Method in class groovyx.gpars.remote.LocalHost: Connect local node to the provider
connect(LocalNode) - Static method in class groovyx.gpars.remote.LocalHostRegistry
connect() - Method in class groovyx.gpars.remote.LocalNode
connect(LocalHost) - Method in class groovyx.gpars.remote.LocalNode
connect(LocalNode) - Method in class groovyx.gpars.remote.RemoteHost
connection - Variable in class groovyx.gpars.remote.netty.NettyHandler
connection - Variable in class groovyx.gpars.remote.netty.RemoteObjectDecoder
connection - Variable in class groovyx.gpars.remote.netty.RemoteObjectEncoder
connections - Variable in class groovyx.gpars.remote.RemoteHost
connectRemoteNode(UUID, SerialContext, Actor) - Method in class groovyx.gpars.remote.LocalHost
contains(Object) - Method in class groovyx.gpars.dataflow.Dataflows: Checks whether a certain key is contained in the map.
contains(Object) - Method in class groovyx.gpars.extra166y.CustomConcurrentHashMap.EntrySet
contains(Object) - Method in class groovyx.gpars.extra166y.CustomConcurrentHashMap.KeySet: Returns true if this set contains an element equivalent to the given element with respect to this set's Equivalence.
contains(Object) - Method in class groovyx.gpars.extra166y.CustomConcurrentHashMap.KeySetView
contains(Object) - Method in class groovyx.gpars.extra166y.CustomConcurrentHashMap.Values
contains(Object) - Method in class groovyx.gpars.extra166y.ParallelArray.AsList
contains(Object) - Method in class groovyx.gpars.extra166y.ParallelDoubleArray.AsList
contains(Object) - Method in class groovyx.gpars.extra166y.ParallelLongArray.AsList
containsKey(Object) - Method in class groovyx.gpars.extra166y.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 class groovyx.gpars.extra166y.CustomConcurrentHashMap: Returns true if this map maps one or more keys to a value equivalent to the given value with respect to this map's value Equivalence.
content - Variable in class groovyx.gpars.pa.CombineHolder
context - Variable in class groovyx.gpars.serial.SerialHandle: local host
continueProcessingMessages() - Method in class groovyx.gpars.util.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<Object>, int, Object) - Method in class groovyx.gpars.dataflow.operator.component.GracefulShutdownListener: Entering a non-idle state, so a notification needs to be sent to the monitor.
controlMessageArrived(DataflowProcessor, DataflowReadChannel<Object>, int, Object) - Method in class groovyx.gpars.dataflow.operator.DataflowEventAdapter: Invoked when a control message (instances of ControlMessage) becomes available in an input channel.
controlMessageArrived(DataflowProcessor, DataflowReadChannel<Object>, int, Object) - Method in interface groovyx.gpars.dataflow.operator.DataflowEventListener: Invoked when a control message (instances of ControlMessage) becomes available in an input channel.
copy - Variable in class groovyx.gpars.agent.AgentBase: Function converting the internal state during read to prevent internal state escape from the protected boundary of the agent
CopyChannelsClosure<V> - Class in groovyx.gpars.dataflow.operator: Used by the chainWith() method to wrap the supplied closure inside the operator's body.
CopyChannelsClosure() - Constructor for class groovyx.gpars.dataflow.operator.CopyChannelsClosure
copyDFV(Queue<DataflowVariable<T>>, Queue<DataflowVariable<T>>) - Method in class groovyx.gpars.dataflow.DataflowQueue
core - Variable in class groovyx.gpars.actor.AbstractLoopingActor: Holds the particular instance of async messaging core to use
core - Variable in class groovyx.gpars.agent.AgentCore
count - Variable in class groovyx.gpars.dataflow.expression.DataflowExpression.DataflowExpressionsCollector
count - Variable in class groovyx.gpars.extra166y.CustomConcurrentHashMap.Segment
count - Variable in class groovyx.gpars.extra166y.PAS.FJCountSelected
count - Variable in class groovyx.gpars.extra166y.PAS.FJDUniquifier
count - Variable in class groovyx.gpars.extra166y.PAS.FJLUniquifier
count - Variable in class groovyx.gpars.extra166y.PAS.FJOUniquifier
count - Variable in class groovyx.gpars.extra166y.PAS.FJRemoveAll
count - Variable in class groovyx.gpars.extra166y.PAS.FJSelectAll
countDown() - Method in class groovyx.gpars.dataflow.impl.ResizeableCountDownLatch: Decrements the count of the latch, releasing all waiting threads if the count reaches zero.
countDown() - Method in class groovyx.gpars.dataflow.operator.CountingPoisonPill
countDown() - Method in class groovyx.gpars.dataflow.operator.ImmediateCountingPoisonPill
countDown() - Method in class groovyx.gpars.dataflow.operator.PoisonPill
countDown() - Method in class groovyx.gpars.dataflow.operator.PoisonTrackCounter
counter - Variable in class groovyx.gpars.dataflow.operator.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 for class groovyx.gpars.dataflow.operator.CountingPoisonPill: Creates a non-immediate instance that could be used to stop operators in a network.
countInputChannels(Map) - Static method in class groovyx.gpars.dataflow.operator.DataflowOperator
countInputChannels(Map) - Static method in class groovyx.gpars.dataflow.operator.DataflowSelector
countParallel(Collection, Object) - Static method in class groovyx.gpars.GParsPoolUtil: Creates a Parallel Array out of the supplied collection/object and invokes the withFilter() method using the supplied rule as the filter predicate.
countParallel(Object, Object) - Static method in class groovyx.gpars.GParsPoolUtil: Creates a Parallel Array out of the supplied collection/object and invokes the withFilter() method using the supplied rule as the filter predicate.
countParallel(Collection, Closure) - Static method in class groovyx.gpars.GParsPoolUtil: Creates a Parallel Array out of the supplied collection/object and invokes the withFilter() method using the supplied rule as the filter predicate.
countParallel(Object, Closure) - Static method in class groovyx.gpars.GParsPoolUtil: Creates a Parallel Array out of the supplied collection/object and invokes the withFilter() method using the supplied rule as the filter predicate.
create(Object) - Static method in class groovyx.gpars.activeobject.InternalActor
create(int, Class<? super T>, ForkJoinPool) - Static method in class groovyx.gpars.extra166y.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) - Static method in class groovyx.gpars.extra166y.ParallelDoubleArray: Creates a new ParallelDoubleArray using the given executor and an array of the given size.
create(int, ForkJoinPool) - Static method in class groovyx.gpars.extra166y.ParallelLongArray: Creates a new ParallelLongArray using the given executor and an array of the given size.
create(WithSerialId, UUID) - Static method in class groovyx.gpars.serial.SerialHandle
createActorMessage(Object) - Method in class groovyx.gpars.actor.Actor
createArray(CharSequence) - Static method in class groovyx.gpars.util.PAUtils
createArray(Map<K, V>) - Static method in class groovyx.gpars.util.PAUtils
createCollection(Iterable<T>) - Static method in class groovyx.gpars.util.PAUtils
createCollection(Iterator<T>) - Static method in class groovyx.gpars.util.PAUtils
createComparator(Closure<Object>) - Static method in class groovyx.gpars.util.PAUtils: Builds a comparator depending on the number of arguments accepted by the supplied closure.
createEmpty(int, Class<? super T>, ForkJoinPool) - Static method in class groovyx.gpars.extra166y.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() operations.
createEmpty(int, ForkJoinPool) - Static method in class groovyx.gpars.extra166y.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() operations.
createEmpty(int, ForkJoinPool) - Static method in class groovyx.gpars.extra166y.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() operations.
createEventManager() - Method in class groovyx.gpars.dataflow.expression.DataflowExpression
createFromCopy(T[], ForkJoinPool) - Static method in class groovyx.gpars.extra166y.ParallelArray: Creates a new ParallelArray using the given executor and initially holding copies of the given source elements.
createFromCopy(int, T[], ForkJoinPool) - Static method in class groovyx.gpars.extra166y.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(double[], ForkJoinPool) - Static method in class groovyx.gpars.extra166y.ParallelDoubleArray: Creates a new ParallelDoubleArray using the given executor and initially holding copies of the given source elements.
createFromCopy(int, double[], ForkJoinPool) - Static method in class groovyx.gpars.extra166y.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(long[], ForkJoinPool) - Static method in class groovyx.gpars.extra166y.ParallelLongArray: Creates a new ParallelLongArray using the given executor and initially holding copies of the given source elements.
createFromCopy(int, long[], ForkJoinPool) - Static method in class groovyx.gpars.extra166y.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(Pool) - Static method in class groovyx.gpars.group.PGroupBuilder: Builds a PGroup instance from a Pool instance
createFromPool(ForkJoinPool) - Static method in class groovyx.gpars.group.PGroupBuilder: Builds a PGroup instance from a ForkJoinPool instance
createFromPool(ThreadPoolExecutor) - Static method in class groovyx.gpars.group.PGroupBuilder: Builds a PGroup instance from a ThreadPoolExecutor instance
createGroupByClosure(Closure<K>, ConcurrentMap<K, List<T>>) - Static method in class groovyx.gpars.util.PAUtils: Creates a closure that will insert elements in the appropriate group
createNewStream() - Method in class groovyx.gpars.dataflow.stream.DataflowStream: A factory method to create new instances of the correct class when needed
createNewStream() - Method in class groovyx.gpars.dataflow.stream.StreamCore: A factory method to create new instances of the correct class when needed
createNewStream() - Method in class groovyx.gpars.dataflow.stream.SyncDataflowStream: A factory method to create new instances of the correct class when needed
createObject(SerialContext) - Method in class groovyx.gpars.actor.Actor.MyRemoteHandle
createObject(SerialContext) - Method in class groovyx.gpars.serial.DefaultRemoteHandle
createObject(SerialContext) - Method in class groovyx.gpars.serial.RemoteHandle
createPA(Map<K, V>, ForkJoinPool) - Static method in class groovyx.gpars.GParsPoolUtil
createPool(boolean, int) - Static method in class groovyx.gpars.scheduler.DefaultPool: Creates a fixed-thread pool of given size.
createPool(int) - Static method in class groovyx.gpars.scheduler.FJPool: Creates a fork/join pool of given size.
createPool() - Method in interface groovyx.gpars.util.PoolFactory
createPool(boolean) - Method in interface groovyx.gpars.util.PoolFactory
createPool(int) - Method in interface groovyx.gpars.util.PoolFactory
createPool(boolean, int) - Method in interface groovyx.gpars.util.PoolFactory
createReadChannel() - Method in class groovyx.gpars.dataflow.DataflowBroadcast: Retrieves an implementation of DataflowReadChannel to read all messages submitted to the broadcast chanel.
createReadChannel() - Method in class groovyx.gpars.dataflow.SyncDataflowBroadcast: Retrieves an implementation of DataflowReadChannel to read all messages submitted to the broadcast chanel.
createRemoteHandle(SerialHandle, SerialContext) - Method in class groovyx.gpars.actor.Actor
createRemoteHandle(SerialHandle, SerialContext) - Method in class groovyx.gpars.serial.WithSerialId
createResizeablePool(boolean, int) - Static method in class groovyx.gpars.scheduler.ResizeablePool: Creates a fixed-thread pool of given size.
createResults(int) - Method in class groovyx.gpars.extra166y.PAS.FJDAppendAllDriver
createResults(int) - Method in class groovyx.gpars.extra166y.PAS.FJDSelectAllDriver
createResults(int) - Method in class groovyx.gpars.extra166y.PAS.FJLAppendAllDriver
createResults(int) - Method in class groovyx.gpars.extra166y.PAS.FJLSelectAllDriver
createResults(int) - Method in class groovyx.gpars.extra166y.PAS.FJOAppendAllDriver
createResults(int) - Method in class groovyx.gpars.extra166y.PAS.FJOSelectAllDriver
createResults(int) - Method in class groovyx.gpars.extra166y.PAS.FJSelectAllDriver
createSDAClosure(StaticDispatchActor<T>) - Static method in class groovyx.gpars.actor.impl.SDAClosure: Creates the closure for a given SDA
createThreadName() - Static method in class groovyx.gpars.scheduler.DefaultPool: Created a JVM-unique name for Actors' threads.
createTimeout(long) - Static method in class groovyx.gpars.dataflow.Select: Creates a timeout channel (DataflowVariable) that will bind a Select.TIMEOUT value after the specified timeout.
createTimer(String, boolean) - Method in interface groovyx.gpars.util.TimerFactory
createTxnExecutor() - Static method in class groovyx.gpars.stm.GParsStm: A factory method to create custom atomic blocks.
createTxnExecutor(Map<String, Object>) - Static method in class groovyx.gpars.stm.GParsStm: A factory method to create custom atomic blocks allowing the caller to set desired transactional characteristics.
createUsingHandoff(T[], ForkJoinPool) - Static method in class groovyx.gpars.extra166y.ParallelArray: Creates a new ParallelArray initially using the given array and executor.
createUsingHandoff(double[], ForkJoinPool) - Static method in class groovyx.gpars.extra166y.ParallelDoubleArray: Creates a new ParallelDoubleArray initially using the given array and executor.
createUsingHandoff(long[], ForkJoinPool) - Static method in class groovyx.gpars.extra166y.ParallelLongArray: Creates a new ParallelLongArray initially using the given array and executor.
createVariable() - Method in class groovyx.gpars.dataflow.DataflowQueue: Creates a new variable to perform the next data exchange
createVariable() - Method in class groovyx.gpars.dataflow.SyncDataflowQueue: Creates a new variable to perform the next data exchange
cumulate(Ops.DoubleReducer, double) - Method in class groovyx.gpars.extra166y.AbstractParallelAnyArray.DUPap
cumulate(Ops.LongReducer, long) - Method in class groovyx.gpars.extra166y.AbstractParallelAnyArray.LUPap
cumulate(Ops.Reducer<T>, T) - Method in class groovyx.gpars.extra166y.AbstractParallelAnyArray.OUPap
cumulate(Ops.Reducer<T>, T) - Method in class groovyx.gpars.extra166y.ParallelArray: Replaces each element with the running cumulation of applying the given reducer.
cumulate(Ops.Reducer<T>, T) - Method in class groovyx.gpars.extra166y.ParallelArrayWithBounds: Replaces each element with the running cumulation of applying the given reducer.
cumulate(Ops.DoubleReducer, double) - Method in class groovyx.gpars.extra166y.ParallelDoubleArray: Replaces each element with the running cumulation of applying the given reducer.
cumulate(Ops.DoubleReducer, double) - Method in class groovyx.gpars.extra166y.ParallelDoubleArrayWithBounds: Replaces each element with the running cumulation of applying the given reducer.
cumulate(Ops.LongReducer, long) - Method in class groovyx.gpars.extra166y.ParallelLongArray: Replaces each element with the running cumulation of applying the given reducer.
cumulate(Ops.LongReducer, long) - Method in class groovyx.gpars.extra166y.ParallelLongArrayWithBounds: Replaces each element with the running cumulation of applying the given reducer.
CUMULATE - Static variable in class groovyx.gpars.extra166y.PAS.FJScan
cumulateLeaf(int, int, PAS.FJScan) - Method in class groovyx.gpars.extra166y.PAS.FJDCumulateOp
cumulateLeaf(int, int, PAS.FJScan) - Method in class groovyx.gpars.extra166y.PAS.FJDCumulatePlusOp
cumulateLeaf(int, int, PAS.FJScan) - Method in class groovyx.gpars.extra166y.PAS.FJDPrecumulateOp
cumulateLeaf(int, int, PAS.FJScan) - Method in class groovyx.gpars.extra166y.PAS.FJDPrecumulatePlusOp
cumulateLeaf(int, int, PAS.FJScan) - Method in class groovyx.gpars.extra166y.PAS.FJLCumulateOp
cumulateLeaf(int, int, PAS.FJScan) - Method in class groovyx.gpars.extra166y.PAS.FJLCumulatePlusOp
cumulateLeaf(int, int, PAS.FJScan) - Method in class groovyx.gpars.extra166y.PAS.FJLPrecumulateOp
cumulateLeaf(int, int, PAS.FJScan) - Method in class groovyx.gpars.extra166y.PAS.FJLPrecumulatePlusOp
cumulateLeaf(int, int, PAS.FJScan) - Method in class groovyx.gpars.extra166y.PAS.FJOCumulateOp
cumulateLeaf(int, int, PAS.FJScan) - Method in class groovyx.gpars.extra166y.PAS.FJOPrecumulateOp
cumulateLeaf(int, int, PAS.FJScan) - Method in class groovyx.gpars.extra166y.PAS.FJScanOp
cumulateSum() - Method in class groovyx.gpars.extra166y.AbstractParallelAnyArray.DUPap
cumulateSum() - Method in class groovyx.gpars.extra166y.AbstractParallelAnyArray.LUPap
cumulateSum() - Method in class groovyx.gpars.extra166y.ParallelDoubleArray: Replaces each element with the running sum.
cumulateSum() - Method in class groovyx.gpars.extra166y.ParallelDoubleArrayWithBounds: Replaces each element with the running sum.
cumulateSum() - Method in class groovyx.gpars.extra166y.ParallelLongArray: Replaces each element with the running sum.
cumulateSum() - Method in class groovyx.gpars.extra166y.ParallelLongArrayWithBounds: Replaces each element with the running sum.
current - Variable in class groovyx.gpars.dataflow.stream.FListIterator
currentActorPerThread - Static variable in class groovyx.gpars.actor.Actor: Maps each thread to the actor it currently processes.
currentSender - Variable in class groovyx.gpars.actor.AbstractLoopingActor
currentTable - Variable in class groovyx.gpars.extra166y.CustomConcurrentHashMap.HashIterator
currentThread - Variable in class groovyx.gpars.actor.Actor
currentThread - Variable in class groovyx.gpars.agent.AgentCore
currentTimerTask - Variable in class groovyx.gpars.actor.AbstractLoopingActor
cursor - Variable in class groovyx.gpars.extra166y.AbstractParallelAnyArray.FilteredAsDoubleIterator
cursor - Variable in class groovyx.gpars.extra166y.AbstractParallelAnyArray.FilteredAsLongIterator
cursor - Variable in class groovyx.gpars.extra166y.AbstractParallelAnyArray.FilteredIterator
cursor - Variable in class groovyx.gpars.extra166y.AbstractParallelAnyArray.UnfilteredAsDoubleIterator
cursor - Variable in class groovyx.gpars.extra166y.AbstractParallelAnyArray.UnfilteredAsLongIterator
cursor - Variable in class groovyx.gpars.extra166y.AbstractParallelAnyArray.UnfilteredIterator
cursor - Variable in class groovyx.gpars.extra166y.ParallelArray.ListIter
cursor - Variable in class groovyx.gpars.extra166y.ParallelArray.ParallelArrayIterator
cursor - Variable in class groovyx.gpars.extra166y.ParallelDoubleArray.ListIter
cursor - Variable in class groovyx.gpars.extra166y.ParallelDoubleArray.ParallelDoubleArrayIterator
cursor - Variable in class groovyx.gpars.extra166y.ParallelLongArray.ListIter
cursor - Variable in class groovyx.gpars.extra166y.ParallelLongArray.ParallelLongArrayIterator
CustomConcurrentHashMap<K,V> - 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(String, CustomConcurrentHashMap.Equivalence<? super K>, String, CustomConcurrentHashMap.Equivalence<? super V>, int) - Constructor for class groovyx.gpars.extra166y.CustomConcurrentHashMap: Internal constructor to set factory, equivalences and segment capacities, and to create segments array.
CustomConcurrentHashMap(CustomConcurrentHashMap.Strength, CustomConcurrentHashMap.Equivalence<? super K>, CustomConcurrentHashMap.Strength, CustomConcurrentHashMap.Equivalence<? super V>, int) - Constructor for class groovyx.gpars.extra166y.CustomConcurrentHashMap: Creates a new CustomConcurrentHashMap with the given parameters.
CustomConcurrentHashMap() - Constructor for class groovyx.gpars.extra166y.CustomConcurrentHashMap: Creates a new CustomConcurrentHashMap with strong keys and values, and equality-based equivalence.
CustomConcurrentHashMap.EmbeddedSoftReference - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.EmbeddedSoftReference(Object, CustomConcurrentHashMap.Reclaimable) - Constructor for class groovyx.gpars.extra166y.CustomConcurrentHashMap.EmbeddedSoftReference
CustomConcurrentHashMap.EmbeddedWeakReference - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.EmbeddedWeakReference(Object, CustomConcurrentHashMap.Reclaimable) - Constructor for class groovyx.gpars.extra166y.CustomConcurrentHashMap.EmbeddedWeakReference
CustomConcurrentHashMap.EntryIterator - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.EntryIterator() - Constructor for class groovyx.gpars.extra166y.CustomConcurrentHashMap.EntryIterator
CustomConcurrentHashMap.EntrySet - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.EntrySet() - Constructor for class groovyx.gpars.extra166y.CustomConcurrentHashMap.EntrySet
CustomConcurrentHashMap.Equivalence<K> - 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 for class groovyx.gpars.extra166y.CustomConcurrentHashMap.EquivalenceUsingEquals
CustomConcurrentHashMap.EquivalenceUsingIdentity - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.EquivalenceUsingIdentity() - Constructor for class groovyx.gpars.extra166y.CustomConcurrentHashMap.EquivalenceUsingIdentity
CustomConcurrentHashMap.HashIterator - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.HashIterator() - Constructor for class groovyx.gpars.extra166y.CustomConcurrentHashMap.HashIterator
CustomConcurrentHashMap.IntKeyIntValueNode - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.IntKeyIntValueNode(int, Object, Object) - Constructor for class groovyx.gpars.extra166y.CustomConcurrentHashMap.IntKeyIntValueNode
CustomConcurrentHashMap.IntKeyIntValueNodeFactory - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.IntKeyIntValueNodeFactory() - Constructor for class groovyx.gpars.extra166y.CustomConcurrentHashMap.IntKeyIntValueNodeFactory
CustomConcurrentHashMap.IntKeyNode - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.IntKeyNode(int, Object) - Constructor for class groovyx.gpars.extra166y.CustomConcurrentHashMap.IntKeyNode
CustomConcurrentHashMap.IntKeySelfValueNode - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.IntKeySelfValueNode(int, Object) - Constructor for class groovyx.gpars.extra166y.CustomConcurrentHashMap.IntKeySelfValueNode
CustomConcurrentHashMap.IntKeySelfValueNodeFactory - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.IntKeySelfValueNodeFactory() - Constructor for class groovyx.gpars.extra166y.CustomConcurrentHashMap.IntKeySelfValueNodeFactory
CustomConcurrentHashMap.IntKeySoftValueNode - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.IntKeySoftValueNode(int, Object, Object, CustomConcurrentHashMap) - Constructor for class groovyx.gpars.extra166y.CustomConcurrentHashMap.IntKeySoftValueNode
CustomConcurrentHashMap.IntKeySoftValueNodeFactory - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.IntKeySoftValueNodeFactory() - Constructor for class groovyx.gpars.extra166y.CustomConcurrentHashMap.IntKeySoftValueNodeFactory
CustomConcurrentHashMap.IntKeyStrongValueNode - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.IntKeyStrongValueNode(int, Object, Object) - Constructor for class groovyx.gpars.extra166y.CustomConcurrentHashMap.IntKeyStrongValueNode
CustomConcurrentHashMap.IntKeyStrongValueNodeFactory - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.IntKeyStrongValueNodeFactory() - Constructor for class groovyx.gpars.extra166y.CustomConcurrentHashMap.IntKeyStrongValueNodeFactory
CustomConcurrentHashMap.IntKeyWeakValueNode - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.IntKeyWeakValueNode(int, Object, Object, CustomConcurrentHashMap) - Constructor for class groovyx.gpars.extra166y.CustomConcurrentHashMap.IntKeyWeakValueNode
CustomConcurrentHashMap.IntKeyWeakValueNodeFactory - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.IntKeyWeakValueNodeFactory() - Constructor for class groovyx.gpars.extra166y.CustomConcurrentHashMap.IntKeyWeakValueNodeFactory
CustomConcurrentHashMap.KeyIterator - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.KeyIterator() - Constructor for class groovyx.gpars.extra166y.CustomConcurrentHashMap.KeyIterator
CustomConcurrentHashMap.KeySet<K> - Class in groovyx.gpars.extra166y: A hash-based set with properties identical to those of Collections.newSetFromMap applied to a CustomConcurrentHashMap, but possibly more space-efficient.
CustomConcurrentHashMap.KeySet(CustomConcurrentHashMap.Strength, CustomConcurrentHashMap.Equivalence<? super K>, int) - Constructor for class groovyx.gpars.extra166y.CustomConcurrentHashMap.KeySet: Creates a set with the given parameters.
CustomConcurrentHashMap.KeySetView - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.KeySetView() - Constructor for class groovyx.gpars.extra166y.CustomConcurrentHashMap.KeySetView
CustomConcurrentHashMap.LinkedIntKeyIntValueNode - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.LinkedIntKeyIntValueNode(int, Object, Object, CustomConcurrentHashMap.Node) - Constructor for class groovyx.gpars.extra166y.CustomConcurrentHashMap.LinkedIntKeyIntValueNode
CustomConcurrentHashMap.LinkedIntKeySelfValueNode - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.LinkedIntKeySelfValueNode(int, Object, CustomConcurrentHashMap.Node) - Constructor for class groovyx.gpars.extra166y.CustomConcurrentHashMap.LinkedIntKeySelfValueNode
CustomConcurrentHashMap.LinkedIntKeySoftValueNode - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.LinkedIntKeySoftValueNode(int, Object, Object, CustomConcurrentHashMap, CustomConcurrentHashMap.Node) - Constructor for class groovyx.gpars.extra166y.CustomConcurrentHashMap.LinkedIntKeySoftValueNode
CustomConcurrentHashMap.LinkedIntKeyStrongValueNode - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.LinkedIntKeyStrongValueNode(int, Object, Object, CustomConcurrentHashMap.Node) - Constructor for class groovyx.gpars.extra166y.CustomConcurrentHashMap.LinkedIntKeyStrongValueNode
CustomConcurrentHashMap.LinkedIntKeyWeakValueNode - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.LinkedIntKeyWeakValueNode(int, Object, Object, CustomConcurrentHashMap, CustomConcurrentHashMap.Node) - Constructor for class groovyx.gpars.extra166y.CustomConcurrentHashMap.LinkedIntKeyWeakValueNode
CustomConcurrentHashMap.LinkedSoftKeyIntValueNode - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.LinkedSoftKeyIntValueNode(int, Object, Object, CustomConcurrentHashMap, CustomConcurrentHashMap.Node) - Constructor for class groovyx.gpars.extra166y.CustomConcurrentHashMap.LinkedSoftKeyIntValueNode
CustomConcurrentHashMap.LinkedSoftKeySelfValueNode - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.LinkedSoftKeySelfValueNode(int, Object, CustomConcurrentHashMap, CustomConcurrentHashMap.Node) - Constructor for class groovyx.gpars.extra166y.CustomConcurrentHashMap.LinkedSoftKeySelfValueNode
CustomConcurrentHashMap.LinkedSoftKeySoftValueNode - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.LinkedSoftKeySoftValueNode(int, Object, Object, CustomConcurrentHashMap, CustomConcurrentHashMap.Node) - Constructor for class groovyx.gpars.extra166y.CustomConcurrentHashMap.LinkedSoftKeySoftValueNode
CustomConcurrentHashMap.LinkedSoftKeyStrongValueNode - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.LinkedSoftKeyStrongValueNode(int, Object, Object, CustomConcurrentHashMap, CustomConcurrentHashMap.Node) - Constructor for class groovyx.gpars.extra166y.CustomConcurrentHashMap.LinkedSoftKeyStrongValueNode
CustomConcurrentHashMap.LinkedSoftKeyWeakValueNode - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.LinkedSoftKeyWeakValueNode(int, Object, Object, CustomConcurrentHashMap, CustomConcurrentHashMap.Node) - Constructor for class groovyx.gpars.extra166y.CustomConcurrentHashMap.LinkedSoftKeyWeakValueNode
CustomConcurrentHashMap.LinkedStrongKeyIntValueNode - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.LinkedStrongKeyIntValueNode(int, Object, Object, CustomConcurrentHashMap.Node) - Constructor for class groovyx.gpars.extra166y.CustomConcurrentHashMap.LinkedStrongKeyIntValueNode
CustomConcurrentHashMap.LinkedStrongKeySelfValueNode - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.LinkedStrongKeySelfValueNode(int, Object, CustomConcurrentHashMap.Node) - Constructor for class groovyx.gpars.extra166y.CustomConcurrentHashMap.LinkedStrongKeySelfValueNode
CustomConcurrentHashMap.LinkedStrongKeySoftValueNode - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.LinkedStrongKeySoftValueNode(int, Object, Object, CustomConcurrentHashMap, CustomConcurrentHashMap.Node) - Constructor for class groovyx.gpars.extra166y.CustomConcurrentHashMap.LinkedStrongKeySoftValueNode
CustomConcurrentHashMap.LinkedStrongKeyStrongValueNode - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.LinkedStrongKeyStrongValueNode(int, Object, Object, CustomConcurrentHashMap.Node) - Constructor for class groovyx.gpars.extra166y.CustomConcurrentHashMap.LinkedStrongKeyStrongValueNode
CustomConcurrentHashMap.LinkedStrongKeyWeakValueNode - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.LinkedStrongKeyWeakValueNode(int, Object, Object, CustomConcurrentHashMap, CustomConcurrentHashMap.Node) - Constructor for class groovyx.gpars.extra166y.CustomConcurrentHashMap.LinkedStrongKeyWeakValueNode
CustomConcurrentHashMap.LinkedWeakKeyIntValueNode - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.LinkedWeakKeyIntValueNode(int, Object, Object, CustomConcurrentHashMap, CustomConcurrentHashMap.Node) - Constructor for class groovyx.gpars.extra166y.CustomConcurrentHashMap.LinkedWeakKeyIntValueNode
CustomConcurrentHashMap.LinkedWeakKeySelfValueNode - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.LinkedWeakKeySelfValueNode(int, Object, CustomConcurrentHashMap, CustomConcurrentHashMap.Node) - Constructor for class groovyx.gpars.extra166y.CustomConcurrentHashMap.LinkedWeakKeySelfValueNode
CustomConcurrentHashMap.LinkedWeakKeySoftValueNode - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.LinkedWeakKeySoftValueNode(int, Object, Object, CustomConcurrentHashMap, CustomConcurrentHashMap.Node) - Constructor for class groovyx.gpars.extra166y.CustomConcurrentHashMap.LinkedWeakKeySoftValueNode
CustomConcurrentHashMap.LinkedWeakKeyStrongValueNode - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.LinkedWeakKeyStrongValueNode(int, Object, Object, CustomConcurrentHashMap, CustomConcurrentHashMap.Node) - Constructor for class groovyx.gpars.extra166y.CustomConcurrentHashMap.LinkedWeakKeyStrongValueNode
CustomConcurrentHashMap.LinkedWeakKeyWeakValueNode - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.LinkedWeakKeyWeakValueNode(int, Object, Object, CustomConcurrentHashMap, CustomConcurrentHashMap.Node) - Constructor for class groovyx.gpars.extra166y.CustomConcurrentHashMap.LinkedWeakKeyWeakValueNode
CustomConcurrentHashMap.MappingFunction<K,V> - 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 ReferenceQueue
CustomConcurrentHashMap.ReclamationThread - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.ReclamationThread(ReferenceQueue<Object>) - Constructor for class groovyx.gpars.extra166y.CustomConcurrentHashMap.ReclamationThread
CustomConcurrentHashMap.RemappingFunction<K,V> - 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 for class groovyx.gpars.extra166y.CustomConcurrentHashMap.Segment
CustomConcurrentHashMap.SoftKeyIntValueNode - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.SoftKeyIntValueNode(int, Object, Object, CustomConcurrentHashMap) - Constructor for class groovyx.gpars.extra166y.CustomConcurrentHashMap.SoftKeyIntValueNode
CustomConcurrentHashMap.SoftKeyIntValueNodeFactory - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.SoftKeyIntValueNodeFactory() - Constructor for class groovyx.gpars.extra166y.CustomConcurrentHashMap.SoftKeyIntValueNodeFactory
CustomConcurrentHashMap.SoftKeyNode - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.SoftKeyNode(int, Object, CustomConcurrentHashMap) - Constructor for class groovyx.gpars.extra166y.CustomConcurrentHashMap.SoftKeyNode
CustomConcurrentHashMap.SoftKeySelfValueNode - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.SoftKeySelfValueNode(int, Object, CustomConcurrentHashMap) - Constructor for class groovyx.gpars.extra166y.CustomConcurrentHashMap.SoftKeySelfValueNode
CustomConcurrentHashMap.SoftKeySelfValueNodeFactory - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.SoftKeySelfValueNodeFactory() - Constructor for class groovyx.gpars.extra166y.CustomConcurrentHashMap.SoftKeySelfValueNodeFactory
CustomConcurrentHashMap.SoftKeySoftValueNode - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.SoftKeySoftValueNode(int, Object, Object, CustomConcurrentHashMap) - Constructor for class groovyx.gpars.extra166y.CustomConcurrentHashMap.SoftKeySoftValueNode
CustomConcurrentHashMap.SoftKeySoftValueNodeFactory - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.SoftKeySoftValueNodeFactory() - Constructor for class groovyx.gpars.extra166y.CustomConcurrentHashMap.SoftKeySoftValueNodeFactory
CustomConcurrentHashMap.SoftKeyStrongValueNode - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.SoftKeyStrongValueNode(int, Object, Object, CustomConcurrentHashMap) - Constructor for class groovyx.gpars.extra166y.CustomConcurrentHashMap.SoftKeyStrongValueNode
CustomConcurrentHashMap.SoftKeyStrongValueNodeFactory - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.SoftKeyStrongValueNodeFactory() - Constructor for class groovyx.gpars.extra166y.CustomConcurrentHashMap.SoftKeyStrongValueNodeFactory
CustomConcurrentHashMap.SoftKeyWeakValueNode - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.SoftKeyWeakValueNode(int, Object, Object, CustomConcurrentHashMap) - Constructor for class groovyx.gpars.extra166y.CustomConcurrentHashMap.SoftKeyWeakValueNode
CustomConcurrentHashMap.SoftKeyWeakValueNodeFactory - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.SoftKeyWeakValueNodeFactory() - Constructor for class groovyx.gpars.extra166y.CustomConcurrentHashMap.SoftKeyWeakValueNodeFactory
CustomConcurrentHashMap.Strength - Enum in groovyx.gpars.extra166y: The strength of keys and values that may be held by maps.
CustomConcurrentHashMap.Strength(String) - Constructor for enum groovyx.gpars.extra166y.CustomConcurrentHashMap.Strength
CustomConcurrentHashMap.StrongKeyIntValueNode - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.StrongKeyIntValueNode(int, Object, Object) - Constructor for class groovyx.gpars.extra166y.CustomConcurrentHashMap.StrongKeyIntValueNode
CustomConcurrentHashMap.StrongKeyIntValueNodeFactory - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.StrongKeyIntValueNodeFactory() - Constructor for class groovyx.gpars.extra166y.CustomConcurrentHashMap.StrongKeyIntValueNodeFactory
CustomConcurrentHashMap.StrongKeyNode - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.StrongKeyNode(int, Object) - Constructor for class groovyx.gpars.extra166y.CustomConcurrentHashMap.StrongKeyNode
CustomConcurrentHashMap.StrongKeySelfValueNode - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.StrongKeySelfValueNode(int, Object) - Constructor for class groovyx.gpars.extra166y.CustomConcurrentHashMap.StrongKeySelfValueNode
CustomConcurrentHashMap.StrongKeySelfValueNodeFactory - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.StrongKeySelfValueNodeFactory() - Constructor for class groovyx.gpars.extra166y.CustomConcurrentHashMap.StrongKeySelfValueNodeFactory
CustomConcurrentHashMap.StrongKeySoftValueNode - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.StrongKeySoftValueNode(int, Object, Object, CustomConcurrentHashMap) - Constructor for class groovyx.gpars.extra166y.CustomConcurrentHashMap.StrongKeySoftValueNode
CustomConcurrentHashMap.StrongKeySoftValueNodeFactory - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.StrongKeySoftValueNodeFactory() - Constructor for class groovyx.gpars.extra166y.CustomConcurrentHashMap.StrongKeySoftValueNodeFactory
CustomConcurrentHashMap.StrongKeyStrongValueNode - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.StrongKeyStrongValueNode(int, Object, Object) - Constructor for class groovyx.gpars.extra166y.CustomConcurrentHashMap.StrongKeyStrongValueNode
CustomConcurrentHashMap.StrongKeyStrongValueNodeFactory - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.StrongKeyStrongValueNodeFactory() - Constructor for class groovyx.gpars.extra166y.CustomConcurrentHashMap.StrongKeyStrongValueNodeFactory
CustomConcurrentHashMap.StrongKeyWeakValueNode - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.StrongKeyWeakValueNode(int, Object, Object, CustomConcurrentHashMap) - Constructor for class groovyx.gpars.extra166y.CustomConcurrentHashMap.StrongKeyWeakValueNode
CustomConcurrentHashMap.StrongKeyWeakValueNodeFactory - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.StrongKeyWeakValueNodeFactory() - Constructor for class groovyx.gpars.extra166y.CustomConcurrentHashMap.StrongKeyWeakValueNodeFactory
CustomConcurrentHashMap.TerminalIntKeyIntValueNode - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.TerminalIntKeyIntValueNode(int, Object, Object) - Constructor for class groovyx.gpars.extra166y.CustomConcurrentHashMap.TerminalIntKeyIntValueNode
CustomConcurrentHashMap.TerminalIntKeySelfValueNode - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.TerminalIntKeySelfValueNode(int, Object) - Constructor for class groovyx.gpars.extra166y.CustomConcurrentHashMap.TerminalIntKeySelfValueNode
CustomConcurrentHashMap.TerminalIntKeySoftValueNode - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.TerminalIntKeySoftValueNode(int, Object, Object, CustomConcurrentHashMap) - Constructor for class groovyx.gpars.extra166y.CustomConcurrentHashMap.TerminalIntKeySoftValueNode
CustomConcurrentHashMap.TerminalIntKeyStrongValueNode - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.TerminalIntKeyStrongValueNode(int, Object, Object) - Constructor for class groovyx.gpars.extra166y.CustomConcurrentHashMap.TerminalIntKeyStrongValueNode
CustomConcurrentHashMap.TerminalIntKeyWeakValueNode - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.TerminalIntKeyWeakValueNode(int, Object, Object, CustomConcurrentHashMap) - Constructor for class groovyx.gpars.extra166y.CustomConcurrentHashMap.TerminalIntKeyWeakValueNode
CustomConcurrentHashMap.TerminalSoftKeyIntValueNode - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.TerminalSoftKeyIntValueNode(int, Object, Object, CustomConcurrentHashMap) - Constructor for class groovyx.gpars.extra166y.CustomConcurrentHashMap.TerminalSoftKeyIntValueNode
CustomConcurrentHashMap.TerminalSoftKeySelfValueNode - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.TerminalSoftKeySelfValueNode(int, Object, CustomConcurrentHashMap) - Constructor for class groovyx.gpars.extra166y.CustomConcurrentHashMap.TerminalSoftKeySelfValueNode
CustomConcurrentHashMap.TerminalSoftKeySoftValueNode - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.TerminalSoftKeySoftValueNode(int, Object, Object, CustomConcurrentHashMap) - Constructor for class groovyx.gpars.extra166y.CustomConcurrentHashMap.TerminalSoftKeySoftValueNode
CustomConcurrentHashMap.TerminalSoftKeyStrongValueNode - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.TerminalSoftKeyStrongValueNode(int, Object, Object, CustomConcurrentHashMap) - Constructor for class groovyx.gpars.extra166y.CustomConcurrentHashMap.TerminalSoftKeyStrongValueNode
CustomConcurrentHashMap.TerminalSoftKeyWeakValueNode - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.TerminalSoftKeyWeakValueNode(int, Object, Object, CustomConcurrentHashMap) - Constructor for class groovyx.gpars.extra166y.CustomConcurrentHashMap.TerminalSoftKeyWeakValueNode
CustomConcurrentHashMap.TerminalStrongKeyIntValueNode - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.TerminalStrongKeyIntValueNode(int, Object, Object) - Constructor for class groovyx.gpars.extra166y.CustomConcurrentHashMap.TerminalStrongKeyIntValueNode
CustomConcurrentHashMap.TerminalStrongKeySelfValueNode - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.TerminalStrongKeySelfValueNode(int, Object) - Constructor for class groovyx.gpars.extra166y.CustomConcurrentHashMap.TerminalStrongKeySelfValueNode
CustomConcurrentHashMap.TerminalStrongKeySoftValueNode - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.TerminalStrongKeySoftValueNode(int, Object, Object, CustomConcurrentHashMap) - Constructor for class groovyx.gpars.extra166y.CustomConcurrentHashMap.TerminalStrongKeySoftValueNode
CustomConcurrentHashMap.TerminalStrongKeyStrongValueNode - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.TerminalStrongKeyStrongValueNode(int, Object, Object) - Constructor for class groovyx.gpars.extra166y.CustomConcurrentHashMap.TerminalStrongKeyStrongValueNode
CustomConcurrentHashMap.TerminalStrongKeyWeakValueNode - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.TerminalStrongKeyWeakValueNode(int, Object, Object, CustomConcurrentHashMap) - Constructor for class groovyx.gpars.extra166y.CustomConcurrentHashMap.TerminalStrongKeyWeakValueNode
CustomConcurrentHashMap.TerminalWeakKeyIntValueNode - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.TerminalWeakKeyIntValueNode(int, Object, Object, CustomConcurrentHashMap) - Constructor for class groovyx.gpars.extra166y.CustomConcurrentHashMap.TerminalWeakKeyIntValueNode
CustomConcurrentHashMap.TerminalWeakKeySelfValueNode - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.TerminalWeakKeySelfValueNode(int, Object, CustomConcurrentHashMap) - Constructor for class groovyx.gpars.extra166y.CustomConcurrentHashMap.TerminalWeakKeySelfValueNode
CustomConcurrentHashMap.TerminalWeakKeySoftValueNode - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.TerminalWeakKeySoftValueNode(int, Object, Object, CustomConcurrentHashMap) - Constructor for class groovyx.gpars.extra166y.CustomConcurrentHashMap.TerminalWeakKeySoftValueNode
CustomConcurrentHashMap.TerminalWeakKeyStrongValueNode - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.TerminalWeakKeyStrongValueNode(int, Object, Object, CustomConcurrentHashMap) - Constructor for class groovyx.gpars.extra166y.CustomConcurrentHashMap.TerminalWeakKeyStrongValueNode
CustomConcurrentHashMap.TerminalWeakKeyWeakValueNode - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.TerminalWeakKeyWeakValueNode(int, Object, Object, CustomConcurrentHashMap) - Constructor for class groovyx.gpars.extra166y.CustomConcurrentHashMap.TerminalWeakKeyWeakValueNode
CustomConcurrentHashMap.ValueIterator - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.ValueIterator() - Constructor for class groovyx.gpars.extra166y.CustomConcurrentHashMap.ValueIterator
CustomConcurrentHashMap.Values - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.Values() - Constructor for class groovyx.gpars.extra166y.CustomConcurrentHashMap.Values
CustomConcurrentHashMap.WeakKeyIntValueNode - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.WeakKeyIntValueNode(int, Object, Object, CustomConcurrentHashMap) - Constructor for class groovyx.gpars.extra166y.CustomConcurrentHashMap.WeakKeyIntValueNode
CustomConcurrentHashMap.WeakKeyIntValueNodeFactory - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.WeakKeyIntValueNodeFactory() - Constructor for class groovyx.gpars.extra166y.CustomConcurrentHashMap.WeakKeyIntValueNodeFactory
CustomConcurrentHashMap.WeakKeyNode - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.WeakKeyNode(int, Object, CustomConcurrentHashMap) - Constructor for class groovyx.gpars.extra166y.CustomConcurrentHashMap.WeakKeyNode
CustomConcurrentHashMap.WeakKeySelfValueNode - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.WeakKeySelfValueNode(int, Object, CustomConcurrentHashMap) - Constructor for class groovyx.gpars.extra166y.CustomConcurrentHashMap.WeakKeySelfValueNode
CustomConcurrentHashMap.WeakKeySelfValueNodeFactory - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.WeakKeySelfValueNodeFactory() - Constructor for class groovyx.gpars.extra166y.CustomConcurrentHashMap.WeakKeySelfValueNodeFactory
CustomConcurrentHashMap.WeakKeySoftValueNode - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.WeakKeySoftValueNode(int, Object, Object, CustomConcurrentHashMap) - Constructor for class groovyx.gpars.extra166y.CustomConcurrentHashMap.WeakKeySoftValueNode
CustomConcurrentHashMap.WeakKeySoftValueNodeFactory - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.WeakKeySoftValueNodeFactory() - Constructor for class groovyx.gpars.extra166y.CustomConcurrentHashMap.WeakKeySoftValueNodeFactory
CustomConcurrentHashMap.WeakKeyStrongValueNode - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.WeakKeyStrongValueNode(int, Object, Object, CustomConcurrentHashMap) - Constructor for class groovyx.gpars.extra166y.CustomConcurrentHashMap.WeakKeyStrongValueNode
CustomConcurrentHashMap.WeakKeyStrongValueNodeFactory - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.WeakKeyStrongValueNodeFactory() - Constructor for class groovyx.gpars.extra166y.CustomConcurrentHashMap.WeakKeyStrongValueNodeFactory
CustomConcurrentHashMap.WeakKeyWeakValueNode - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.WeakKeyWeakValueNode(int, Object, Object, CustomConcurrentHashMap) - Constructor for class groovyx.gpars.extra166y.CustomConcurrentHashMap.WeakKeyWeakValueNode
CustomConcurrentHashMap.WeakKeyWeakValueNodeFactory - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.WeakKeyWeakValueNodeFactory() - Constructor for class groovyx.gpars.extra166y.CustomConcurrentHashMap.WeakKeyWeakValueNodeFactory
CustomConcurrentHashMap.WriteThroughEntry - Class in groovyx.gpars.extra166y
CustomConcurrentHashMap.WriteThroughEntry(K, V) - Constructor for class groovyx.gpars.extra166y.CustomConcurrentHashMap.WriteThroughEntry
customEvent(DataflowProcessor, Object) - Method in class groovyx.gpars.dataflow.operator.DataflowEventAdapter: Invoked when the fireCustomEvent() method is triggered manually on a dataflow operator/selector.
customEvent(DataflowProcessor, Object) - Method in interface groovyx.gpars.dataflow.operator.DataflowEventListener: Invoked when the fireCustomEvent() method is triggered manually on a dataflow operator/selector When using maxForks, the method may be invoked from threads running the forks.

D

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

E

eachParallel(Collection<T>, Closure) - Static method in class groovyx.gpars.GParsPoolUtil: Creates a Parallel Array out of the supplied collection/object and invokes the withMapping() method using the supplied closure as the transformation operation.
eachParallel(T, Closure) - Static method in class groovyx.gpars.GParsPoolUtil: Creates a Parallel Array out of the supplied collection/object and invokes the withMapping() method using the supplied closure as the transformation operation.
eachParallel(Map<K, V>, Closure) - Static method in class groovyx.gpars.GParsPoolUtil: Creates a Parallel Array out of the supplied map and invokes the withMapping() method using the supplied closure as the transformation operation.
eachWithIndexParallel(Collection<T>, Closure) - Static method in class groovyx.gpars.GParsPoolUtil: Creates a Parallel Array out of the supplied collection/object and invokes the withMapping() method using the supplied closure as the transformation operation.
eachWithIndexParallel(T, Closure) - Static method in class groovyx.gpars.GParsPoolUtil: Creates a Parallel Array out of the supplied collection/object and invokes the withMapping() method using the supplied closure as the transformation operation.
eachWithIndexParallel(Map<K, V>, Closure) - Static method in class groovyx.gpars.GParsPoolUtil: Does parallel eachWithIndex on maps
elementType - Variable in class groovyx.gpars.extra166y.PAS.FJOSelectAllDriver
empty - Variable in class groovyx.gpars.util.DefaultMessageQueue
EMPTY_ARGUMENTS - Static variable in class groovyx.gpars.actor.Actor
EMPTY_OBJECTS - Static variable in class groovyx.gpars.forkjoin.FJWorker
encode(ChannelHandlerContext, Channel, Object) - Method in class groovyx.gpars.remote.netty.RemoteObjectEncoder
enhanceAndUnwrap(ActorMessage) - Method in class groovyx.gpars.actor.BlockingActor
enhanceClosure(Closure) - Method in class groovyx.gpars.actor.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() - Constructor for class groovyx.gpars.util.EnhancedRWLock
EnhancedRWLock(boolean) - Constructor for class groovyx.gpars.util.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 for class groovyx.gpars.util.EnhancedSemaphore: Creates a new EnhancedSemaphore, delegating to the Semaphore class constructor.
enhanceReplies(ActorMessage) - Method in class groovyx.gpars.actor.BlockingActor: Adds reply and replyIfExists methods to the current Actor and the message.
ensureToContainVariable(Object) - Method in class groovyx.gpars.dataflow.Dataflows: The idea is following: we try to putIfAbsent dummy DFV in to map if something real already there we are done if not we obtain lock and put new DFV with double check
enter() - Method in class groovyx.gpars.serial.SerialContext: Enter to the context
entrySet - Variable in class groovyx.gpars.extra166y.CustomConcurrentHashMap
entrySet() - Method in class groovyx.gpars.extra166y.CustomConcurrentHashMap: Returns a Set view of the mappings contained in this map.
eos() - Static method in class groovyx.gpars.dataflow.stream.StreamCore
equal(K, Object) - Method in interface groovyx.gpars.extra166y.CustomConcurrentHashMap.Equivalence: Returns true if the given objects are considered equal.
equal(Object, Object) - Method in class groovyx.gpars.extra166y.CustomConcurrentHashMap.EquivalenceUsingEquals
equal(Object, Object) - Method in class groovyx.gpars.extra166y.CustomConcurrentHashMap.EquivalenceUsingIdentity
equalityPredicate() - Static method in class groovyx.gpars.extra166y.CommonOps: Returns a predicate evaluating to true if the first argument equals the second.
equals(Object) - Method in class groovyx.gpars.dataflow.SelectResult
equals(Object) - Method in class groovyx.gpars.dataflow.stream.StreamCore
EQUALS - Static variable in class groovyx.gpars.extra166y.CustomConcurrentHashMap: An Equivalence object performing Object.equals(java.lang.Object) based comparisons and using Object.hashCode() hashing
equals(Object) - Method in class groovyx.gpars.extra166y.CustomConcurrentHashMap: Compares the specified object with this map for equality.
equals(Object) - Method in class groovyx.gpars.extra166y.CustomConcurrentHashMap.WriteThroughEntry
equals(Object) - Method in class groovyx.gpars.memoize.NullValue: Deprecated.
error - Variable in class groovyx.gpars.dataflow.expression.DataflowExpression
ERROR_READING_A_SYNCHRONOUS_CHANNEL - Static variable in class groovyx.gpars.dataflow.SyncDataflowVariable
errorHandler - Variable in class groovyx.gpars.dataflow.impl.ThenMessagingRunnable
errors - Variable in class groovyx.gpars.agent.AgentCore: Holds agent errors
eval(Object) - Static method in class groovyx.gpars.dataflow.stream.StreamCore
evalLoopCondition() - Method in class groovyx.gpars.actor.DefaultActor
evaluate() - Method in class groovyx.gpars.dataflow.expression.DataflowComplexExpression: Evaluates all the arguments
evaluate() - Method in class groovyx.gpars.dataflow.expression.DataflowExpression: Evaluates the expression after the ones we depend on are ready
evaluate() - Method in class groovyx.gpars.dataflow.expression.DataflowExpression.TransformMany
evaluate() - Method in class groovyx.gpars.dataflow.expression.DataflowExpression.TransformOne
evaluate() - Method in class groovyx.gpars.dataflow.expression.DataflowGetPropertyExpression: Retrieves the receiver's property value
evaluate() - Method in class groovyx.gpars.dataflow.expression.DataflowInvocationExpression
evaluate() - Method in class groovyx.gpars.dataflow.expression.RemoteDataflowExpression
evaluateArguments(Pool, Object[], int, List<Object>, DataflowVariable<Object>, Closure<T>, boolean) - Static method in class groovyx.gpars.util.PAUtils: Performs a single step in the evaluation of parameters passed into an asynchronous function
eventManager - Variable in class groovyx.gpars.dataflow.DataflowQueue
eventManager - Variable in class groovyx.gpars.dataflow.expression.DataflowExpression
eventManager - Variable in class groovyx.gpars.dataflow.stream.DataflowStreamReadAdapter
everyParallel(Collection, Closure) - Static method in class groovyx.gpars.GParsPoolUtil: Creates a Parallel Array out of the supplied collection/object and invokes the withFilter() method using the supplied closure as the filter predicate.
everyParallel(Object, Closure) - Static method in class groovyx.gpars.GParsPoolUtil: Creates a Parallel Array out of the supplied collection/object and invokes the withFilter() method using the supplied closure as the filter predicate.
everyParallel(Map, Closure) - Static method in class groovyx.gpars.GParsPoolUtil: Creates a Parallel Array out of the supplied map and invokes the withFilter() method using the supplied closure as the filter predicate.
ex - Variable in class groovyx.gpars.extra166y.AbstractParallelAnyArray
exceptionCaught(ChannelHandlerContext, ExceptionEvent) - Method in class groovyx.gpars.remote.netty.NettyHandler
exec() - Method in class groovyx.gpars.extra166y.PAS.FJScan
execute(RemoteConnection) - Method in class groovyx.gpars.actor.Actor.RemoteActor.StopActorMsg
execute(RemoteConnection) - Method in class groovyx.gpars.actor.Actor.RemoteActor.TerminateActorMsg
execute(RemoteConnection) - Method in class groovyx.gpars.actor.impl.MessageStream.SendTo
execute(RemoteConnection) - Method in class groovyx.gpars.dataflow.expression.DataflowExpression.BindDataflow: Performs the actual bind on the remote host
execute(Runnable) - Method in class groovyx.gpars.group.PGroup: schedules a new task for processing with the pool
execute(RemoteConnection) - Method in class groovyx.gpars.remote.message.NodeConnectedMsg
execute(RemoteConnection) - Method in class groovyx.gpars.remote.message.NodeDisconnectedMsg
execute(Runnable) - Method in class groovyx.gpars.scheduler.DefaultPool: schedules a new task for processing with the pool
execute(Runnable) - Method in class groovyx.gpars.scheduler.FJPool: schedules a new task for processing with the pool
execute(Runnable) - Method in interface groovyx.gpars.scheduler.Pool: schedules a new task for processing with the pool
execute(Runnable) - Method in class groovyx.gpars.scheduler.Scheduler
execute(RemoteConnection) - Method in class groovyx.gpars.serial.SerialHandle.RemoteSerialHandle.ReleaseHandle
execute(RemoteConnection) - Method in class groovyx.gpars.serial.SerialMsg
EXPECTED - Static variable in class groovyx.gpars.actor.DefaultActor
expr - Variable in class groovyx.gpars.dataflow.expression.DataflowExpression.BindDataflow
extractInputs(Map<String, Object>) - Static method in class groovyx.gpars.dataflow.operator.DataflowProcessor
extractListeners(Map<String, Object>) - Static method in class groovyx.gpars.dataflow.operator.DataflowProcessor
extractOutputs(Map<String, Object>) - Static method in class groovyx.gpars.dataflow.operator.DataflowProcessor
extractState(Map<String, Object>) - Static method in class groovyx.gpars.dataflow.operator.DataflowProcessor

F

factory - Variable in class groovyx.gpars.extra166y.CustomConcurrentHashMap: The factory for this map
factory - Variable in class groovyx.gpars.remote.netty.NettyTransportProvider.Client
factory - Variable in class groovyx.gpars.remote.netty.NettyTransportProvider.Server
fair - Variable in class groovyx.gpars.util.AsyncMessagingCore: Fair agents give up the thread after processing each message, non-fair agents keep a thread until their message queue is empty.
fairActor(Runnable) - Static method in class groovyx.gpars.actor.Actors: Creates a new instance of PooledActor, using the passed-in closure as the body of the actor's act() method.
fairActor(Runnable) - Method in class groovyx.gpars.group.PGroup: Creates a new instance of DefaultActor, using the passed-in runnable/closure as the body of the actor's act() method.
fairAgent(T) - Static method in class groovyx.gpars.agent.Agent: Creates an agent instance initialized with the given state, which will cooperate in thread sharing with other Agent instances in a fair manner.
fairAgent(T, Closure) - Static method in class groovyx.gpars.agent.Agent: Creates an agent instance initialized with the given state, which will cooperate in thread sharing with other agents and actors in a fair manner.
fairAgent(T) - Method in class groovyx.gpars.group.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.
fairAgent(T, Closure) - Method in class groovyx.gpars.group.PGroup: Creates an agent instance initialized with the given state, which will cooperate in thread sharing with other agents and actors in a fair manner.
fairMessageHandler(Closure) - Static method in class groovyx.gpars.actor.Actors: Creates an instance of DynamicDispatchActor, which will cooperate in thread sharing with other actors in a fair manner.
fairMessageHandler(Closure) - Method in class groovyx.gpars.group.PGroup: Creates an instance of DynamicDispatchActor, which will cooperate in thread sharing with other actors sharing the same thread pool
fairReactor(Closure) - Static method in class groovyx.gpars.actor.Actors: Creates a reactor around the supplied code, which will cooperate in thread sharing with other actors in a fair manner.
fairReactor(Closure) - Method in class groovyx.gpars.group.PGroup: Creates a reactor around the supplied code, which will cooperate in thread sharing with other actors sharing the same thread pool When a reactor receives a message, the supplied block of code is run with the message as a parameter and the result of the code is send in reply.
fairStaticMessageHandler(Closure) - Static method in class groovyx.gpars.actor.Actors: Creates an instance of StaticDispatchActor, which will cooperate in thread sharing with other actors sharing the same thread pool.
fairStaticMessageHandler(Closure) - Method in class groovyx.gpars.group.PGroup: Creates an instance of StaticDispatchActor, which will cooperate in thread sharing with other actors sharing the same thread pool.
fence - Variable in class groovyx.gpars.extra166y.AbstractParallelAnyArray
fence - Variable in class groovyx.gpars.extra166y.PAS.FJScanOp
filter(Closure<Boolean>) - Method in class groovyx.gpars.dataflow.DataflowQueue
filter(Pool, Closure<Boolean>) - Method in class groovyx.gpars.dataflow.DataflowQueue
filter(PGroup, Closure<Boolean>) - Method in class groovyx.gpars.dataflow.DataflowQueue
filter(Map<String, Object>, Closure<Boolean>) - Method in class groovyx.gpars.dataflow.DataflowQueue
filter(Pool, Map<String, Object>, Closure<Boolean>) - Method in class groovyx.gpars.dataflow.DataflowQueue
filter(PGroup, Map<String, Object>, Closure<Boolean>) - Method in class groovyx.gpars.dataflow.DataflowQueue
filter(Closure<Boolean>) - Method in interface groovyx.gpars.dataflow.DataflowReadChannel: Creates and attaches a new operator that will filter data using the provided closure
filter(Pool, Closure<Boolean>) - Method in interface groovyx.gpars.dataflow.DataflowReadChannel: Creates and attaches a new operator that will filter data using the provided closure
filter(PGroup, Closure<Boolean>) - Method in interface groovyx.gpars.dataflow.DataflowReadChannel: Creates and attaches a new operator that will filter data using the provided closure
filter(Map<String, Object>, Closure<Boolean>) - Method in interface groovyx.gpars.dataflow.DataflowReadChannel: Creates and attaches a new operator that will filter data using the provided closure
filter(Pool, Map<String, Object>, Closure<Boolean>) - Method in interface groovyx.gpars.dataflow.DataflowReadChannel: Creates and attaches a new operator that will filter data using the provided closure
filter(PGroup, Map<String, Object>, Closure<Boolean>) - Method in interface groovyx.gpars.dataflow.DataflowReadChannel: Creates and attaches a new operator that will filter data using the provided closure
filter(Closure<Boolean>) - Method in class groovyx.gpars.dataflow.expression.DataflowExpression
filter(Pool, Closure<Boolean>) - Method in class groovyx.gpars.dataflow.expression.DataflowExpression
filter(PGroup, Closure<Boolean>) - Method in class groovyx.gpars.dataflow.expression.DataflowExpression
filter(Map<String, Object>, Closure<Boolean>) - Method in class groovyx.gpars.dataflow.expression.DataflowExpression
filter(Pool, Map<String, Object>, Closure<Boolean>) - Method in class groovyx.gpars.dataflow.expression.DataflowExpression
filter(PGroup, Map<String, Object>, Closure<Boolean>) - Method in class groovyx.gpars.dataflow.expression.DataflowExpression
filter(Closure<Boolean>) - Method in class groovyx.gpars.dataflow.operator.Pipeline: Creates and attaches a new operator that will filter data using the provided closure
filter(Map<String, Object>, Closure<Boolean>) - Method in class groovyx.gpars.dataflow.operator.Pipeline: Creates and attaches a new operator that will filter data using the provided closure
filter(Closure<Boolean>) - Method in class groovyx.gpars.dataflow.stream.DataflowStreamReadAdapter
filter(Pool, Closure<Boolean>) - Method in class groovyx.gpars.dataflow.stream.DataflowStreamReadAdapter
filter(PGroup, Closure<Boolean>) - Method in class groovyx.gpars.dataflow.stream.DataflowStreamReadAdapter
filter(Map<String, Object>, Closure<Boolean>) - Method in class groovyx.gpars.dataflow.stream.DataflowStreamReadAdapter
filter(Pool, Map<String, Object>, Closure<Boolean>) - Method in class groovyx.gpars.dataflow.stream.DataflowStreamReadAdapter
filter(PGroup, Map<String, Object>, Closure<Boolean>) - Method in class groovyx.gpars.dataflow.stream.DataflowStreamReadAdapter
filter(Closure) - Method in interface groovyx.gpars.dataflow.stream.FList
filter(Closure) - Method in class groovyx.gpars.dataflow.stream.StreamCore: Builds a filtered stream using the supplied filter closure
filter(StreamCore<T>, Closure, StreamCore<T>) - Method in class groovyx.gpars.dataflow.stream.StreamCore
FilterClosure<V> - Class in groovyx.gpars.dataflow.operator: Used by the filter() method to wrap the supplied closure and use it for filtering data.
FilterClosure(Closure<Boolean>) - Constructor for class groovyx.gpars.dataflow.operator.FilterClosure
filteredAtLeaf(int, int) - Method in class groovyx.gpars.extra166y.PAS.FJDStats
filteredAtLeaf(int, int) - Method in class groovyx.gpars.extra166y.PAS.FJLStats
filteredAtLeaf(int, int) - Method in class groovyx.gpars.extra166y.PAS.FJOStats
finalize() - Method in class groovyx.gpars.group.PGroup: Shutdown the thread pool gracefully
finalizeHandle(SerialHandle) - Method in class groovyx.gpars.serial.SerialContext
finalizeHandle(SerialHandle) - Method in class groovyx.gpars.serial.SerialHandles
finalizeReference() - Method in class groovyx.gpars.serial.SerialHandle
finalizeReference() - Method in class groovyx.gpars.serial.SerialHandle.RemoteSerialHandle
findAllParallel(Collection<T>, Closure) - Static method in class groovyx.gpars.GParsPoolUtil: Creates a Parallel Array out of the supplied collection/object and invokes the withFilter() method using the supplied closure as the filter predicate.
findAllParallel(Object, Closure) - Static method in class groovyx.gpars.GParsPoolUtil: Creates a Parallel Array out of the supplied collection/object and invokes the withFilter() method using the supplied closure as the filter predicate.
findAllParallel(Map<K, V>, Closure) - Static method in class groovyx.gpars.GParsPoolUtil: Creates a Parallel Array out of the supplied map and invokes the withFilter() method using the supplied closure as the filter predicate.
findAnyParallel(Collection<T>, Closure) - Static method in class groovyx.gpars.GParsPoolUtil: Creates a Parallel Array out of the supplied collection/object and invokes the withFilter() method using the supplied closure as the filter predicate.
findAnyParallel(Object, Closure) - Static method in class groovyx.gpars.GParsPoolUtil: Creates a Parallel Array out of the supplied collection/object and invokes the withFilter() method using the supplied closure as the filter predicate.
findAnyParallel(Map<K, V>, Closure) - Static method in class groovyx.gpars.GParsPoolUtil: Creates a Parallel Array out of the supplied map and invokes the withFilter() method using the supplied closure as the filter predicate.
findGroupById(String) - Method in class groovyx.gpars.activeobject.ActiveObjectRegistry
findNode(Object, int, CustomConcurrentHashMap.Segment) - Method in class groovyx.gpars.extra166y.CustomConcurrentHashMap: Returns node for key, or null if none.
findParallel(Collection<T>, Closure) - Static method in class groovyx.gpars.GParsPoolUtil: Creates a Parallel Array out of the supplied collection/object and invokes the withFilter() method using the supplied closure as the filter predicate.
findParallel(Object, Closure) - Static method in class groovyx.gpars.GParsPoolUtil: Creates a Parallel Array out of the supplied collection/object and invokes the withFilter() method using the supplied closure as the filter predicate.
findParallel(Map<K, V>, Closure) - Static method in class groovyx.gpars.GParsPoolUtil: Creates a Parallel Array out of the supplied map and invokes the withFilter() method using the supplied closure as the filter predicate.
findSuitablePrivateMethodName(ClassNode, MethodNode) - Static method in class groovyx.gpars.activeobject.ActiveObjectASTTransformation.MyClassCodeExpressionTransformer
FINISHED - Static variable in class groovyx.gpars.extra166y.PAS.FJScan
fireAfterRun(List<Object>) - Method in class groovyx.gpars.dataflow.operator.DataflowProcessor
fireAfterStart() - Method in class groovyx.gpars.dataflow.operator.DataflowProcessor
fireAfterStop() - Method in class groovyx.gpars.dataflow.operator.DataflowProcessor
fireBeforeRun(List<Object>) - Method in class groovyx.gpars.dataflow.operator.DataflowProcessor
fireBindError(T, boolean) - Method in class groovyx.gpars.dataflow.expression.DataflowExpression
fireBindError(Throwable) - Method in class groovyx.gpars.dataflow.expression.DataflowExpression
fireBindError(T, T, boolean) - Method in interface groovyx.gpars.dataflow.impl.BindErrorDistributor
fireBindError(T, Throwable) - Method in interface groovyx.gpars.dataflow.impl.BindErrorDistributor
fireBindError(Throwable, T, boolean) - Method in interface groovyx.gpars.dataflow.impl.BindErrorDistributor
fireBindError(Throwable, Throwable) - Method in interface groovyx.gpars.dataflow.impl.BindErrorDistributor
fireBindError(T, T, boolean) - Method in class groovyx.gpars.dataflow.impl.DataflowChannelEventOrchestrator: Notifies all listeners about failed bind operations
fireBindError(T, Throwable) - Method in class groovyx.gpars.dataflow.impl.DataflowChannelEventOrchestrator: Notifies all listeners about failed bindError operations
fireBindError(Throwable, T, boolean) - Method in class groovyx.gpars.dataflow.impl.DataflowChannelEventOrchestrator: Notifies all listeners about failed bind operations
fireBindError(Throwable, Throwable) - Method in class groovyx.gpars.dataflow.impl.DataflowChannelEventOrchestrator: Notifies all listeners about failed bindError operations
fireControlMessageArrived(DataflowReadChannel, int, Object) - Method in class groovyx.gpars.dataflow.operator.DataflowProcessor
fireCustomEvent(Object) - Method in class groovyx.gpars.dataflow.operator.DataflowProcessor
fireEvent() - Method in class groovyx.gpars.dataflow.operator.component.GracefulShutdownListener: If shutdown is in progress, we'll notify the monitor
fireMessageArrived(DataflowReadChannel, int, Object) - Method in class groovyx.gpars.dataflow.operator.DataflowProcessor
fireMessageArrived(Object, int, boolean) - Method in class groovyx.gpars.dataflow.operator.DataflowProcessorActor
fireMessageSentOut(DataflowWriteChannel, int, Object) - Method in class groovyx.gpars.dataflow.operator.DataflowProcessor
fireOnException(Throwable) - Method in class groovyx.gpars.dataflow.operator.DataflowProcessor
fireOnMessage(T) - Method in class groovyx.gpars.dataflow.DataflowQueue
fireOnMessage(T) - Method in class groovyx.gpars.dataflow.expression.DataflowExpression
fireOnMessage(T) - Method in interface groovyx.gpars.dataflow.impl.DataflowChannelEventDistributor
fireOnMessage(T) - Method in class groovyx.gpars.dataflow.impl.DataflowChannelEventOrchestrator
fireOnMessage(T) - Method in class groovyx.gpars.dataflow.stream.DataflowStreamReadAdapter
first - Variable in class groovyx.gpars.actor.ForwardingDelegate
first - Variable in class groovyx.gpars.actor.impl.RunnableBackedBlockingActor.RunnableBackedPooledActorDelegate
first - Variable in class groovyx.gpars.dataflow.stream.StreamCore
first - Variable in class groovyx.gpars.extra166y.AbstractParallelAnyArray.AndPredicate
FJPool - Class in groovyx.gpars.scheduler: Represents the actors' thread pool, which performs tasks on behalf of the actors.
FJPool() - Constructor for class groovyx.gpars.scheduler.FJPool: Creates the pool with default number of threads.
FJPool(int) - Constructor for class groovyx.gpars.scheduler.FJPool: Creates the pool with specified number of threads.
FJPool(ForkJoinPool) - Constructor for class groovyx.gpars.scheduler.FJPool: Creates the pool wrapping the provided ForkJoinPool
FJWorker<T> - Class in groovyx.gpars.forkjoin: Represents a recursive task for the builder-style fork/join algorithm.
FJWorker(Object...) - Constructor for class groovyx.gpars.forkjoin.FJWorker
FList<T> - Interface in groovyx.gpars.dataflow.stream: Represents a list implemented as a Functional Queue.
FListIterator<T> - Class in groovyx.gpars.dataflow.stream
FListIterator(FList<T>) - Constructor for class groovyx.gpars.dataflow.stream.FListIterator
foldParallel(Collection<T>, Closure) - Static method in class groovyx.gpars.GParsPoolUtil: Deprecated.
foldParallel(Object, Closure) - Static method in class groovyx.gpars.GParsPoolUtil: Deprecated.
foldParallel(Collection<T>, T, Closure) - Static method in class groovyx.gpars.GParsPoolUtil: Deprecated.
foldParallel(Object, Object, Closure) - Static method in class groovyx.gpars.GParsPoolUtil: Deprecated.
ForkingDataflowOperatorActor - Class in groovyx.gpars.dataflow.operator: An operator's internal actor.
ForkingDataflowOperatorActor(DataflowOperator, PGroup, List, List, Closure, int) - Constructor for class groovyx.gpars.dataflow.operator.ForkingDataflowOperatorActor
ForkingDataflowSelectorActor - Class in groovyx.gpars.dataflow.operator: An selector's internal actor.
ForkingDataflowSelectorActor(DataflowSelector, PGroup, List, List, Closure, int) - Constructor for class groovyx.gpars.dataflow.operator.ForkingDataflowSelectorActor
ForkJoinUtils - Class in groovyx.gpars.forkjoin
ForkJoinUtils() - Constructor for class groovyx.gpars.forkjoin.ForkJoinUtils
forkOffChild(AbstractForkJoinWorker<T>) - Method in class groovyx.gpars.forkjoin.AbstractForkJoinWorker: Forks a child task.
forkOffChild(Object...) - Method in class groovyx.gpars.forkjoin.FJWorker
ForwardingDelegate - Class in groovyx.gpars.actor
ForwardingDelegate(Object, Object) - Constructor for class groovyx.gpars.actor.ForwardingDelegate
forwardPoisonPill(Object) - Method in class groovyx.gpars.dataflow.operator.DataflowProcessorActor
forwardPoisonPill(Object) - Method in class groovyx.gpars.dataflow.operator.ForkingDataflowOperatorActor
forwardPoisonPill(Object) - Method in class groovyx.gpars.dataflow.operator.ForkingDataflowSelectorActor
FQMessageQueue - Class in groovyx.gpars.util: An implementation of the message queue for actor and agent messaging using functional queues.
FQMessageQueue() - Constructor for class groovyx.gpars.util.FQMessageQueue
FQMessageQueue.EmptyNode - Class in groovyx.gpars.util
FQMessageQueue.EmptyNode() - Constructor for class groovyx.gpars.util.FQMessageQueue.EmptyNode
FQMessageQueue.Node - Class in groovyx.gpars.util
FQMessageQueue.Node(FQMessageQueue.Node, Object) - Constructor for class groovyx.gpars.util.FQMessageQueue.Node

G

GeneralTimer - Interface in groovyx.gpars.util: Represents timers, either java.util.Timer or timers provided by the hosting environment, such as GAE
generate(T, Closure, Closure) - Method in class groovyx.gpars.dataflow.stream.StreamCore: Populates the stream with generated values
generateNext(T, StreamCore<T>, Closure, Closure) - Method in class groovyx.gpars.dataflow.stream.StreamCore
generator - Static variable in class groovyx.gpars.extra166y.CommonOps.DoubleRandomGenerator
generator - Static variable in class groovyx.gpars.extra166y.CommonOps.IntRandomGenerator
generator - Static variable in class groovyx.gpars.extra166y.CommonOps.LongRandomGenerator
generator - Variable in class groovyx.gpars.extra166y.PAS.FJDGenerate
generator - Variable in class groovyx.gpars.extra166y.PAS.FJLGenerate
generator - Variable in class groovyx.gpars.extra166y.PAS.FJOGenerate
get() - Method in class groovyx.gpars.dataflow.DataflowVariable: Retrieves the value of the variable, blocking until a value is available
get(long, TimeUnit) - Method in class groovyx.gpars.dataflow.DataflowVariable: Retrieves the value of the variable, blocking up to given timeout, if the value has not been assigned yet.
get() - Method in interface groovyx.gpars.dataflow.Promise: Retrieves the value of the variable, blocking until a value is available
get(long, TimeUnit) - Method in interface groovyx.gpars.dataflow.Promise: Retrieves the value of the variable, blocking up to given timeout, if the value has not been assigned yet.
get(Object) - Method in class groovyx.gpars.extra166y.CustomConcurrentHashMap: Returns the value associated with a key equivalent to the given key with respect to this map's key Equivalence, or null if no such mapping exists.
get() - Method in class groovyx.gpars.extra166y.CustomConcurrentHashMap.IntKeyNode
get() - Method in interface groovyx.gpars.extra166y.CustomConcurrentHashMap.Node: Returns the key established during the creation of this node.
get() - Method in class groovyx.gpars.extra166y.CustomConcurrentHashMap.StrongKeyNode
get(int) - Method in class groovyx.gpars.extra166y.ParallelArray.AsList
get(int) - Method in class groovyx.gpars.extra166y.ParallelArray: Returns the element of the array at the given index.
get(int) - Method in class groovyx.gpars.extra166y.ParallelDoubleArray.AsList
get(int) - Method in class groovyx.gpars.extra166y.ParallelDoubleArray: Returns the element of the array at the given index.
get(int) - Method in class groovyx.gpars.extra166y.ParallelLongArray.AsList
get(int) - Method in class groovyx.gpars.extra166y.ParallelLongArray: Returns the element of the array at the given index.
get() - Static method in class groovyx.gpars.serial.SerialContext
get(UUID) - Method in class groovyx.gpars.serial.SerialContext
get(UUID) - Method in class groovyx.gpars.serial.SerialHandles
getAddress() - Method in class groovyx.gpars.remote.netty.NettyTransportProvider.Server
getArray() - Method in class groovyx.gpars.extra166y.ParallelArray: Returns the underlying array used for computations.
getArray() - Method in class groovyx.gpars.extra166y.ParallelDoubleArray: Returns the underlying array used for computations.
getArray() - Method in class groovyx.gpars.extra166y.ParallelLongArray: Returns the underlying array used for computations.
getAt(int) - Method in class groovyx.gpars.dataflow.Dataflows: Retrieves the DFV associated with the given index
getBindErrorListeners() - Method in interface groovyx.gpars.dataflow.impl.BindErrorListenerManager
getBindErrorListeners() - Method in class groovyx.gpars.dataflow.impl.DataflowChannelEventOrchestrator
getBindErrorManager() - Method in class groovyx.gpars.dataflow.expression.DataflowExpression
getChannel() - Method in class groovyx.gpars.remote.netty.NettyHandler
getChildrenResults() - Method in class groovyx.gpars.forkjoin.AbstractForkJoinWorker: Waits for and returns the results of the child tasks.
getConcurrentExceptions() - Method in exception groovyx.gpars.AsyncException
getConfiguredPoolSize() - Method in class groovyx.gpars.scheduler.FJPool
getConnection() - Method in class groovyx.gpars.remote.RemoteHost
getContent() - Method in class groovyx.gpars.pa.CombineHolder
getCore() - Method in class groovyx.gpars.actor.AbstractLoopingActor
getCount() - Method in class groovyx.gpars.dataflow.impl.ResizeableCountDownLatch: Returns the current count.
getCount() - Method in class groovyx.gpars.dataflow.impl.ResizeableCountDownLatch.Sync
getCurrent() - Method in class groovyx.gpars.ThreadLocalPools: Gives the current element
getError() - Method in class groovyx.gpars.dataflow.DataflowVariable: Returns the error bound to the promise
getError() - Method in class groovyx.gpars.dataflow.LazyDataflowVariable: Returns the error bound to the promise
getError() - Method in interface groovyx.gpars.dataflow.Promise: Returns the error bound to the promise
getErrors() - Method in class groovyx.gpars.agent.AgentCore: Retrieves a list of exception thrown within the agent's body.
getEventManager() - Method in class groovyx.gpars.dataflow.DataflowQueue
getEventManager() - Method in interface groovyx.gpars.dataflow.DataflowReadChannel: Retrieves the event manager object of this channel
getEventManager() - Method in class groovyx.gpars.dataflow.expression.DataflowExpression
getEventManager() - Method in class groovyx.gpars.dataflow.stream.DataflowStreamReadAdapter
getExecutor() - Method in class groovyx.gpars.extra166y.ParallelArray: Returns the executor used for computations.
getExecutor() - Method in class groovyx.gpars.extra166y.ParallelDoubleArray: Returns the executor used for computations.
getExecutor() - Method in class groovyx.gpars.extra166y.ParallelLongArray: Returns the executor used for computations.
getExecutorService() - Method in class groovyx.gpars.scheduler.DefaultPool: Retrieves the internal executor service.
getFirst() - Method in interface groovyx.gpars.dataflow.stream.FList
getFirst() - Method in class groovyx.gpars.dataflow.stream.StreamCore: Retrieved the first element in the stream, blocking until a value is available
getFirstDFV() - Method in class groovyx.gpars.dataflow.stream.StreamCore
getForkJoinPool() - Method in class groovyx.gpars.scheduler.FJPool: Retrieves the internal executor service.
getGroup() - Method in class groovyx.gpars.dataflow.operator.Pipeline
getHead() - Method in class groovyx.gpars.dataflow.stream.DataflowStreamWriteAdapter
getHost() - Method in class groovyx.gpars.remote.RemoteConnection
getHostId() - Method in class groovyx.gpars.serial.SerialContext
getId() - Method in class groovyx.gpars.actor.ActorTimerTask
getId() - Method in class groovyx.gpars.remote.LocalNode
getId() - Method in class groovyx.gpars.remote.RemoteNode
getId() - Method in class groovyx.gpars.serial.LocalHandle
getId() - Method in class groovyx.gpars.serial.SerialHandles: Getter for provider id
getImmediateInstance() - Static method in class groovyx.gpars.dataflow.operator.PoisonPill: Retrieves an immediate poison pill instance
getIndex() - Method in class groovyx.gpars.dataflow.SelectResult
getInstance() - Static method in class groovyx.gpars.activeobject.ActiveObjectRegistry
getInstance() - Static method in class groovyx.gpars.dataflow.operator.PoisonPill: Retrieves a non-immediate poison pill instance
getInstance() - Static method in class groovyx.gpars.dataflow.operator.StopGently
getInstance() - Static method in class groovyx.gpars.pa.SumClosure
getInstantVal() - Method in class groovyx.gpars.agent.AgentBase: A shorthand method for safe message-based retrieval of the internal state.
getIssues() - Method in exception groovyx.gpars.actor.impl.ActorReplyException
getJoinLatch() - Method in class groovyx.gpars.actor.Actor: Join-point for this actor
getKey() - Method in class groovyx.gpars.extra166y.CustomConcurrentHashMap.WriteThroughEntry
getLinkage() - Method in class groovyx.gpars.extra166y.CustomConcurrentHashMap.LinkedIntKeyIntValueNode
getLinkage() - Method in class groovyx.gpars.extra166y.CustomConcurrentHashMap.LinkedIntKeySelfValueNode
getLinkage() - Method in class groovyx.gpars.extra166y.CustomConcurrentHashMap.LinkedIntKeySoftValueNode
getLinkage() - Method in class groovyx.gpars.extra166y.CustomConcurrentHashMap.LinkedIntKeyStrongValueNode
getLinkage() - Method in class groovyx.gpars.extra166y.CustomConcurrentHashMap.LinkedIntKeyWeakValueNode
getLinkage() - Method in class groovyx.gpars.extra166y.CustomConcurrentHashMap.LinkedSoftKeyIntValueNode
getLinkage() - Method in class groovyx.gpars.extra166y.CustomConcurrentHashMap.LinkedSoftKeySelfValueNode
getLinkage() - Method in class groovyx.gpars.extra166y.CustomConcurrentHashMap.LinkedSoftKeySoftValueNode
getLinkage() - Method in class groovyx.gpars.extra166y.CustomConcurrentHashMap.LinkedSoftKeyStrongValueNode
getLinkage() - Method in class groovyx.gpars.extra166y.CustomConcurrentHashMap.LinkedSoftKeyWeakValueNode
getLinkage() - Method in class groovyx.gpars.extra166y.CustomConcurrentHashMap.LinkedStrongKeyIntValueNode
getLinkage() - Method in class groovyx.gpars.extra166y.CustomConcurrentHashMap.LinkedStrongKeySelfValueNode
getLinkage() - Method in class groovyx.gpars.extra166y.CustomConcurrentHashMap.LinkedStrongKeySoftValueNode
getLinkage() - Method in class groovyx.gpars.extra166y.CustomConcurrentHashMap.LinkedStrongKeyStrongValueNode
getLinkage() - Method in class groovyx.gpars.extra166y.CustomConcurrentHashMap.LinkedStrongKeyWeakValueNode
getLinkage() - Method in class groovyx.gpars.extra166y.CustomConcurrentHashMap.LinkedWeakKeyIntValueNode
getLinkage() - Method in class groovyx.gpars.extra166y.CustomConcurrentHashMap.LinkedWeakKeySelfValueNode
getLinkage() - Method in class groovyx.gpars.extra166y.CustomConcurrentHashMap.LinkedWeakKeySoftValueNode
getLinkage() - Method in class groovyx.gpars.extra166y.CustomConcurrentHashMap.LinkedWeakKeyStrongValueNode
getLinkage() - Method in class groovyx.gpars.extra166y.CustomConcurrentHashMap.LinkedWeakKeyWeakValueNode
getLinkage() - Method in interface groovyx.gpars.extra166y.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 class groovyx.gpars.extra166y.CustomConcurrentHashMap.TerminalIntKeyIntValueNode
getLinkage() - Method in class groovyx.gpars.extra166y.CustomConcurrentHashMap.TerminalIntKeySelfValueNode
getLinkage() - Method in class groovyx.gpars.extra166y.CustomConcurrentHashMap.TerminalIntKeySoftValueNode
getLinkage() - Method in class groovyx.gpars.extra166y.CustomConcurrentHashMap.TerminalIntKeyStrongValueNode
getLinkage() - Method in class groovyx.gpars.extra166y.CustomConcurrentHashMap.TerminalIntKeyWeakValueNode
getLinkage() - Method in class groovyx.gpars.extra166y.CustomConcurrentHashMap.TerminalSoftKeyIntValueNode
getLinkage() - Method in class groovyx.gpars.extra166y.CustomConcurrentHashMap.TerminalSoftKeySelfValueNode
getLinkage() - Method in class groovyx.gpars.extra166y.CustomConcurrentHashMap.TerminalSoftKeySoftValueNode
getLinkage() - Method in class groovyx.gpars.extra166y.CustomConcurrentHashMap.TerminalSoftKeyStrongValueNode
getLinkage() - Method in class groovyx.gpars.extra166y.CustomConcurrentHashMap.TerminalSoftKeyWeakValueNode
getLinkage() - Method in class groovyx.gpars.extra166y.CustomConcurrentHashMap.TerminalStrongKeyIntValueNode
getLinkage() - Method in class groovyx.gpars.extra166y.CustomConcurrentHashMap.TerminalStrongKeySelfValueNode
getLinkage() - Method in class groovyx.gpars.extra166y.CustomConcurrentHashMap.TerminalStrongKeySoftValueNode
getLinkage() - Method in class groovyx.gpars.extra166y.CustomConcurrentHashMap.TerminalStrongKeyStrongValueNode
getLinkage() - Method in class groovyx.gpars.extra166y.CustomConcurrentHashMap.TerminalStrongKeyWeakValueNode
getLinkage() - Method in class groovyx.gpars.extra166y.CustomConcurrentHashMap.TerminalWeakKeyIntValueNode
getLinkage() - Method in class groovyx.gpars.extra166y.CustomConcurrentHashMap.TerminalWeakKeySelfValueNode
getLinkage() - Method in class groovyx.gpars.extra166y.CustomConcurrentHashMap.TerminalWeakKeySoftValueNode
getLinkage() - Method in class groovyx.gpars.extra166y.CustomConcurrentHashMap.TerminalWeakKeyStrongValueNode
getLinkage() - Method in class groovyx.gpars.extra166y.CustomConcurrentHashMap.TerminalWeakKeyWeakValueNode
getListeners() - Method in interface groovyx.gpars.dataflow.impl.DataflowChannelEventListenerManager
getListeners() - Method in class groovyx.gpars.dataflow.impl.DataflowChannelEventOrchestrator
getLocalHost() - Method in class groovyx.gpars.remote.LocalNode
getLocalHost() - Method in class groovyx.gpars.remote.RemoteHost
getLocalHostId() - Method in class groovyx.gpars.serial.SerialContext
getLocator() - Method in class groovyx.gpars.extra166y.CustomConcurrentHashMap.IntKeyNode
getLocator() - Method in interface groovyx.gpars.extra166y.CustomConcurrentHashMap.Node: Returns the locator established during the creation of this node.
getLocator() - Method in class groovyx.gpars.extra166y.CustomConcurrentHashMap.SoftKeyNode
getLocator() - Method in class groovyx.gpars.extra166y.CustomConcurrentHashMap.StrongKeyNode
getLocator() - Method in class groovyx.gpars.extra166y.CustomConcurrentHashMap.WeakKeyNode
getMainActor() - Method in class groovyx.gpars.remote.LocalNode
getMainActor() - Method in class groovyx.gpars.remote.RemoteNode
getMaximumNumberOfParameters() - Method in class groovyx.gpars.dataflow.operator.BinaryChoiceClosure
getMaximumNumberOfParameters() - Method in class groovyx.gpars.dataflow.operator.ChainWithClosure
getMaximumNumberOfParameters() - Method in class groovyx.gpars.dataflow.operator.ChoiceClosure
getMaximumNumberOfParameters() - Method in class groovyx.gpars.dataflow.operator.CopyChannelsClosure
getMaximumNumberOfParameters() - Method in class groovyx.gpars.dataflow.operator.DataflowProcessorAtomicBoundAllClosure
getMaximumNumberOfParameters() - Method in class groovyx.gpars.dataflow.operator.FilterClosure
getMaximumNumberOfParameters() - Method in class groovyx.gpars.dataflow.operator.SeparationClosure
getMaximumNumberOfParameters() - Method in class groovyx.gpars.DataflowMessagingRunnable
getMaximumNumberOfParameters() - Method in class groovyx.gpars.MessagingRunnable
getMaximumNumberOfParameters() - Method in class groovyx.gpars.ReactorMessagingRunnable
getMessage() - Method in class groovyx.gpars.actor.impl.MessageStream.SendTo
getMessage() - Method in exception groovyx.gpars.AsyncException
getMetaClass() - Method in class groovyx.gpars.dataflow.expression.DataflowExpression
getName() - Method in enum groovyx.gpars.extra166y.CustomConcurrentHashMap.Strength
getOrCreateSerialHandle() - Method in class groovyx.gpars.serial.WithSerialId: Gets serial handle for the object If needed new handle created and serialization host subscribed for the object handle
getOutput() - Method in class groovyx.gpars.dataflow.operator.DataflowProcessor: The processor's first / only output channel
getOutput() - Method in class groovyx.gpars.dataflow.operator.Pipeline
getOutputs(int) - Method in class groovyx.gpars.dataflow.operator.DataflowProcessor: The processor's output channel of the given index
getOutputs() - Method in class groovyx.gpars.dataflow.operator.DataflowProcessor: The processor's all output channels
getOwningProcessor() - Method in class groovyx.gpars.DataflowMessagingRunnable: Retrieves the owning processor (operator or selector) giving the DataflowMessagingRunnable a way to call methods like bindOutput()
getParallel(Collection<T>) - Static method in class groovyx.gpars.GParsPoolUtil: Creates a PAWrapper around a ParallelArray wrapping the elements of the original collection.
getParallel(Object) - Static method in class groovyx.gpars.GParsPoolUtil: Creates a PAWrapper around a ParallelArray wrapping the elements of the original collection.
getParallelArray(Collection<T>) - Static method in class groovyx.gpars.GParsPoolUtil: Creates a ParallelArray wrapping the elements of the original collection.
getParallelArray(Object) - Static method in class groovyx.gpars.GParsPoolUtil: Creates a ParallelArray wrapping the elements of the original collection.
getParallelGroup() - Method in class groovyx.gpars.actor.Actor: Retrieves the group to which the actor belongs
getParameterTypes() - Method in class groovyx.gpars.dataflow.operator.BinaryChoiceClosure
getParameterTypes() - Method in class groovyx.gpars.dataflow.operator.ChainWithClosure
getParameterTypes() - Method in class groovyx.gpars.dataflow.operator.ChoiceClosure
getParameterTypes() - Method in class groovyx.gpars.dataflow.operator.CopyChannelsClosure
getParameterTypes() - Method in class groovyx.gpars.dataflow.operator.FilterClosure
getParameterTypes() - Method in class groovyx.gpars.dataflow.operator.SeparationClosure
getParameterTypes() - Method in class groovyx.gpars.DataflowMessagingRunnable: Returns types expected by the Runnable.
getParameterTypes() - Method in class groovyx.gpars.MessagingRunnable
getParameterTypes() - Method in class groovyx.gpars.ReactorMessagingRunnable
getPayLoad() - Method in class groovyx.gpars.actor.ActorMessage
getPipeline() - Method in class groovyx.gpars.remote.netty.NettyTransportProvider.ServerPipelineFactory
getPoolFactory() - Static method in class groovyx.gpars.GParsConfig
getPoolSize() - Method in class groovyx.gpars.group.PGroup: Retrieves the current thread pool size
getPoolSize() - Method in class groovyx.gpars.scheduler.DefaultPool: Retrieves the current thread pool size
getPoolSize() - Method in class groovyx.gpars.scheduler.FJPool: Retrieves the current thread pool size
getPoolSize() - Method in interface groovyx.gpars.scheduler.Pool: Retrieves the current thread pool size
getPoolSize() - Method in class groovyx.gpars.scheduler.Scheduler: Retrieves the current thread pool size
getProperty(String) - Method in class groovyx.gpars.actor.ForwardingDelegate
getProperty(String) - Method in class groovyx.gpars.actor.impl.RunnableBackedBlockingActor.RunnableBackedPooledActorDelegate
getProperty(String) - Method in class groovyx.gpars.dataflow.Dataflows
getProperty(String) - Method in class groovyx.gpars.dataflow.expression.DataflowExpression: Returns either standard property of the expression or creates an expression, which will request given property when the receiver becomes available
getQueue() - Method in class groovyx.gpars.dataflow.DataflowQueue
getRawResult() - Method in class groovyx.gpars.extra166y.PAS.FJScan
getReclamationQueue() - Static method in class groovyx.gpars.extra166y.CustomConcurrentHashMap: Returns a queue that may be used as the ReferenceQueue argument to Reference constructors to arrange removal of reclaimed nodes from maps via a background thread.
getRemoteClass() - Method in class groovyx.gpars.actor.impl.MessageStream
getRemoteClass() - Method in class groovyx.gpars.dataflow.DataflowVariable
getRemoteClass() - Method in class groovyx.gpars.serial.WithSerialId: Class of remote object to be created
getRemoteHost() - Method in class groovyx.gpars.remote.RemoteNode
getRest() - Method in class groovyx.gpars.dataflow.stream.DataflowStream: Retrieves a DataflowStream representing the rest of this Stream after removing the first element
getRest() - Method in interface groovyx.gpars.dataflow.stream.FList
getRest() - Method in class groovyx.gpars.dataflow.stream.StreamCore: Retrieves a DataflowStream representing the rest of this Stream after removing the first element
getRest() - Method in class groovyx.gpars.dataflow.stream.SyncDataflowStream: Retrieves a DataflowStream representing the rest of this Stream after removing the first element
getResult() - Method in class groovyx.gpars.actor.impl.MessageStream.ResultWaiter: Retrieves the response blocking until a message arrives
getResult(long, TimeUnit) - Method in class groovyx.gpars.actor.impl.MessageStream.ResultWaiter: Retrieves the response blocking until a message arrives
getScheduler() - Method in class groovyx.gpars.remote.LocalNode
getSegmentForAdd(int) - Method in class groovyx.gpars.extra166y.CustomConcurrentHashMap: Returns the segment for possibly inserting into the table associated with given hash, constructing it if necessary.
getSegmentForTraversal(int) - Method in class groovyx.gpars.extra166y.CustomConcurrentHashMap: Returns the segment for traversing table for key with given hash.
getSender() - Method in class groovyx.gpars.actor.AbstractLoopingActor: Retrieves the sender actor of the currently processed message.
getSender() - Method in class groovyx.gpars.actor.ActorMessage
getSender() - Method in class groovyx.gpars.actor.impl.ReplyingMessageStream
getSerialHost(UUID, Object) - Method in class groovyx.gpars.remote.LocalHost
getSerialHost(UUID, Object) - Method in class groovyx.gpars.serial.SerialContext
getSerialHost(UUID, Object) - Method in class groovyx.gpars.serial.SerialHandles
getSerialId() - Method in class groovyx.gpars.serial.SerialHandle: Serial id of the object
getSourceUnit() - Method in class groovyx.gpars.activeobject.ActiveObjectASTTransformation.MyClassCodeExpressionTransformer
getStateObject() - Method in class groovyx.gpars.dataflow.operator.DataflowProcessor: Retrieves the custom state object
getSubscribers() - Method in class groovyx.gpars.serial.SerialHandle: Getter for subscribers
getTableForAdd(CustomConcurrentHashMap) - Method in class groovyx.gpars.extra166y.CustomConcurrentHashMap.Segment
getTableForTraversal() - Method in class groovyx.gpars.extra166y.CustomConcurrentHashMap.Segment
getTermination() - Method in class groovyx.gpars.dataflow.operator.CountingPoisonPill: Retrieves the promise for termination
getTermination() - Method in class groovyx.gpars.dataflow.operator.ImmediateCountingPoisonPill: Retrieves the promise for termination
getTermination() - Method in class groovyx.gpars.dataflow.operator.PoisonTrackCounter
getThreadPool() - Method in class groovyx.gpars.group.PGroup
getThreadPool() - Method in class groovyx.gpars.util.AsyncMessagingCore
getThreshold() - Method in class groovyx.gpars.extra166y.AbstractParallelAnyArray: Returns lazily computed threshold.
getTimerFactory() - Static method in class groovyx.gpars.GParsConfig
getTo() - Method in class groovyx.gpars.actor.impl.MessageStream.SendTo
getUnsafe() - Static method in class groovyx.gpars.extra166y.CustomConcurrentHashMap: Returns a sun.misc.Unsafe.
getVal() - Method in class groovyx.gpars.agent.AgentBase: A shorthand method for safe message-based retrieval of the internal state.
getVal() - Method in class groovyx.gpars.dataflow.DataflowQueue: Retrieves the value at the head of the buffer.
getVal(long, TimeUnit) - Method in class groovyx.gpars.dataflow.DataflowQueue: Retrieves the value at the head of the buffer.
getVal() - Method in interface groovyx.gpars.dataflow.DataflowReadChannel: Reads the current value of the channel.
getVal(long, TimeUnit) - Method in interface groovyx.gpars.dataflow.DataflowReadChannel: Reads the current value of the channel.
getVal() - Method in class groovyx.gpars.dataflow.expression.DataflowExpression: Reads the value of the variable.
getVal(long, TimeUnit) - Method in class groovyx.gpars.dataflow.expression.DataflowExpression: Reads the value of the variable.
getVal() - Method in class groovyx.gpars.dataflow.LazyDataflowVariable
getVal(long, TimeUnit) - Method in class groovyx.gpars.dataflow.LazyDataflowVariable
getVal() - Method in class groovyx.gpars.dataflow.stream.DataflowStreamReadAdapter
getVal(long, TimeUnit) - Method in class groovyx.gpars.dataflow.stream.DataflowStreamReadAdapter
getVal() - Method in class groovyx.gpars.dataflow.SyncDataflowStreamReadAdapter
getVal(long, TimeUnit) - Method in class groovyx.gpars.dataflow.SyncDataflowStreamReadAdapter
getVal() - Method in class groovyx.gpars.dataflow.SyncDataflowVariable: Reads the value of the variable.
getVal(long, TimeUnit) - Method in class groovyx.gpars.dataflow.SyncDataflowVariable: Reads the value of the variable.
getValAsync(MessageStream) - Method in class groovyx.gpars.dataflow.DataflowQueue: Asynchronously retrieves the value at the head of the buffer.
getValAsync(Object, MessageStream) - Method in class groovyx.gpars.dataflow.DataflowQueue: Asynchronously retrieves the value at the head of the buffer.
getValAsync(MessageStream) - Method in interface groovyx.gpars.dataflow.DataflowReadChannel: Asynchronously retrieves the value from the channel.
getValAsync(Object, MessageStream) - Method in interface groovyx.gpars.dataflow.DataflowReadChannel: Asynchronously retrieves the value from the channel.
getValAsync(MessageStream) - Method in class groovyx.gpars.dataflow.expression.DataflowExpression: Asynchronously retrieves the value of the variable.
getValAsync(Object, MessageStream) - Method in class groovyx.gpars.dataflow.expression.DataflowExpression: Used by Dataflow operators.
getValAsync(MessageStream) - Method in class groovyx.gpars.dataflow.LazyDataflowVariable
getValAsync(Object, MessageStream) - Method in class groovyx.gpars.dataflow.LazyDataflowVariable
getValAsync(MessageStream) - Method in class groovyx.gpars.dataflow.stream.DataflowStreamReadAdapter
getValAsync(Object, MessageStream) - Method in class groovyx.gpars.dataflow.stream.DataflowStreamReadAdapter
getValAsync(MessageStream) - Method in class groovyx.gpars.dataflow.SyncDataflowStreamReadAdapter
getValAsync(Object, MessageStream) - Method in class groovyx.gpars.dataflow.SyncDataflowStreamReadAdapter
getValue() - Method in class groovyx.gpars.dataflow.SelectResult
getValue() - Method in class groovyx.gpars.extra166y.CustomConcurrentHashMap.IntKeyIntValueNode
getValue() - Method in class groovyx.gpars.extra166y.CustomConcurrentHashMap.IntKeySelfValueNode
getValue() - Method in class groovyx.gpars.extra166y.CustomConcurrentHashMap.IntKeySoftValueNode
getValue() - Method in class groovyx.gpars.extra166y.CustomConcurrentHashMap.IntKeyStrongValueNode
getValue() - Method in class groovyx.gpars.extra166y.CustomConcurrentHashMap.IntKeyWeakValueNode
getValue() - Method in interface groovyx.gpars.extra166y.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 class groovyx.gpars.extra166y.CustomConcurrentHashMap.SoftKeyIntValueNode
getValue() - Method in class groovyx.gpars.extra166y.CustomConcurrentHashMap.SoftKeySelfValueNode
getValue() - Method in class groovyx.gpars.extra166y.CustomConcurrentHashMap.SoftKeySoftValueNode
getValue() - Method in class groovyx.gpars.extra166y.CustomConcurrentHashMap.SoftKeyStrongValueNode
getValue() - Method in class groovyx.gpars.extra166y.CustomConcurrentHashMap.SoftKeyWeakValueNode
getValue() - Method in class groovyx.gpars.extra166y.CustomConcurrentHashMap.StrongKeyIntValueNode
getValue() - Method in class groovyx.gpars.extra166y.CustomConcurrentHashMap.StrongKeySelfValueNode
getValue() - Method in class groovyx.gpars.extra166y.CustomConcurrentHashMap.StrongKeySoftValueNode
getValue() - Method in class groovyx.gpars.extra166y.CustomConcurrentHashMap.StrongKeyStrongValueNode
getValue() - Method in class groovyx.gpars.extra166y.CustomConcurrentHashMap.StrongKeyWeakValueNode
getValue() - Method in class groovyx.gpars.extra166y.CustomConcurrentHashMap.WeakKeyIntValueNode
getValue() - Method in class groovyx.gpars.extra166y.CustomConcurrentHashMap.WeakKeySelfValueNode
getValue() - Method in class groovyx.gpars.extra166y.CustomConcurrentHashMap.WeakKeySoftValueNode
getValue() - Method in class groovyx.gpars.extra166y.CustomConcurrentHashMap.WeakKeyStrongValueNode
getValue() - Method in class groovyx.gpars.extra166y.CustomConcurrentHashMap.WeakKeyWeakValueNode
getValue() - Method in class groovyx.gpars.extra166y.CustomConcurrentHashMap.WriteThroughEntry
gmemoize(Closure<T>) - Static method in class groovyx.gpars.GParsPoolUtil: Deprecated.
gmemoizeAtLeast(Closure<T>, int) - Static method in class groovyx.gpars.GParsPoolUtil: Deprecated.
gmemoizeAtMost(Closure<T>, int) - Static method in class groovyx.gpars.GParsPoolUtil: Deprecated.
gmemoizeBetween(Closure<T>, int, int) - Static method in class groovyx.gpars.GParsPoolUtil: Deprecated.
GPARS_POOLSIZE - Static variable in class groovyx.gpars.util.PoolUtils
GParsAtomicBooleanBlock - Class in groovyx.gpars.stm: A default implementation of org.multiverse.api.closures.AtomicBooleanClosure properly handling exception propagation
GParsAtomicBooleanBlock(Closure) - Constructor for class groovyx.gpars.stm.GParsAtomicBooleanBlock
GParsAtomicDoubleBlock - Class in groovyx.gpars.stm: A default implementation of org.multiverse.api.closures.AtomicDoubleClosure properly handling exception propagation
GParsAtomicDoubleBlock(Closure) - Constructor for class groovyx.gpars.stm.GParsAtomicDoubleBlock
GParsAtomicIntBlock - Class in groovyx.gpars.stm: A default implementation of org.multiverse.api.closures.AtomicIntClosure properly handling exception propagation
GParsAtomicIntBlock(Closure) - Constructor for class groovyx.gpars.stm.GParsAtomicIntBlock
GParsAtomicLongBlock - Class in groovyx.gpars.stm: A default implementation of org.multiverse.api.closures.AtomicLongClosure properly handling exception propagation
GParsAtomicLongBlock(Closure) - Constructor for class groovyx.gpars.stm.GParsAtomicLongBlock
GParsAtomicVoidBlock - Class in groovyx.gpars.stm: A default implementation of org.multiverse.api.closures.AtomicVoidClosure properly handling exception propagation
GParsAtomicVoidBlock(Closure) - Constructor for class groovyx.gpars.stm.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 for class groovyx.gpars.GParsConfig
GParsPoolUtil - Class in groovyx.gpars: This class forms the core of the DSL initialized by GParsPool.
GParsPoolUtil() - Constructor for class groovyx.gpars.GParsPoolUtil
GParsStm - Class in groovyx.gpars.stm: Provides access to GPars Stm services.
GParsStm() - Constructor for class groovyx.gpars.stm.GParsStm
GParsTxnExecutor<T> - Class in groovyx.gpars.stm: A default implementation of org.multiverse.api.closures.AtomicClosure properly handling exception propagation
GParsTxnExecutor(Closure) - Constructor for class groovyx.gpars.stm.GParsTxnExecutor
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 for class groovyx.gpars.dataflow.operator.component.GracefulShutdownListener: Hooks hooks the shared monitor
GracefulShutdownMonitor - Class in groovyx.gpars.dataflow.operator.component: The monitor will orchestrate a graceful shutdown, when its shutdownNetwork() method is called.
GracefulShutdownMonitor() - Constructor for class groovyx.gpars.dataflow.operator.component.GracefulShutdownMonitor: Uses the default timer delay
GracefulShutdownMonitor(long) - Constructor for class groovyx.gpars.dataflow.operator.component.GracefulShutdownMonitor: Allows to use a customized delay
gran - Variable in class groovyx.gpars.extra166y.PAS.FJDCMerger
gran - Variable in class groovyx.gpars.extra166y.PAS.FJDCSorter
gran - Variable in class groovyx.gpars.extra166y.PAS.FJDMerger
gran - Variable in class groovyx.gpars.extra166y.PAS.FJDSorter
gran - Variable in class groovyx.gpars.extra166y.PAS.FJLCMerger
gran - Variable in class groovyx.gpars.extra166y.PAS.FJLCSorter
gran - Variable in class groovyx.gpars.extra166y.PAS.FJLMerger
gran - Variable in class groovyx.gpars.extra166y.PAS.FJLSorter
gran - Variable in class groovyx.gpars.extra166y.PAS.FJOCMerger
gran - Variable in class groovyx.gpars.extra166y.PAS.FJOCSorter
gran - Variable in class groovyx.gpars.extra166y.PAS.FJOMerger
gran - Variable in class groovyx.gpars.extra166y.PAS.FJOSorter
grepParallel(Collection<T>, Object) - Static method in class groovyx.gpars.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, Object) - Static method in class groovyx.gpars.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(Map<K, V>, Object) - Static method in class groovyx.gpars.GParsPoolUtil: Creates a Parallel Array out of the supplied map and invokes the withFilter() method using the supplied rule as the filter predicate.
groovyx.gpars - package groovyx.gpars: This package holds classes for asynchronous collection processing.
groovyx.gpars.activeobject - package groovyx.gpars.activeobject
groovyx.gpars.actor - package groovyx.gpars.actor: This package holds classes forming the public actor API.
groovyx.gpars.actor.impl - package groovyx.gpars.actor.impl: This package holds classes some non-public aspects of actor implementation.
groovyx.gpars.agent - package groovyx.gpars.agent
groovyx.gpars.dataflow - package groovyx.gpars.dataflow: This package holds classes for basic dataflow concurrency constructs, like dataflow variables, streams and threads.
groovyx.gpars.dataflow.expression - package groovyx.gpars.dataflow.expression
groovyx.gpars.dataflow.impl - package groovyx.gpars.dataflow.impl
groovyx.gpars.dataflow.operator - package groovyx.gpars.dataflow.operator: This package holds classes representing operators and channels necessary for full dataflow concurrency.
groovyx.gpars.dataflow.operator.component - package groovyx.gpars.dataflow.operator.component
groovyx.gpars.dataflow.stream - package groovyx.gpars.dataflow.stream
groovyx.gpars.extra166y - package groovyx.gpars.extra166y: Collections supporting parallel operations.
groovyx.gpars.forkjoin - package groovyx.gpars.forkjoin
groovyx.gpars.group - package groovyx.gpars.group
groovyx.gpars.memoize - package groovyx.gpars.memoize
groovyx.gpars.pa - package groovyx.gpars.pa
groovyx.gpars.remote - package groovyx.gpars.remote: This package holds classes implementing the remote actors functionality.
groovyx.gpars.remote.message - package groovyx.gpars.remote.message: This package holds message classes for the remote actors implementation.
groovyx.gpars.remote.netty - package groovyx.gpars.remote.netty: This package holds implementation-specific classes implementing the remote actors functionality on top of Netty.
groovyx.gpars.scheduler - package groovyx.gpars.scheduler: This package holds thread pools / schedulers used by actors and dataflow concurrency.
groovyx.gpars.serial - package groovyx.gpars.serial: This package holds classes used for actor identification in the network.
groovyx.gpars.stm - package groovyx.gpars.stm
groovyx.gpars.util - package groovyx.gpars.util: Various utility classes enhancing basic Java concurrency constructs.
group - Variable in class groovyx.gpars.dataflow.LazyDataflowVariable
group - Variable in class groovyx.gpars.dataflow.operator.Pipeline
group - Static variable in class groovyx.gpars.remote.BroadcastDiscovery
groupByParallel(Collection<T>, Closure<K>) - Static method in class groovyx.gpars.GParsPoolUtil: Creates a Parallel Array out of the supplied collection/object and invokes the withMapping() method using the supplied closure as the mapping predicate.
groupByParallel(Object, Closure<K>) - Static method in class groovyx.gpars.GParsPoolUtil: Creates a Parallel Array out of the supplied collection/object and invokes the withMapping() method using the supplied closure as the mapping predicate.
groupByParallelPA(ParallelArray<T>, Closure<K>) - Static method in class groovyx.gpars.GParsPoolUtil
GuardedSelectRequest<T> - Class in groovyx.gpars.dataflow.impl: The base implementation of the SelectRequest interface, providing a useful default masking (guarding) functionality.
GuardedSelectRequest(List<Boolean>) - Constructor for class groovyx.gpars.dataflow.impl.GuardedSelectRequest
guards - Variable in class groovyx.gpars.dataflow.operator.DataflowSelector

H

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

I

id - Variable in class groovyx.gpars.actor.ActorTimerTask
id - Variable in class groovyx.gpars.remote.LocalNode
id - Variable in class groovyx.gpars.remote.netty.NettyTransportProvider.ClientHandler
id - Variable in class groovyx.gpars.remote.RemoteNode
id - Variable in class groovyx.gpars.serial.LocalHandle
id - Variable in class groovyx.gpars.serial.SerialHandles: Unique id of the provider
IDENTITY - Static variable in class groovyx.gpars.extra166y.CustomConcurrentHashMap: An Equivalence object performing identity-based comparisons and using System.identityHashCode(java.lang.Object) for hashing
identityPredicate() - Static method in class groovyx.gpars.extra166y.CommonOps: Returns a predicate evaluating to true if the first argument == the second.
immediate - Variable in class groovyx.gpars.dataflow.operator.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 for class groovyx.gpars.dataflow.operator.ImmediateCountingPoisonPill: Creates an immediate instance that could be used to stop operators in a network.
immediateInstance - Static variable in class groovyx.gpars.dataflow.operator.PoisonPill
in - Variable in class groovyx.gpars.extra166y.PAS.FJDScan
in - Variable in class groovyx.gpars.extra166y.PAS.FJLScan
in - Variable in class groovyx.gpars.extra166y.PAS.FJOScan
increaseCount() - Method in class groovyx.gpars.dataflow.impl.ResizeableCountDownLatch
increaseCount() - Method in class groovyx.gpars.dataflow.impl.ResizeableCountDownLatch.Sync
incrementCount() - Method in class groovyx.gpars.extra166y.CustomConcurrentHashMap.Segment
incrementParties() - Method in class groovyx.gpars.dataflow.stream.StreamCore: Increases the number of parties required to perform the data exchange
incrementParties() - Method in class groovyx.gpars.dataflow.stream.SyncDataflowStream: Increases the number of parties required to perform the data exchange
incrementParties() - Method in class groovyx.gpars.dataflow.SyncDataflowVariable: Increases the number of parties required to perform data exchange by one.
index - Variable in class groovyx.gpars.dataflow.impl.SelectCallback
index - Variable in class groovyx.gpars.dataflow.SelectResult
indexedMapper(Ops.BinaryOp<? super T, ? super U, ? extends V>, ParallelArrayWithMapping<W, U>, int) - Static method in class groovyx.gpars.extra166y.AbstractParallelAnyArray
indexedMapper(Ops.ObjectAndObjectToDouble<? super T, ? super U>, ParallelArrayWithMapping<W, U>, int) - Static method in class groovyx.gpars.extra166y.AbstractParallelAnyArray
indexedMapper(Ops.ObjectAndObjectToLong<? super T, ? super U>, ParallelArrayWithMapping<W, U>, int) - Static method in class groovyx.gpars.extra166y.AbstractParallelAnyArray
indexedMapper(Ops.ObjectAndDoubleToObject<? super T, ? extends V>, ParallelDoubleArrayWithDoubleMapping, int) - Static method in class groovyx.gpars.extra166y.AbstractParallelAnyArray
indexedMapper(Ops.ObjectAndDoubleToDouble<? super T>, ParallelDoubleArrayWithDoubleMapping, int) - Static method in class groovyx.gpars.extra166y.AbstractParallelAnyArray
indexedMapper(Ops.ObjectAndDoubleToLong<? super T>, ParallelDoubleArrayWithDoubleMapping, int) - Static method in class groovyx.gpars.extra166y.AbstractParallelAnyArray
indexedMapper(Ops.ObjectAndLongToObject<? super T, ? extends V>, ParallelLongArrayWithLongMapping, int) - Static method in class groovyx.gpars.extra166y.AbstractParallelAnyArray
indexedMapper(Ops.ObjectAndLongToDouble<? super T>, ParallelLongArrayWithLongMapping, int) - Static method in class groovyx.gpars.extra166y.AbstractParallelAnyArray
indexedMapper(Ops.ObjectAndLongToLong<? super T>, ParallelLongArrayWithLongMapping, int) - Static method in class groovyx.gpars.extra166y.AbstractParallelAnyArray
indexedMapper(Ops.DoubleAndObjectToObject<? super U, ? extends V>, ParallelArrayWithMapping<W, U>, int) - Static method in class groovyx.gpars.extra166y.AbstractParallelAnyArray
indexedMapper(Ops.DoubleAndObjectToDouble<? super U>, ParallelArrayWithMapping<W, U>, int) - Static method in class groovyx.gpars.extra166y.AbstractParallelAnyArray
indexedMapper(Ops.DoubleAndObjectToLong<? super U>, ParallelArrayWithMapping<W, U>, int) - Static method in class groovyx.gpars.extra166y.AbstractParallelAnyArray
indexedMapper(Ops.DoubleAndDoubleToObject<? extends V>, ParallelDoubleArrayWithDoubleMapping, int) - Static method in class groovyx.gpars.extra166y.AbstractParallelAnyArray
indexedMapper(Ops.BinaryDoubleOp, ParallelDoubleArrayWithDoubleMapping, int) - Static method in class groovyx.gpars.extra166y.AbstractParallelAnyArray
indexedMapper(Ops.DoubleAndDoubleToLong, ParallelDoubleArrayWithDoubleMapping, int) - Static method in class groovyx.gpars.extra166y.AbstractParallelAnyArray
indexedMapper(Ops.DoubleAndLongToObject<? extends V>, ParallelLongArrayWithLongMapping, int) - Static method in class groovyx.gpars.extra166y.AbstractParallelAnyArray
indexedMapper(Ops.DoubleAndLongToDouble, ParallelLongArrayWithLongMapping, int) - Static method in class groovyx.gpars.extra166y.AbstractParallelAnyArray
indexedMapper(Ops.DoubleAndLongToLong, ParallelLongArrayWithLongMapping, int) - Static method in class groovyx.gpars.extra166y.AbstractParallelAnyArray
indexedMapper(Ops.LongAndObjectToObject<? super U, ? extends V>, ParallelArrayWithMapping<W, U>, int) - Static method in class groovyx.gpars.extra166y.AbstractParallelAnyArray
indexedMapper(Ops.LongAndObjectToDouble<? super U>, ParallelArrayWithMapping<W, U>, int) - Static method in class groovyx.gpars.extra166y.AbstractParallelAnyArray
indexedMapper(Ops.LongAndObjectToLong<? super U>, ParallelArrayWithMapping<W, U>, int) - Static method in class groovyx.gpars.extra166y.AbstractParallelAnyArray
indexedMapper(Ops.LongAndDoubleToObject<? extends V>, ParallelDoubleArrayWithDoubleMapping, int) - Static method in class groovyx.gpars.extra166y.AbstractParallelAnyArray
indexedMapper(Ops.LongAndDoubleToDouble, ParallelDoubleArrayWithDoubleMapping, int) - Static method in class groovyx.gpars.extra166y.AbstractParallelAnyArray
indexedMapper(Ops.LongAndDoubleToLong, ParallelDoubleArrayWithDoubleMapping, int) - Static method in class groovyx.gpars.extra166y.AbstractParallelAnyArray
indexedMapper(Ops.LongAndLongToObject<? extends V>, ParallelLongArrayWithLongMapping, int) - Static method in class groovyx.gpars.extra166y.AbstractParallelAnyArray
indexedMapper(Ops.LongAndLongToDouble, ParallelLongArrayWithLongMapping, int) - Static method in class groovyx.gpars.extra166y.AbstractParallelAnyArray
indexedMapper(Ops.BinaryLongOp, ParallelLongArrayWithLongMapping, int) - Static method in class groovyx.gpars.extra166y.AbstractParallelAnyArray
indexedSelector(Ops.BinaryPredicate<? super T, ? super U>, ParallelArrayWithMapping<W, U>, int) - Static method in class groovyx.gpars.extra166y.AbstractParallelAnyArray
indexedSelector(Ops.BinaryDoublePredicate, ParallelDoubleArrayWithDoubleMapping, int) - Static method in class groovyx.gpars.extra166y.AbstractParallelAnyArray
indexedSelector(Ops.BinaryLongPredicate, ParallelLongArrayWithLongMapping, int) - Static method in class groovyx.gpars.extra166y.AbstractParallelAnyArray
indexOf(double) - Method in class groovyx.gpars.extra166y.AbstractParallelAnyArray.DUPap
indexOf(long) - Method in class groovyx.gpars.extra166y.AbstractParallelAnyArray.LUPap
indexOf(T) - Method in class groovyx.gpars.extra166y.AbstractParallelAnyArray.OUPap
indexOf(Object) - Method in class groovyx.gpars.extra166y.ParallelArray.AsList
indexOf(T) - Method in class groovyx.gpars.extra166y.ParallelArray: Returns the index of some element equal to given target, or -1 if not present.
indexOf(T) - Method in class groovyx.gpars.extra166y.ParallelArrayWithBounds: Returns the index of some element equal to given target, or -1 if not present.
indexOf(Object) - Method in class groovyx.gpars.extra166y.ParallelDoubleArray.AsList
indexOf(double) - Method in class groovyx.gpars.extra166y.ParallelDoubleArray: Returns the index of some element equal to given target, or -1 if not present.
indexOf(double) - Method in class groovyx.gpars.extra166y.ParallelDoubleArrayWithBounds: Returns the index of some element equal to given target, or -1 if not present.
indexOf(Object) - Method in class groovyx.gpars.extra166y.ParallelLongArray.AsList
indexOf(long) - Method in class groovyx.gpars.extra166y.ParallelLongArray: Returns the index of some element equal to given target, or -1 if not present.
indexOf(long) - Method in class groovyx.gpars.extra166y.ParallelLongArrayWithBounds: Returns the index of some element equal to given target, or -1 if not present.
indexOfMax() - Method in interface groovyx.gpars.extra166y.ParallelArray.SummaryStatistics: Returns the index of the maximum element, or -1 if empty
indexOfMax() - Method in interface groovyx.gpars.extra166y.ParallelDoubleArray.SummaryStatistics: Returns the index of the maximum element, or -1 if empty
indexOfMax() - Method in interface groovyx.gpars.extra166y.ParallelLongArray.SummaryStatistics: Returns the index of the maximum element, or -1 if empty
indexOfMax - Variable in class groovyx.gpars.extra166y.PAS.FJDStats
indexOfMax() - Method in class groovyx.gpars.extra166y.PAS.FJDStats
indexOfMax - Variable in class groovyx.gpars.extra166y.PAS.FJLStats
indexOfMax() - Method in class groovyx.gpars.extra166y.PAS.FJLStats
indexOfMax - Variable in class groovyx.gpars.extra166y.PAS.FJOStats
indexOfMax() - Method in class groovyx.gpars.extra166y.PAS.FJOStats
indexOfMin() - Method in interface groovyx.gpars.extra166y.ParallelArray.SummaryStatistics: Returns the index of the minimum element, or -1 if empty
indexOfMin() - Method in interface groovyx.gpars.extra166y.ParallelDoubleArray.SummaryStatistics: Returns the index of the minimum element, or -1 if empty
indexOfMin() - Method in interface groovyx.gpars.extra166y.ParallelLongArray.SummaryStatistics: Returns the index of the minimum element, or -1 if empty
indexOfMin - Variable in class groovyx.gpars.extra166y.PAS.FJDStats
indexOfMin() - Method in class groovyx.gpars.extra166y.PAS.FJDStats
indexOfMin - Variable in class groovyx.gpars.extra166y.PAS.FJLStats
indexOfMin() - Method in class groovyx.gpars.extra166y.PAS.FJLStats
indexOfMin - Variable in class groovyx.gpars.extra166y.PAS.FJOStats
indexOfMin() - Method in class groovyx.gpars.extra166y.PAS.FJOStats
indices - Variable in class groovyx.gpars.extra166y.PAS.FJRemoveAll
indices - Variable in class groovyx.gpars.extra166y.PAS.FJRemoveAllDriver
indices - Variable in class groovyx.gpars.extra166y.PAS.FJSelectAllDriver
inequalityPredicate() - Static method in class groovyx.gpars.extra166y.CommonOps: Returns a predicate evaluating to true if the first argument !equals the second.
init(ASTNode[]) - Static method in class groovyx.gpars.util.AsyncFunASTTransformation
initializationStarted - Variable in class groovyx.gpars.dataflow.LazyDataflowVariable
initialize(Closure) - Method in class groovyx.gpars.actor.AbstractLoopingActor: Builds the async messaging core using the supplied code handler
initialize() - Method in class groovyx.gpars.dataflow.LazyDataflowVariable
initializer - Variable in class groovyx.gpars.dataflow.LazyDataflowVariable
initialOffset - Variable in class groovyx.gpars.extra166y.PAS.FJSelectAllDriver
initialSegmentCapacity - Variable in class groovyx.gpars.extra166y.CustomConcurrentHashMap: The initial size of Segment tables when they are first constructed
initialValue() - Method in class groovyx.gpars.ThreadLocalPools
initiateShutdown() - Method in class groovyx.gpars.dataflow.operator.component.GracefulShutdownListener: Starts the shutdown phase by turning shutdownFlag on
injectParallel(Collection<T>, Closure) - Static method in class groovyx.gpars.GParsPoolUtil: Creates a Parallel Array out of the supplied collection/object and invokes its reduce() method using the supplied closure as the reduction operation.
injectParallel(Object, Closure) - Static method in class groovyx.gpars.GParsPoolUtil: Creates a Parallel Array out of the supplied collection/object and invokes its reduce() method using the supplied closure as the reduction operation.
injectParallel(Collection<T>, T, Closure) - Static method in class groovyx.gpars.GParsPoolUtil: Creates a Parallel Array out of the supplied collection/object and invokes its reduce() method using the supplied closure as the reduction operation.
injectParallel(Object, Object, Closure) - Static method in class groovyx.gpars.GParsPoolUtil: Creates a Parallel Array out of the supplied collection/object and invokes its reduce() method using the supplied closure as the reduction operation.
inorderMove(PAS.FJRemoveAll, int) - Static method in class groovyx.gpars.extra166y.PAS.FJRemoveAllDriver: Inorder traversal to move indexed elements across reachable nodes.
inputQueue - Variable in class groovyx.gpars.actor.impl.SequentialProcessingActor: Stored incoming messages.
inputQueueUpdater - Static variable in class groovyx.gpars.actor.impl.SequentialProcessingActor
INPUTS - Static variable in class groovyx.gpars.dataflow.operator.DataflowProcessor
inputs - Variable in class groovyx.gpars.dataflow.operator.DataflowProcessorActor
insertElementAt(int, T) - Method in class groovyx.gpars.extra166y.ParallelArray
insertElementAt(int, double) - Method in class groovyx.gpars.extra166y.ParallelDoubleArray
insertElementAt(int, long) - Method in class groovyx.gpars.extra166y.ParallelLongArray
INSERTION_SORT_THRESHOLD - Static variable in class groovyx.gpars.extra166y.PAS: Cutoff for when to use insertion-sort instead of quicksort
insertSlotsAt(int, int) - Method in class groovyx.gpars.extra166y.ParallelArray: Makes len slots available at index.
insertSlotsAt(int, int) - Method in class groovyx.gpars.extra166y.ParallelDoubleArray: Makes len slots available at index.
insertSlotsAt(int, int) - Method in class groovyx.gpars.extra166y.ParallelLongArray: Makes len slots available at index.
inside - Variable in class groovyx.gpars.util.DefaultMessageQueue
inside - Variable in class groovyx.gpars.util.FQMessageQueue
instance - Static variable in class groovyx.gpars.remote.netty.NettyTransportProvider.MyThreadFactory
instanceofPredicate(Class) - Static method in class groovyx.gpars.extra166y.CommonOps: Returns a predicate evaluating to true if its argument is an instance of (see Class.isInstance(java.lang.Object) the given type (class).
INT_STRING - Static variable in class groovyx.gpars.extra166y.CustomConcurrentHashMap: Config string for int maps
intAdder() - Static method in class groovyx.gpars.extra166y.CommonOps: Returns a reducer that adds two int elements.
intEqualityPredicate() - Static method in class groovyx.gpars.extra166y.CommonOps: Returns a predicate evaluating to true if the first argument == the second.
intern(K) - Method in class groovyx.gpars.extra166y.CustomConcurrentHashMap.KeySet: Returns an element equivalent to the given element with respect to this set's Equivalence, if such an element exists, else adds and returns the given element.
INTERNAL_ACTIVE_OBJECT_ACTOR - Static variable in annotation type groovyx.gpars.activeobject.ActiveObject
InternalActor - Class in groovyx.gpars.activeobject: Backs active objects and invokes all object's active methods.
InternalActor() - Constructor for class groovyx.gpars.activeobject.InternalActor: Just like DynamicDispatchActor, except that the actual method dispatch is static through the closure passed to the initialize() method.
internalCompute(int, int, int) - Method in class groovyx.gpars.extra166y.PAS.FJBase
internalPhase0() - Method in class groovyx.gpars.extra166y.PAS.FJSelectAll
internalPhase1() - Method in class groovyx.gpars.extra166y.PAS.FJSelectAll
intInequalityPredicate() - Static method in class groovyx.gpars.extra166y.CommonOps: Returns a predicate evaluating to true if the first argument != the second.
into(DataflowWriteChannel<T>) - Method in class groovyx.gpars.dataflow.DataflowQueue
into(Pool, DataflowWriteChannel<T>) - Method in class groovyx.gpars.dataflow.DataflowQueue
into(PGroup, DataflowWriteChannel<T>) - Method in class groovyx.gpars.dataflow.DataflowQueue
into(Map<String, Object>, DataflowWriteChannel<T>) - Method in class groovyx.gpars.dataflow.DataflowQueue
into(Pool, Map<String, Object>, DataflowWriteChannel<T>) - Method in class groovyx.gpars.dataflow.DataflowQueue
into(PGroup, Map<String, Object>, DataflowWriteChannel<T>) - Method in class groovyx.gpars.dataflow.DataflowQueue
into(DataflowWriteChannel<T>) - Method in interface groovyx.gpars.dataflow.DataflowReadChannel: Makes the output of the current channel to be an input for the specified channel
into(Pool, DataflowWriteChannel<T>) - Method in interface groovyx.gpars.dataflow.DataflowReadChannel: Makes the output of the current channel to be an input for the specified channel
into(PGroup, DataflowWriteChannel<T>) - Method in interface groovyx.gpars.dataflow.DataflowReadChannel: Makes the output of the current channel to be an input for the specified channel
into(Map<String, Object>, DataflowWriteChannel<T>) - Method in interface groovyx.gpars.dataflow.DataflowReadChannel: Makes the output of the current channel to be an input for the specified channel
into(Pool, Map<String, Object>, DataflowWriteChannel<T>) - Method in interface groovyx.gpars.dataflow.DataflowReadChannel: Makes the output of the current channel to be an input for the specified channel
into(PGroup, Map<String, Object>, DataflowWriteChannel<T>) - Method in interface groovyx.gpars.dataflow.DataflowReadChannel: Makes the output of the current channel to be an input for the specified channel
into(DataflowWriteChannel<T>) - Method in class groovyx.gpars.dataflow.expression.DataflowExpression
into(Pool, DataflowWriteChannel<T>) - Method in class groovyx.gpars.dataflow.expression.DataflowExpression
into(PGroup, DataflowWriteChannel<T>) - Method in class groovyx.gpars.dataflow.expression.DataflowExpression
into(Map<String, Object>, DataflowWriteChannel<T>) - Method in class groovyx.gpars.dataflow.expression.DataflowExpression
into(Pool, Map<String, Object>, DataflowWriteChannel<T>) - Method in class groovyx.gpars.dataflow.expression.DataflowExpression
into(PGroup, Map<String, Object>, DataflowWriteChannel<T>) - Method in class groovyx.gpars.dataflow.expression.DataflowExpression
into(DataflowWriteChannel<V>) - Method in class groovyx.gpars.dataflow.operator.Pipeline: Makes the output of the pipeline to be an input for the specified channel
into(Map<String, Object>, DataflowWriteChannel<V>) - Method in class groovyx.gpars.dataflow.operator.Pipeline: Makes the output of the pipeline to be an input for the specified channel
into(DataflowWriteChannel<T>) - Method in class groovyx.gpars.dataflow.stream.DataflowStreamReadAdapter
into(Pool, DataflowWriteChannel<T>) - Method in class groovyx.gpars.dataflow.stream.DataflowStreamReadAdapter
into(PGroup, DataflowWriteChannel<T>) - Method in class groovyx.gpars.dataflow.stream.DataflowStreamReadAdapter
into(Map<String, Object>, DataflowWriteChannel<T>) - Method in class groovyx.gpars.dataflow.stream.DataflowStreamReadAdapter
into(Pool, Map<String, Object>, DataflowWriteChannel<T>) - Method in class groovyx.gpars.dataflow.stream.DataflowStreamReadAdapter
into(PGroup, Map<String, Object>, DataflowWriteChannel<T>) - Method in class groovyx.gpars.dataflow.stream.DataflowStreamReadAdapter
intRandom() - Static method in class groovyx.gpars.extra166y.CommonOps: Returns a generator producing uniform random values with the same properties as Random.nextInt().
intRandom(int) - Static method in class groovyx.gpars.extra166y.CommonOps: Returns a generator producing uniform random values with the same properties as Random.nextInt(int).
intRandom(int, int) - Static method in class groovyx.gpars.extra166y.CommonOps: Returns a generator producing uniform random values between the given least value (inclusive) and bound (exclusive).
invokeMethod(String, Object) - Method in class groovyx.gpars.actor.ForwardingDelegate
invokeMethod(String, Object) - Method in class groovyx.gpars.actor.impl.RunnableBackedBlockingActor.RunnableBackedPooledActorDelegate
invokeMethod(String, Object) - Method in class groovyx.gpars.dataflow.Dataflows: Invokes the given method.
invokeMethod(String, Object) - Method in class groovyx.gpars.dataflow.expression.DataflowExpression: Invokes the method on itself or creates an expression, which will invoke the method n the bound value, once it is available.
isActive() - Method in class groovyx.gpars.actor.AbstractLoopingActor
isActive() - Method in class groovyx.gpars.actor.Actor: Checks the current status of the Actor.
isActive() - Method in class groovyx.gpars.actor.Actor.RemoteActor
isActive() - Method in class groovyx.gpars.actor.impl.SequentialProcessingActor: Checks the current status of the Actor.
isActorThread() - Method in class groovyx.gpars.actor.Actor: Checks whether the current thread is the actor's current thread.
isAssignablePredicate(Class) - Static method in class groovyx.gpars.extra166y.CommonOps: Returns a predicate evaluating to true if its argument is assignable from (see Class.isAssignableFrom(java.lang.Class<?>) the given type (class).
isBound() - Method in class groovyx.gpars.dataflow.DataflowQueue: Check if value has been set already for this expression
isBound() - Method in interface groovyx.gpars.dataflow.DataflowReadChannel: Check if value has been set already for this expression
isBound() - Method in class groovyx.gpars.dataflow.expression.DataflowExpression: Check if value has been set already for this expression
isBound() - Method in interface groovyx.gpars.dataflow.Promise: Check if value has been set already for this expression
isBound() - Method in class groovyx.gpars.dataflow.stream.DataflowStreamReadAdapter
isBound() - Method in class groovyx.gpars.dataflow.SyncDataflowStreamReadAdapter
isComplete() - Method in class groovyx.gpars.dataflow.operator.Pipeline
isConcurrent(Object) - Static method in class groovyx.gpars.GParsPoolUtil: Indicates whether the iterative methods like each() or collect() work have been altered to work concurrently.
isConnected() - Method in class groovyx.gpars.remote.RemoteHost
isControlMessage(Object) - Static method in class groovyx.gpars.dataflow.operator.DataflowProcessorActor
isEmpty() - Method in interface groovyx.gpars.dataflow.stream.FList
isEmpty() - Method in class groovyx.gpars.dataflow.stream.StreamCore: Indicates, whether the first element in the stream is an eos
isEmpty() - Method in class groovyx.gpars.extra166y.AbstractParallelAnyArray: Returns true if there are no elements.
isEmpty() - Method in class groovyx.gpars.extra166y.CustomConcurrentHashMap.EntrySet
isEmpty() - Method in class groovyx.gpars.extra166y.CustomConcurrentHashMap: Returns true if this map contains no key-value mappings.
isEmpty() - Method in class groovyx.gpars.extra166y.CustomConcurrentHashMap.KeySet: Returns true if this set contains no elements.
isEmpty() - Method in class groovyx.gpars.extra166y.CustomConcurrentHashMap.KeySetView
isEmpty() - Method in class groovyx.gpars.extra166y.CustomConcurrentHashMap.Values
isEmpty() - Method in class groovyx.gpars.extra166y.ParallelArray.AsList
isEmpty() - Method in class groovyx.gpars.extra166y.ParallelDoubleArray.AsList
isEmpty() - Method in class groovyx.gpars.extra166y.ParallelLongArray.AsList
isEmpty() - Method in class groovyx.gpars.ThreadLocalPools: Indicates whether the stack is empty
isEmpty() - Method in class groovyx.gpars.util.DefaultMessageQueue
isEmpty() - Method in class groovyx.gpars.util.FQMessageQueue.EmptyNode
isEmpty() - Method in class groovyx.gpars.util.FQMessageQueue
isEmpty() - Method in class groovyx.gpars.util.FQMessageQueue.Node
isEmpty() - Method in interface groovyx.gpars.util.MessageQueue
isEmptyWithRespectToSync() - Method in class groovyx.gpars.dataflow.stream.SyncDataflowStream
isError() - Method in class groovyx.gpars.dataflow.DataflowVariable: Checks if the promise is bound to an error
isError() - Method in class groovyx.gpars.dataflow.LazyDataflowVariable: Checks if the promise is bound to an error
isError() - Method in interface groovyx.gpars.dataflow.Promise: Checks if the promise is bound to an error
isFair() - Method in class groovyx.gpars.actor.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 class groovyx.gpars.agent.AgentCore: Retrieves the agent's fairness flag Fair agents give up the thread after processing each message, non-fair agents keep a thread until their message queue is empty.
isFair() - Method in class groovyx.gpars.util.AsyncMessagingCore: Retrieves the agent's fairness flag Fair agents give up the thread after processing each message, non-fair agents keep a thread until their message queue is empty.
isIdle() - Method in class groovyx.gpars.dataflow.operator.component.GracefulShutdownListener: A quick check on, whether the operator/selector is in the Idle state
isIdleAndNoIncomingMessages() - Method in class groovyx.gpars.dataflow.operator.component.GracefulShutdownListener: A more sophisticated test for being Idle
isImmediate() - Method in class groovyx.gpars.dataflow.operator.PoisonPill
isInternal - Variable in class groovyx.gpars.extra166y.PAS.FJSelectAll
isListAccepting(Closure<T>) - Static method in class groovyx.gpars.group.PGroup
isNonNullPredicate() - Static method in class groovyx.gpars.extra166y.CommonOps: Returns a predicate evaluating to true if its argument is non-null.
isNullPredicate() - Static method in class groovyx.gpars.extra166y.CommonOps: Returns a predicate evaluating to true if its argument is null.
isReleasedFlag() - Method in class groovyx.gpars.dataflow.impl.ResizeableCountDownLatch
isRootActiveObject(ClassNode) - Static method in class groovyx.gpars.activeobject.ActiveObjectASTTransformation
isSelected(int) - Method in class groovyx.gpars.extra166y.AbstractParallelAnyArray.DFDCPap
isSelected(int) - Method in class groovyx.gpars.extra166y.AbstractParallelAnyArray.DFDMPap
isSelected(int) - Method in class groovyx.gpars.extra166y.AbstractParallelAnyArray.DFLCPap
isSelected(int) - Method in class groovyx.gpars.extra166y.AbstractParallelAnyArray.DFLMPap
isSelected(int) - Method in class groovyx.gpars.extra166y.AbstractParallelAnyArray.DFOCPap
isSelected(int) - Method in class groovyx.gpars.extra166y.AbstractParallelAnyArray.DFOMPap
isSelected(int) - Method in class groovyx.gpars.extra166y.AbstractParallelAnyArray.DFPap
isSelected(int) - Method in class groovyx.gpars.extra166y.AbstractParallelAnyArray.DRDCPap
isSelected(int) - Method in class groovyx.gpars.extra166y.AbstractParallelAnyArray.DRDMPap
isSelected(int) - Method in class groovyx.gpars.extra166y.AbstractParallelAnyArray.DRLCPap
isSelected(int) - Method in class groovyx.gpars.extra166y.AbstractParallelAnyArray.DRLMPap
isSelected(int) - Method in class groovyx.gpars.extra166y.AbstractParallelAnyArray.DROCPap
isSelected(int) - Method in class groovyx.gpars.extra166y.AbstractParallelAnyArray.DROMPap
isSelected(int) - Method in class groovyx.gpars.extra166y.AbstractParallelAnyArray.DRPap
isSelected(int) - Method in class groovyx.gpars.extra166y.AbstractParallelAnyArray
isSelected(int) - Method in class groovyx.gpars.extra166y.AbstractParallelAnyArray.LFDCPap
isSelected(int) - Method in class groovyx.gpars.extra166y.AbstractParallelAnyArray.LFDMPap
isSelected(int) - Method in class groovyx.gpars.extra166y.AbstractParallelAnyArray.LFLCPap
isSelected(int) - Method in class groovyx.gpars.extra166y.AbstractParallelAnyArray.LFLMPap
isSelected(int) - Method in class groovyx.gpars.extra166y.AbstractParallelAnyArray.LFOCPap
isSelected(int) - Method in class groovyx.gpars.extra166y.AbstractParallelAnyArray.LFOMPap
isSelected(int) - Method in class groovyx.gpars.extra166y.AbstractParallelAnyArray.LFPap
isSelected(int) - Method in class groovyx.gpars.extra166y.AbstractParallelAnyArray.LRDCPap
isSelected(int) - Method in class groovyx.gpars.extra166y.AbstractParallelAnyArray.LRDMPap
isSelected(int) - Method in class groovyx.gpars.extra166y.AbstractParallelAnyArray.LRLCPap
isSelected(int) - Method in class groovyx.gpars.extra166y.AbstractParallelAnyArray.LRLMPap
isSelected(int) - Method in class groovyx.gpars.extra166y.AbstractParallelAnyArray.LROCPap
isSelected(int) - Method in class groovyx.gpars.extra166y.AbstractParallelAnyArray.LROMPap
isSelected(int) - Method in class groovyx.gpars.extra166y.AbstractParallelAnyArray.LRPap
isSelected(int) - Method in class groovyx.gpars.extra166y.AbstractParallelAnyArray.OFDCPap
isSelected(int) - Method in class groovyx.gpars.extra166y.AbstractParallelAnyArray.OFDMPap
isSelected(int) - Method in class groovyx.gpars.extra166y.AbstractParallelAnyArray.OFLCPap
isSelected(int) - Method in class groovyx.gpars.extra166y.AbstractParallelAnyArray.OFLMPap
isSelected(int) - Method in class groovyx.gpars.extra166y.AbstractParallelAnyArray.OFOCPap
isSelected(int) - Method in class groovyx.gpars.extra166y.AbstractParallelAnyArray.OFOMPap
isSelected(int) - Method in class groovyx.gpars.extra166y.AbstractParallelAnyArray.OFPap
isSelected(int) - Method in class groovyx.gpars.extra166y.AbstractParallelAnyArray.ORDCPap
isSelected(int) - Method in class groovyx.gpars.extra166y.AbstractParallelAnyArray.ORDMPap
isSelected(int) - Method in class groovyx.gpars.extra166y.AbstractParallelAnyArray.ORLCPap
isSelected(int) - Method in class groovyx.gpars.extra166y.AbstractParallelAnyArray.ORLMPap
isSelected(int) - Method in class groovyx.gpars.extra166y.AbstractParallelAnyArray.OROCPap
isSelected(int) - Method in class groovyx.gpars.extra166y.AbstractParallelAnyArray.OROMPap
isSelected(int) - Method in class groovyx.gpars.extra166y.AbstractParallelAnyArray.ORPap
isSet - Variable in class groovyx.gpars.actor.impl.MessageStream.ResultWaiter
issues - Variable in exception groovyx.gpars.actor.impl.ActorReplyException
iterator() - Method in class groovyx.gpars.dataflow.DataflowQueue: Returns an iterator over a current snapshot of the buffer's content.
iterator() - Method in class groovyx.gpars.dataflow.Dataflows: Convenience method to play nicely with Groovy object iteration methods.
iterator() - Method in class groovyx.gpars.dataflow.stream.DataflowStreamReadAdapter
iterator() - Method in class groovyx.gpars.dataflow.stream.StreamCore: Builds an iterator to iterate over the stream
iterator() - Method in class groovyx.gpars.dataflow.SyncDataflowStreamReadAdapter
iterator() - Method in class groovyx.gpars.extra166y.AbstractParallelAnyArray.Sequentially
iterator() - Method in class groovyx.gpars.extra166y.AbstractParallelAnyArray.SequentiallyAsDouble
iterator() - Method in class groovyx.gpars.extra166y.AbstractParallelAnyArray.SequentiallyAsLong
iterator() - Method in class groovyx.gpars.extra166y.CustomConcurrentHashMap.EntrySet
iterator() - Method in class groovyx.gpars.extra166y.CustomConcurrentHashMap.KeySet: Returns a weakly consistent iterator over the elements in this set, that may reflect some, all or none of the changes made to the set after the iterator was created.
iterator() - Method in class groovyx.gpars.extra166y.CustomConcurrentHashMap.KeySetView
iterator() - Method in class groovyx.gpars.extra166y.CustomConcurrentHashMap.Values
iterator() - Method in class groovyx.gpars.extra166y.ParallelArray.AsList
iterator() - Method in class groovyx.gpars.extra166y.ParallelArray: Returns an iterator stepping through each element of the array up to the current limit.
iterator() - Method in class groovyx.gpars.extra166y.ParallelDoubleArray.AsList
iterator() - Method in class groovyx.gpars.extra166y.ParallelDoubleArray: Returns an iterator stepping through each element of the array up to the current limit.
iterator() - Method in class groovyx.gpars.extra166y.ParallelLongArray.AsList
iterator() - Method in class groovyx.gpars.extra166y.ParallelLongArray: Returns an iterator stepping through each element of the array up to the current limit.

J

join() - Method in class groovyx.gpars.actor.Actor: Joins the actor.
join(MessageStream) - Method in class groovyx.gpars.actor.Actor: Notify listener when finished
join(long, TimeUnit) - Method in class groovyx.gpars.actor.Actor: Joins the actor.
join(BaseDuration) - Method in class groovyx.gpars.actor.Actor: Joins the actor.
join() - Method in class groovyx.gpars.dataflow.expression.DataflowExpression: Blocks, if the value has not been assigned yet to the DataflowVariable
join(long, TimeUnit) - Method in class groovyx.gpars.dataflow.expression.DataflowExpression: Blocks, if the value has not been assigned yet to the DataflowVariable
join() - Method in class groovyx.gpars.dataflow.operator.CountingPoisonPill: Blocks until the number of terminated operators reaches the number specified in the constructor
join(long, TimeUnit) - Method in class groovyx.gpars.dataflow.operator.CountingPoisonPill: Blocks until the number of terminated operators reaches the number specified in the constructor
join() - Method in class groovyx.gpars.dataflow.operator.DataflowProcessor: Joins the processor waiting for it to finish
join() - Method in class groovyx.gpars.dataflow.operator.ImmediateCountingPoisonPill: Blocks until the number of terminated operators reaches the number specified in the constructor
join(long, TimeUnit) - Method in class groovyx.gpars.dataflow.operator.ImmediateCountingPoisonPill: Blocks until the number of terminated operators reaches the number specified in the constructor
join() - Method in class groovyx.gpars.dataflow.operator.PoisonTrackCounter: Blocks until the number of terminated operators reaches the number specified in the constructor
join(long, TimeUnit) - Method in class groovyx.gpars.dataflow.operator.PoisonTrackCounter: Blocks until the number of terminated operators reaches the number specified in the constructor
join() - Method in interface groovyx.gpars.dataflow.Promise: Blocks, if the value has not been assigned yet to the DataflowVariable
join(long, TimeUnit) - Method in interface groovyx.gpars.dataflow.Promise: Blocks, if the value has not been assigned yet to the DataflowVariable
joinLatch - Variable in class groovyx.gpars.actor.Actor
joinLatch - Variable in class groovyx.gpars.actor.Actor.MyRemoteHandle

K

KEEP_ALIVE_TIME - Static variable in class groovyx.gpars.scheduler.ResizeablePool