com.oracle.coherence.concurrent.executor (Java API Reference for Oracle® Coherence Community Edition)

Classes to allow submission of tasks to the grid for execution.

Since:: 21.12

Interface Summary
Interface	Description
RemoteExecutor	A RemoteExecutor allows submitting and/or scheduling `runnables`, `callables`, and `tasks` for execution within a Coherence cluster.
Task<T>	A task which may take a long time to execute, may be executed by multiple `Executor`s, may generate intermediate results, and may yield for later execution.
Task.Collectable<T,R>	Provides the mechanism to submit, orchestrate and collect results from a `Task` defined as part of an `Task.Orchestration`, including the creation of a `Task.Coordinator` to subscribe to results, manage and interact with an orchestrated `Task`.
Task.Collector<T,A,R>	A mutable reduction operation that accumulates results into a mutable result container, optionally transforming the accumulated result into a final representation after all results have been processed.
Task.Completable<T,R>	A `Task.Collectable` that supports performing operations when a `Task` orchestration is complete.
Task.CompletionRunnable<T>	A runnable to be called upon task completion.
Task.Context<T>	Provides contextual information for a `Task` as it is executed, including the ability to access and update intermediate results for the `Executor` executing the said `Task`.
Task.Coordinator<T>	A publisher of collected `Task` results that additionally permits coordination of the submitted `Task`.
Task.Option	An option for configuring `Task` orchestration.
Task.Orchestration<T>	Defines information concerning the orchestration of a `Task` across a set of `Executor`s for a given `TaskExecutorService`.
Task.Properties	Define an interface to allow states sharing between the task executors.
Task.SubscribedOrchestration<T>	Defines the subset of `Task.Orchestration` methods which are permitted after `Task.SubscribedOrchestration.subscribe(Subscriber)` is called.
Task.Subscriber<T>	A receiver of items produced by a `Task.Coordinator`.
Task.Subscription<T>	Represents a subscription a `Task.Subscriber` has made to a `Task.Coordinator`, allowing control and termination of the `Task.Subscription`.

Class Summary
Class	Description
Result<T>	An immutable container representing an intermediate or final result produced by executing a `Task`, typically by an individual `Executor`, including no result, a specific value or a `Throwable`.
TaskCollectors	Static helper methods to create `Task.Collector`s.
TaskCollectors.CountCollector<T>	A `Task.Collector` that counts the number of results are present.
TaskCollectors.FirstOfCollector<T>	A `Task.Collector` to collect any (the first provided) available result.
TaskCollectors.LastOfCollector<T>	A `Task.Collector` that collects and returns the last contributed result.
TaskCollectors.ListOfCollector<T>	A `Task.Collector` that collects and returns all contributed results that are values as a `List`.
TaskCollectors.SetOfCollector<T>	A `Task.Collector` that collects and returns all contributed results that are values as a `Set`.

Exception Summary
Exception	Description
Task.Yield	An exception signalling the execution of a `Task` by an `Executor` is to be suspended and resumed at some later point in time, typically by the same `Executor`.