Package com.oracle.coherence.concurrent.executor

package com.oracle.coherence.concurrent.executor

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

Since:

21.12

Related Packages

Package	Description
com.oracle.coherence.concurrent	Coherence Concurrent utilities based on java.util.concurrent.
com.oracle.coherence.concurrent.executor.function	Various predicates used by the Executor Service.
com.oracle.coherence.concurrent.executor.management	MBeans for Coherence Concurrent executors.
com.oracle.coherence.concurrent.executor.options	Options used as metadata for executors or during task submission to the grid.
com.oracle.coherence.concurrent.executor.subscribers	Task.Subscriber implementations.
com.oracle.coherence.concurrent.executor.tasks	Task implementations.

Class	Description
RemoteExecutor	A RemoteExecutor allows submitting and/or scheduling runnables, callables, and tasks for execution within a Coherence cluster.
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.
Task<T>	A task which may take a long time to execute, may be executed by multiple Executors, 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 Executors 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.
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.
TaskCollectors	Static helper methods to create Task.Collectors.
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.