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
-
ClassDescriptionResult<T>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 aTask
defined as part of anTask.Orchestration
, including the creation of aTask.Coordinator
to subscribe to results, manage and interact with an orchestratedTask
.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> ATask.Collectable
that supports performing operations when aTask
orchestration is complete.A runnable to be called upon task completion.Task.Context<T>An option for configuringTask
orchestration.Define an interface to allow states sharing between the task executors.Defines the subset ofTask.Orchestration
methods which are permitted afterTask.SubscribedOrchestration.subscribe(Subscriber)
is called.A receiver of items produced by aTask.Coordinator
.Represents a subscription aTask.Subscriber
has made to aTask.Coordinator
, allowing control and termination of theTask.Subscription
.Static helper methods to createTask.Collector
s.ATask.Collector
that counts the number of results are present.ATask.Collector
to collect any (the first provided) available result.ATask.Collector
that collects and returns the last contributed result.ATask.Collector
that collects and returns all contributed results that are values as aList
.ATask.Collector
that collects and returns all contributed results that are values as aSet
.