Index (org.codehaus.gpars)

Returns a reducer returning maximum of two values, or null if both arguments are null, and that casts its arguments as Comparable on each comparison, throwing ClassCastException on failure.

castedMinReducer() - Method in CommonOps

Returns a reducer returning minimum of two values, or null if both arguments are null, and that casts its arguments as Comparable on each comparison, throwing ClassCastException on failure.

cchm - Field in CustomConcurrentHashMap.IntKeySoftValueNode

cchm - Field in CustomConcurrentHashMap.IntKeyWeakValueNode

cchm - Field in CustomConcurrentHashMap.KeySet

cchm - Field in CustomConcurrentHashMap.SoftKeyNode

cchm - Field in CustomConcurrentHashMap.StrongKeySoftValueNode

cchm - Field in CustomConcurrentHashMap.StrongKeyWeakValueNode

cchm - Field in CustomConcurrentHashMap.WeakKeyNode

chainWith(PGroup, Map, Closure) - Method in DataflowExpression

chainWith(PGroup, Map, Closure) - Method in DataflowQueue

chainWith(PGroup, Map, Closure) - Method in DataflowReadChannel

chainWith(PGroup, Map, Closure) - Method in DataflowStreamReadAdapter

chainWith(Map, Closure) - Method in Pipeline

Creates and attaches a new operator

chainWith(PGroup, Closure) - Method in SyncDataflowQueue

chainWith(PGroup, Closure) - Method in SyncDataflowStreamReadAdapter

chainWith(PGroup, Closure) - Method in SyncDataflowVariable

ChainWithClosure - Class in groovyx.gpars.dataflow.operator

Used by the chainWith() method to wrap the supplied closure inside the operator's body.

ChainWithClosure(Closure) - Constructor in ChainWithClosure

channel - Field in NettyHandler

channel - Field in NettyTransportProvider.Server

channel - Field in SelectCallback

channelConnected(ChannelHandlerContext, ChannelStateEvent) - Method in NettyHandler

channelDisconnected(ChannelHandlerContext, ChannelStateEvent) - Method in NettyHandler

channelDisconnected(ChannelHandlerContext, ChannelStateEvent) - Method in NettyTransportProvider.ClientHandler

channelFuture - Field in NettyTransportProvider.Client

ChannelInputList - Class in groovyx.gpars.csp

ChannelInputList is used to create a list of ChannelInputEnds

ChannelInputList() - Constructor in ChannelInputList

ChannelInputList uses the ArrayList class of java This constructor creates an empty ArrayList to be populated with NetChannelInputs

channelOpen(ChannelHandlerContext, ChannelStateEvent) - Method in NettyHandler

ChannelOutputList - Class in groovyx.gpars.csp

ChannelOutputList is used to create a list of ChannelOUTPUTEnds

ChannelOutputList() - Constructor in ChannelOutputList

ChannelOutputList uses the ArrayList class of java This constructor creates an empty ArrayList to be populated with NetChannelOUTPUTs

channels - Field in SelectBase

checkBlockingMethod(MethodNode, Iterable) - Method in ActiveObjectASTTransformation.MyClassCodeExpressionTransformer

checkClosed() - Method in SyncDataflowStreamReadAdapter

checkClosure(Closure) - Method in AgentBase

Returns the current value of the Agent's state

checkForBodyArguments(Closure) - Method in DefaultActor

checkForMessageHandlerArguments(Closure) - Method in DefaultActor

checkForNull(Runnable) - Method in DefaultActor

checkMaxForks(Map) - Method in DataflowProcessor

checkPoison(Object) - Method in DataflowProcessorActor

checkState() - Method in Pipeline

checkStoppedFlags() - Method in BlockingActor

checkStopTerminate() - Method in SequentialProcessingActor

checkValidPoolSize(int) - Method in PoolUtils

checkWhetherAnyEventsHaveArrived() - Method in GracefulShutdownMonitor

Checks the notification flag whether there has been some activity since last timer run.

children - Field in AbstractForkJoinWorker

choice(PGroup, Map, List, Closure) - Method in DataflowExpression

choice(PGroup, Map, List, Closure) - Method in DataflowQueue

choice(PGroup, Map, List, Closure) - Method in DataflowReadChannel

choice(PGroup, Map, List, Closure) - Method in DataflowStreamReadAdapter

choice(Map, List, Closure) - Method in Pipeline

Allows the closure to output different values to different output channels.

ChoiceClosure - Class in groovyx.gpars.dataflow.operator

Used by the chainWith() method to wrap the supplied closure inside the operator's body.

ChoiceClosure(Closure) - Constructor in ChoiceClosure

cleanUpNullReferences(Map, ReferenceQueue) - Method in GParsPoolUtilHelper

clear() - Method in CustomConcurrentHashMap

Removes all of the mappings from this map.

clear() - Method in CustomConcurrentHashMap.EntrySet

clear() - Method in CustomConcurrentHashMap.KeySet

clear() - Method in CustomConcurrentHashMap.KeySetView

clear() - Method in CustomConcurrentHashMap.Values

clear() - Method in ParallelArray.AsList

clear() - Method in ParallelDoubleArray.AsList

clear() - Method in ParallelLongArray.AsList

clearCount() - Method in CustomConcurrentHashMap.Segment

clearInputArea - Property in GConsole

clients - Field in NettyTransportProvider

cList - Property in ChannelInputList

cList - Property in ChannelOutputList

clone() - Method in CallClosure

clone() - Method in LRUProtectionStorage

close() - Method in SyncDataflowStreamReadAdapter

closed - Field in SyncDataflowStreamReadAdapter

closure - Field in DataflowExpression.TransformMany

closure - Field in DataflowExpression.TransformOne

closure - Field in RemoteNodeDiscoveryListener.RemoteNodeDiscoveryListenerClosure

closure - Field in ThenMessagingRunnable

ClosureMapper - Class in groovyx.gpars.pa

A PA mapper built around a closure

ClosureMapper(Closure) - Constructor in ClosureMapper

ClosureNegationPredicate - Class in groovyx.gpars.pa

A PA predicate built around a closure

ClosureNegationPredicate(Closure) - Constructor in ClosureNegationPredicate

ClosurePredicate - Class in groovyx.gpars.pa

A PA predicate built around a closure

ClosurePredicate(Closure) - Constructor in ClosurePredicate

ClosureReducer - Class in groovyx.gpars.pa

A PA reducer built around a closure

ClosureReducer(Closure) - Constructor in ClosureReducer

cmp - Field in CommonOps.RawComparator

cmp - Field in PAS.FJDMerger

cmp - Field in PAS.FJDSorter

cmp - Field in PAS.FJLMerger

cmp - Field in PAS.FJLSorter

cmp - Field in PAS.FJOMerger

cmp - Field in PAS.FJOSorter

code - Field in BinaryChoiceClosure

code - Field in CallAsyncTask

code - Field in ChainWithClosure

code - Field in ChoiceClosure

code - Field in ClosureMapper

code - Field in ClosureNegationPredicate

code - Field in ClosurePredicate

code - Field in ClosureReducer

code - Field in DataCallback

code - Field in DataCallbackWithPool

code - Field in DataflowProcessorActor

code - Field in FJWorker

code - Field in GParsAtomicBooleanBlock

code - Field in GParsAtomicDoubleBlock

code - Field in GParsAtomicIntBlock

code - Field in GParsAtomicLongBlock

code - Field in GParsAtomicVoidBlock

code - Field in GParsPool.MyCancellableRecursiveTask

code - Field in GParsTxnExecutor

code - Field in SeparationClosure

collect(Closure) - Method in TransparentParallel

collectingMessages - Field in GracefulShutdownListener

collectMany(Closure) - Method in TransparentParallel

collectManyParallel(Map, Closure) - Method in GParsPoolUtil

collectManyParallel(Closure) - Method in Parallel

Iterates over a collection/object with the collectMany() method using an asynchronous variant of the supplied closure to evaluate each collection's element.

collectParallel(Closure) - Method in GParsExecutorsPoolEnhancer

Iterates over a collection/object with the collect() method using an asynchronous variant of the supplied closure to evaluate each collection's element.

collectParallel(Map, Closure) - Method in GParsExecutorsPoolUtil

Does parallel collect on a map

collectParallel(Map, Closure) - Method in GParsPoolUtil

collectParallel(Closure) - Method in Parallel

Iterates over a collection/object with the collect() method using an asynchronous variant of the supplied closure to evaluate each collection's element.

combine(Object, Closure) - Method in AbstractPAWrapper

Performs a parallel combine operation.

CombineHolder - Class in groovyx.gpars.pa

Holds a temporary reduce result for groupBy

CombineHolder(Map) - Constructor in CombineHolder

combineImpl(def, def, Closure, Closure) - Method in AbstractPAWrapper

combiner - Field in PAS.FJDCombineInPlace

combiner - Field in PAS.FJDPACombineInPlace

combiner - Field in PAS.FJLCombineInPlace

combiner - Field in PAS.FJLPACombineInPlace

combiner - Field in PAS.FJOCombineInPlace

combiner - Field in PAS.FJOPACombineInPlace

CommonOps - Class in groovyx.gpars.extra166y

A collection of static factory methods providing commonly useful implementations of operations.

CommonOps.DoubleAdder - Class in groovyx.gpars.extra166y

CommonOps.DoubleAdder() - Constructor in CommonOps.DoubleAdder

CommonOps.DoubleBoundedRandomGenerator - Class in groovyx.gpars.extra166y

CommonOps.DoubleBoundedRandomGenerator(double) - Constructor in CommonOps.DoubleBoundedRandomGenerator

CommonOps.DoubleEqualityPredicate - Class in groovyx.gpars.extra166y

CommonOps.DoubleEqualityPredicate() - Constructor in CommonOps.DoubleEqualityPredicate

CommonOps.DoubleInequalityPredicate - Class in groovyx.gpars.extra166y

CommonOps.DoubleInequalityPredicate() - Constructor in CommonOps.DoubleInequalityPredicate

CommonOps.DoubleIntervalRandomGenerator - Class in groovyx.gpars.extra166y

CommonOps.DoubleIntervalRandomGenerator(double, double) - Constructor in CommonOps.DoubleIntervalRandomGenerator

CommonOps.DoubleRandomGenerator - Class in groovyx.gpars.extra166y

CommonOps.DoubleRandomGenerator() - Constructor in CommonOps.DoubleRandomGenerator

CommonOps.EqualityPredicate - Class in groovyx.gpars.extra166y

CommonOps.EqualityPredicate() - Constructor in CommonOps.EqualityPredicate

CommonOps.IdentityPredicate - Class in groovyx.gpars.extra166y

CommonOps.IdentityPredicate() - Constructor in CommonOps.IdentityPredicate

CommonOps.InequalityPredicate - Class in groovyx.gpars.extra166y

CommonOps.InequalityPredicate() - Constructor in CommonOps.InequalityPredicate

CommonOps.IntAdder - Class in groovyx.gpars.extra166y

CommonOps.IntAdder() - Constructor in CommonOps.IntAdder

CommonOps.IntBoundedRandomGenerator - Class in groovyx.gpars.extra166y

CommonOps.IntBoundedRandomGenerator(int) - Constructor in CommonOps.IntBoundedRandomGenerator

CommonOps.IntEqualityPredicate - Class in groovyx.gpars.extra166y

CommonOps.IntEqualityPredicate() - Constructor in CommonOps.IntEqualityPredicate

CommonOps.IntInequalityPredicate - Class in groovyx.gpars.extra166y

CommonOps.IntInequalityPredicate() - Constructor in CommonOps.IntInequalityPredicate

CommonOps.IntIntervalRandomGenerator - Class in groovyx.gpars.extra166y

CommonOps.IntIntervalRandomGenerator(int, int) - Constructor in CommonOps.IntIntervalRandomGenerator

CommonOps.IntRandomGenerator - Class in groovyx.gpars.extra166y

CommonOps.IntRandomGenerator() - Constructor in CommonOps.IntRandomGenerator

CommonOps.IsNonNullPredicate - Class in groovyx.gpars.extra166y

CommonOps.IsNonNullPredicate() - Constructor in CommonOps.IsNonNullPredicate

CommonOps.IsNullPredicate - Class in groovyx.gpars.extra166y

CommonOps.IsNullPredicate() - Constructor in CommonOps.IsNullPredicate

CommonOps.LongAdder - Class in groovyx.gpars.extra166y

CommonOps.LongAdder() - Constructor in CommonOps.LongAdder

CommonOps.LongBoundedRandomGenerator - Class in groovyx.gpars.extra166y

CommonOps.LongBoundedRandomGenerator(long) - Constructor in CommonOps.LongBoundedRandomGenerator

CommonOps.LongEqualityPredicate - Class in groovyx.gpars.extra166y

CommonOps.LongEqualityPredicate() - Constructor in CommonOps.LongEqualityPredicate

CommonOps.LongInequalityPredicate - Class in groovyx.gpars.extra166y

CommonOps.LongInequalityPredicate() - Constructor in CommonOps.LongInequalityPredicate

CommonOps.LongIntervalRandomGenerator - Class in groovyx.gpars.extra166y

CommonOps.LongIntervalRandomGenerator(long, long) - Constructor in CommonOps.LongIntervalRandomGenerator

CommonOps.LongRandomGenerator - Class in groovyx.gpars.extra166y

CommonOps.LongRandomGenerator() - Constructor in CommonOps.LongRandomGenerator

CommonOps.NaturalDoubleComparator - Class in groovyx.gpars.extra166y

CommonOps.NaturalDoubleComparator() - Constructor in CommonOps.NaturalDoubleComparator

CommonOps.NaturalDoubleMaxReducer - Class in groovyx.gpars.extra166y

CommonOps.NaturalDoubleMaxReducer() - Constructor in CommonOps.NaturalDoubleMaxReducer

CommonOps.NaturalDoubleMinReducer - Class in groovyx.gpars.extra166y

CommonOps.NaturalDoubleMinReducer() - Constructor in CommonOps.NaturalDoubleMinReducer

CommonOps.NaturalLongComparator - Class in groovyx.gpars.extra166y

CommonOps.NaturalLongComparator() - Constructor in CommonOps.NaturalLongComparator

CommonOps.NaturalLongMaxReducer - Class in groovyx.gpars.extra166y

CommonOps.NaturalLongMaxReducer() - Constructor in CommonOps.NaturalLongMaxReducer

CommonOps.NaturalLongMinReducer - Class in groovyx.gpars.extra166y

CommonOps.NaturalLongMinReducer() - Constructor in CommonOps.NaturalLongMinReducer

CommonOps.NonidentityPredicate - Class in groovyx.gpars.extra166y

CommonOps.NonidentityPredicate() - Constructor in CommonOps.NonidentityPredicate

CommonOps.RawComparator - Class in groovyx.gpars.extra166y

CommonOps.RawComparator() - Constructor in CommonOps.RawComparator

CommonOps.RawMaxReducer - Class in groovyx.gpars.extra166y

CommonOps.RawMaxReducer() - Constructor in CommonOps.RawMaxReducer

CommonOps.RawMinReducer - Class in groovyx.gpars.extra166y

CommonOps.RawMinReducer() - Constructor in CommonOps.RawMinReducer

CommonOps() - Constructor in CommonOps

comparator - Field in CommonOps.NaturalDoubleComparator

comparator - Field in CommonOps.NaturalLongComparator

comparator - Field in PAS.FJDStats

comparator - Field in PAS.FJLStats

comparator - Field in PAS.FJOStats

compare(double, double) - Method in CommonOps.NaturalDoubleComparator

compare(long, long) - Method in CommonOps.NaturalLongComparator

compare(Object, Object) - Method in CommonOps.RawComparator

compare(double, double) - Method in Ops.DoubleComparator

compare(int, int) - Method in Ops.IntComparator

compare(long, long) - Method in Ops.LongComparator

complete - Field in Pipeline

compoundIndexedOp(LongOp, IntAndLongToLong) - Method in AbstractParallelAnyArray

compoundIndexedSelector(IntAndLongPredicate, LongPredicate) - Method in AbstractParallelAnyArray

compoundOp(LongToDouble, DoubleToLong) - Method in CommonOps

Returns a composite mapper that applies a second mapper to the results of applying the first one.

compute() - Method in AbstractForkJoinWorker

compute() - Method in CallAsyncTask

compute(Object, CustomConcurrentHashMap.RemappingFunction) - Method in CustomConcurrentHashMap

Updates the mapping for the given key with the result of the given remappingFunction.

compute() - Method in GParsPool.MyCancellableRecursiveTask

compute() - Method in PAS.FJBase

compute() - Method in PAS.FJDCMerger

compute() - Method in PAS.FJDCSorter

compute() - Method in PAS.FJDMerger

compute() - Method in PAS.FJDSorter

compute() - Method in PAS.FJLCMerger

compute() - Method in PAS.FJLCSorter

Utility class to sort half a partitioned array

compute() - Method in PAS.FJLMerger

compute() - Method in PAS.FJLSorter

compute() - Method in PAS.FJOCMerger

compute() - Method in PAS.FJOCSorter

compute() - Method in PAS.FJOMerger

compute() - Method in PAS.FJOSorter

compute() - Method in PAS.FJRemoveAll

compute() - Method in PAS.FJRemoveAllDriver

compute() - Method in PAS.FJSearchBase

compute() - Method in PAS.FJSelectAll

compute() - Method in PAS.FJSelectAllDriver

compute() - Method in PAS.FJSubSorter

computeIfAbsent(Object, CustomConcurrentHashMap.MappingFunction) - Method in CustomConcurrentHashMap

computeTask() - Method in AbstractForkJoinWorker

computeTask() - Method in FJWorker

computeThreshold() - Method in AbstractParallelAnyArray

Returns size threshold for splitting into subtask.

concurrencyActive - Field in TransparentParallel

concurrentExceptions - Field in AsyncException

configuredPoolSize - Field in FJPool

connect(def) - Method in GroovyMobileProcess

connect(LocalNode) - Method in LocalHost

connect(LocalNode) - Method in LocalHostRegistry

connect(LocalHost) - Method in LocalNode

connect(List) - Method in MobileAgent

connect(LocalNode) - Method in RemoteHost

connection - Field in NettyHandler

connection - Field in RemoteObjectDecoder

connection - Field in RemoteObjectEncoder

connections - Field in RemoteHost

connectRemoteNode(UUID, SerialContext, Actor) - Method in LocalHost

consumer - Field in KanbanLink

consumerAlreadyStarted() - Method in KanbanLink

consumerSpec - Property in KanbanLink

contains(def) - Method in ChannelInputList

contains(def) - Method in ChannelOutputList

contains(Object) - Method in CustomConcurrentHashMap.EntrySet

contains(Object) - Method in CustomConcurrentHashMap.KeySet

Adds the specified element to this set if there is not already an element equivalent to the given element with respect to this set's Equivalence.

contains(Object) - Method in CustomConcurrentHashMap.KeySetView

contains(Object) - Method in CustomConcurrentHashMap.Values

contains(Object) - Method in Dataflows

Convenience method to play nicely with Groovy object iteration methods.

contains(Object) - Method in ParallelArray.AsList

contains(Object) - Method in ParallelDoubleArray.AsList

contains(Object) - Method in ParallelLongArray.AsList

containsKey(Object) - Method in CustomConcurrentHashMap

Returns true if this map contains a key equivalent to the given key with respect to this map's key Equivalence.

containsValue(Object) - Method in CustomConcurrentHashMap

content - Field in CombineHolder

context - Field in SerialHandle

Construct handle for object with given id to it

continueProcessingMessages() - Method in AsyncMessagingCore

Informs about a new thread being assigned to process the next message

ControlMessage - Interface in groovyx.gpars.dataflow.operator

A marker interface indicating control dataflow messages, which in general do not get propagated to the operator's body

controlMessageArrived(DataflowProcessor, DataflowReadChannel, int, Object) - Method in DataflowEventAdapter

Invoked when a message is being bound to an output channel.

controlMessageArrived(DataflowProcessor, DataflowReadChannel, int, Object) - Method in DataflowEventListener

controlMessageArrived(DataflowProcessor, DataflowReadChannel, int, Object) - Method in GracefulShutdownListener

Entering a different non-idle state, so a notification needs to be sent to the monitor.

convertToBoolean(def) - Method in GParsPoolUtilHelper

copy - Field in AgentBase

copy() - Method in JCSPCopy

The interface JCSPCopy is used to define a copy method that is used to make a deep copy of an object.

CopyChannelsClosure - Class in groovyx.gpars.dataflow.operator

Used by the chainWith() method to wrap the supplied closure inside the operator's body.

CopyChannelsClosure() - Constructor in CopyChannelsClosure

copyDFV(Queue, Queue) - Method in DataflowQueue

core - Field in AbstractLoopingActor

core - Field in AgentCore

count - Field in CustomConcurrentHashMap.Segment

count - Field in DataflowExpression.DataflowExpressionsCollector

count - Field in PAS.FJCountSelected

count - Field in PAS.FJDUniquifier

count - Field in PAS.FJLUniquifier

count - Field in PAS.FJOUniquifier

count - Field in PAS.FJRemoveAll

count - Field in PAS.FJSelectAll

count(def) - Method in TransparentParallel

countDown() - Method in CountingPoisonPill

countDown() - Method in ImmediateCountingPoisonPill

countDown() - Method in PoisonPill

countDown() - Method in PoisonTrackCounter

countDown() - Method in ResizeableCountDownLatch

counter - Field in PoisonTrackCounter

CountingPoisonPill - Class in groovyx.gpars.dataflow.operator

Represents a non-immediate PoisonPill that counts stopped operators and can be used to wait for all the operators to terminate.

CountingPoisonPill(int) - Constructor in CountingPoisonPill

countInputChannels(Map) - Method in DataflowOperator

countInputChannels(Map) - Method in DataflowSelector

countParallel(Object, Closure) - Method in GParsPoolUtil

countParallel(Object) - Method in Parallel

Performs the count() operation using an asynchronous variant of the supplied closure to evaluate each collection's/object's element.

create(Object) - Method in InternalActor

create(int, Class, ForkJoinPool) - Method in ParallelArray

Creates a new ParallelArray using the given executor and an array of the given size constructed using the indicated base element type.

create(int, ForkJoinPool) - Method in ParallelDoubleArray

Creates a new ParallelDoubleArray using the given executor and an array of the given size.

create(int, ForkJoinPool) - Method in ParallelLongArray

Creates a new ParallelLongArray using the given executor and an array of the given size.

create(WithSerialId, UUID) - Method in SerialHandle

createActorMessage(Object) - Method in Actor

createArray(Map) - Method in PAUtils

createCollection(Object) - Method in PAGroovyUtils

createCollection(Iterator) - Method in PAUtils

createComparator(Closure) - Method in PAUtils

createDDAClosure(DynamicDispatchActor) - Method in DDAClosure

Creates the closure for a given DDA

createDefaultThreadFactory() - Method in GParsExecutorsPool

createDefaultUncaughtExceptionHandler() - Method in GParsPool

createEmpty(int, Class, ForkJoinPool) - Method in ParallelArray

Creates a new ParallelArray using the given executor and an array of the given size constructed using the indicated base element type, but with an initial effective size of zero, enabling incremental insertion via ParallelArray#asList#asList operations.

createEmpty(int, ForkJoinPool) - Method in ParallelDoubleArray

Creates a new ParallelDoubleArray using the given executor and an array of the given size, but with an initial effective size of zero, enabling incremental insertion via ParallelDoubleArray#asList#asList operations.

createEmpty(int, ForkJoinPool) - Method in ParallelLongArray

Creates a new ParallelLongArray using the given executor and an array of the given size, but with an initial effective size of zero, enabling incremental insertion via ParallelLongArray#asList#asList operations.

createEventManager() - Method in DataflowExpression

createFromCopy(int, Object, ForkJoinPool) - Method in ParallelArray

Creates a new ParallelArray using an array of the given size, initially holding copies of the given source truncated or padded with nulls to obtain the specified length.

createFromCopy(int, double[], ForkJoinPool) - Method in ParallelDoubleArray

Creates a new ParallelDoubleArray using an array of the given size, initially holding copies of the given source truncated or padded with zeros to obtain the specified length.

createFromCopy(int, long[], ForkJoinPool) - Method in ParallelLongArray

Creates a new ParallelLongArray using an array of the given size, initially holding copies of the given source truncated or padded with zeros to obtain the specified length.

createFromPool(ThreadPoolExecutor) - Method in PGroupBuilder

createGroupByClosure(Closure, ConcurrentMap) - Method in PAUtils

Creates a closure that will insert elements in the appropriate group

createNewStream() - Method in DataflowStream

createNewStream() - Method in StreamCore

createNewStream() - Method in SyncDataflowStream

createObject(SerialContext) - Method in Actor.MyRemoteHandle

createObject(SerialContext) - Method in DefaultRemoteHandle

createObject(SerialContext) - Method in RemoteHandle

createPA(Map, ForkJoinPool) - Method in GParsPoolUtil

Overrides the iterative methods like each(), collect() and such, so that they call their parallel variants from the GParsPoolUtil class like eachParallel(), collectParallel() and such.

createPA(Object, ForkJoinPool) - Method in GParsPoolUtilHelper

createPAFromArray(Object, ForkJoinPool) - Method in GParsPoolUtilHelper

createPAFromCollection(def, ForkJoinPool) - Method in GParsPoolUtilHelper

createPool(boolean, int) - Method in DefaultPool

createPool(int) - Method in FJPool

createPool(int, ThreadFactory) - Method in GParsExecutorsPool

createPool(int, UncaughtExceptionHandler) - Method in GParsPool

createPool(boolean, int) - Method in PoolFactory

createReadChannel() - Method in DataflowBroadcast

createReadChannel() - Method in SyncDataflowBroadcast

Un-registers the supplied read channel from the broadcast.

createRemoteHandle(SerialHandle, SerialContext) - Method in Actor

createRemoteHandle(SerialHandle, SerialContext) - Method in WithSerialId

createResizeablePool(boolean, int) - Method in ResizeablePool

createResults(int) - Method in PAS.FJDAppendAllDriver

createResults(int) - Method in PAS.FJDSelectAllDriver

createResults(int) - Method in PAS.FJLAppendAllDriver

createResults(int) - Method in PAS.FJLSelectAllDriver

createResults(int) - Method in PAS.FJOAppendAllDriver

createResults(int) - Method in PAS.FJOSelectAllDriver

createResults(int) - Method in PAS.FJSelectAllDriver

createSDAClosure(StaticDispatchActor) - Method in SDAClosure

createThreadName() - Method in DefaultPool

Created a JVM-unique name for Actors' threads.

createTimeout(long) - Method in Select

createTimer(String, boolean) - Method in TimerFactory

createTxnExecutor(Map) - Method in GParsStm

createUsingHandoff(Object, ForkJoinPool) - Method in ParallelArray

Creates a new ParallelArray initially using the given array and executor.

createUsingHandoff(double[], ForkJoinPool) - Method in ParallelDoubleArray

Creates a new ParallelDoubleArray initially using the given array and executor.

createUsingHandoff(long[], ForkJoinPool) - Method in ParallelLongArray

Creates a new ParallelLongArray initially using the given array and executor.

createVariable() - Method in DataflowQueue

Retrieves the value at the head of the buffer.

createVariable() - Method in SyncDataflowQueue

cumulate(DoubleReducer, double) - Method in AbstractParallelAnyArray.DUPap

cumulate(LongReducer, long) - Method in AbstractParallelAnyArray.LUPap

cumulate(Reducer, Object) - Method in AbstractParallelAnyArray.OUPap

cumulate(Reducer, Object) - Method in ParallelArray