Index (org.codehaus.gpars)

Overview

Deprecated

org.codehaus.gpars

FRAMES NO FRAMES

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

A

B

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

C

D

E

each(Closure) - Method in TransparentParallel
eachParallel(Closure) - Method in GParsExecutorsPoolEnhancer: Iterates over a collection/object with the each() method using an asynchronous variant of the supplied closure to evaluate each collection's element.
eachParallel(Map, Closure) - Method in GParsExecutorsPoolUtil: Does parallel each on maps
eachParallel(Map, Closure) - Method in GParsPoolUtil
eachParallel(Closure) - Method in Parallel: Iterates over a collection/object with the each() method using an asynchronous variant of the supplied closure to evaluate each collection's element.
eachParallelPA(ParallelArray, Closure) - Method in GParsPoolUtilHelper
eachWithIndex(ParallelArray, Closure) - Method in GParsPoolUtilHelper
eachWithIndex(Closure) - Method in TransparentParallel
eachWithIndexParallel(Closure) - Method in GParsExecutorsPoolEnhancer: Iterates over a collection/object with the eachWithIndex() method using an asynchronous variant of the supplied closure to evaluate each collection's element.
eachWithIndexParallel(Map, Closure) - Method in GParsExecutorsPoolUtil: Does parallel eachWithIndex on maps
eachWithIndexParallel(Map, Closure) - Method in GParsPoolUtil
eachWithIndexParallel(Closure) - Method in Parallel: Iterates over a collection/object with the eachWithIndex() method using an asynchronous variant of the supplied closure to evaluate each collection's element.
elementType - Field in PAS.FJOSelectAllDriver
EMPTY_ARGUMENTS - Field in Actor
empty - Field in DefaultMessageQueue
EMPTY_OBJECTS - Field in FJWorker
encode(ChannelHandlerContext, Channel, Object) - Method in RemoteObjectEncoder
enhance(Object) - Method in Parallel: Enhances to resulting collection so that parallel methods can be chained.
enhanceAndUnwrap(ActorMessage) - Method in BlockingActor
enhanceClass(Class) - Method in GParsExecutorsPoolEnhancer: Enhances a class and so all instances created in the future by mixing-in an instance of GParsExecutorsPoolEnhancer.
enhanceClass(Class) - Method in ParallelEnhancer: Enhances a class and so all instances created in the future by mixing-in an instance of Parallel.
enhanceClosure(Closure) - Method in DefaultActor
EnhancedRWLock - Class in groovyx.gpars.util: Extends ReentrantReadWriteLock with handy withReadLock(Closure) and withWriteLock(Closure) methods to safely lock and unlock the lock for the passed-in closure.
EnhancedRWLock(boolean) - Constructor in EnhancedRWLock
EnhancedSemaphore - Class in groovyx.gpars.util: Extends Semaphore with a handy withSemaphore(Closure) method to safely acquire and release the Semaphore for the passed-in closure.
EnhancedSemaphore(int) - Constructor in EnhancedSemaphore
enhanceInstance(Object) - Method in GParsExecutorsPoolEnhancer: Enhances a single instance by mixing-in an instance of GParsExecutorsPoolEnhancer.
enhanceInstance(Object) - Method in ParallelEnhancer: Enhances a single instance by mixing-in an instance of Parallel.
enhanceReplies(ActorMessage) - Method in BlockingActor: Retrieves a message from the message queue, waiting, if necessary, for a message to arrive.
ensurePool(ForkJoinPool, Closure) - Method in GParsPool: Just like withExistingPool() registers a thread pool, but doesn't install the GParsPoolUtil category.
ensureToContainVariable(Object) - Method in Dataflows: Utility method extracted just to help JIT
enter() - Method in SerialContext: Leave this context
entrySet - Field in CustomConcurrentHashMap
eos() - Method in StreamCore
equal(Object, Object) - Method in CustomConcurrentHashMap.Equivalence: Returns true if the given objects are considered equal.
equal(Object, Object) - Method in CustomConcurrentHashMap.EquivalenceUsingEquals
equal(Object, Object) - Method in CustomConcurrentHashMap.EquivalenceUsingIdentity
equalityPredicate() - Method in CommonOps: Returns a predicate evaluating to true if the first argument equals the second.
EQUALS - Field in CustomConcurrentHashMap: An Equivalence object performing java.lang.Object#equals based comparisons and using java.lang.Object#hashCode hashing
equals(Object) - Method in CustomConcurrentHashMap.WriteThroughEntry
equals(Object) - Method in NullValue
equals(Object) - Method in SelectResult
equals(Object) - Method in StreamCore
error - Field in DataflowExpression
ERROR_READING_A_SYNCHRONOUS_CHANNEL - Field in SyncDataflowVariable
errorHandler - Field in ThenMessagingRunnable
errors - Field in AgentCore: Adds the message to the agent\s message queue
eval(Object) - Method in StreamCore
evalLoopCondition() - Method in DefaultActor: Schedules an ActorAction to take the next message off the message queue and to pass it on to the supplied closure.
evaluate() - Method in DataflowComplexExpression
evaluate() - Method in DataflowExpression: Returns either standard property of the expression or creates an expression, which will request given property when the receiver becomes available
evaluate() - Method in DataflowExpression.TransformMany
evaluate() - Method in DataflowExpression.TransformOne
evaluate() - Method in DataflowGetPropertyExpression
evaluate() - Method in DataflowInvocationExpression
evaluate() - Method in RemoteDataflowExpression
evaluateArguments(Pool, Object, int, List, DataflowVariable, Closure, boolean) - Method in PAUtils: Performs a single step in the evaluation of parameters passed into an asynchronous function
eventManager - Field in DataflowExpression
eventManager - Field in DataflowQueue
eventManager - Field in DataflowStreamReadAdapter
every(Closure) - Method in TransparentParallel
everyParallel(Closure) - Method in GParsExecutorsPoolEnhancer: Performs the all() operation using an asynchronous variant of the supplied closure to evaluate each collection's/object's element.
everyParallel(Map, Closure) - Method in GParsExecutorsPoolUtil: Does parallel every on a map
everyParallel(Map, Closure) - Method in GParsPoolUtil
everyParallel(Closure) - Method in Parallel: Performs the all() operation using an asynchronous variant of the supplied closure to evaluate each collection's/object's element.
ex - Field in AbstractParallelAnyArray
exceptionCaught(ChannelHandlerContext, ExceptionEvent) - Method in NettyHandler
exec() - Method in PAS.FJScan
execute(RemoteConnection) - Method in Actor.RemoteActor.StopActorMsg
execute(RemoteConnection) - Method in Actor.RemoteActor.TerminateActorMsg
execute(RemoteConnection) - Method in DataflowExpression.BindDataflow
execute(Runnable) - Method in DefaultPool: Retrieves the internal executor service.
execute(Runnable) - Method in FJPool: Retrieves the internal executor service.
execute(RemoteConnection) - Method in MessageStream.SendTo
execute(RemoteConnection) - Method in NodeConnectedMsg
execute(RemoteConnection) - Method in NodeDisconnectedMsg
execute(Runnable) - Method in PGroup
execute(Runnable) - Method in Pool
execute(Runnable) - Method in Scheduler
execute(RemoteConnection) - Method in SerialHandle.RemoteSerialHandle.ReleaseHandle
execute(RemoteConnection) - Method in SerialMsg
executeAsync(List) - Method in GParsExecutorsPool: Starts multiple closures in separate threads, collecting Futures for their return values If an exception is thrown from the closure when called on any of the collection's elements, it will be re-thrown in the calling thread when it calls the Future.get() method.
executeAsync(List) - Method in GParsPool: Starts multiple closures in separate threads, collecting Futures for their return values Reuses the pool defined by the surrounding withPool() call.
executeAsyncAndWait(List) - Method in GParsExecutorsPool: Starts multiple closures in separate threads, collecting their return values If an exception is thrown from the closure when called on any of the collection's elements, it will be re-thrown in the calling thread when it calls the Future.get() method.
executeAsyncAndWait(List) - Method in GParsPool: Starts multiple closures in separate threads, collecting their return values Reuses the pool defined by the surrounding withPool() call.
EXPECTED - Field in DefaultActor
expr - Field in DataflowExpression.BindDataflow
extractInputs(Map) - Method in DataflowProcessor
extractListeners(Map) - Method in DataflowProcessor
extractOutputs(Map) - Method in DataflowProcessor
extractState(Map) - Method in DataflowProcessor

F

G

H

I

J

K

L

M

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

N

O

P

Q

R

S

T

U

V

W