Package com.oracle.coherence.concurrent.executor

Interface Task.Orchestration<T>

Type Parameters:

T - the type of results produced by a Task

All Superinterfaces:

Task.SubscribedOrchestration<T>

Enclosing interface:

Task<T>

public static interface Task.Orchestration<T>
extends Task.SubscribedOrchestration<T>

Defines information concerning the orchestration of a Task across a set of Executors for a given TaskExecutorService. This information represents the first part of an orchestration pipeline definition, which is agnostic to the final type of result. The optional second and last part of an orchestration pipeline is defined by the Task.Collectable, produced when collect(Collector) is called. Task.SubscribedOrchestration.subscribe(Subscriber) (optional) and Task.SubscribedOrchestration.submit() may be called directly on the Task.Orchestration if using a Task.Collector is not desired.

See Also:

Task.Collectable

Method Summary

Modifier and Type	Method	Description
Task.Orchestration<T>	as(String sIdentity)	Sets the unique identity for the Task when it is orchestrated.
<R> Task.Collectable<T,R>	collect(Task.Collector<? super T,?,R> collector)	Creates a Task.Collectable for the Task using the specified Task.Collector, that will collect individual results from Tasks when they are executed with orchestrated Executors.
Task.Orchestration<T>	concurrently()	Specify that the Task should be executed concurrently on its assigned Executors.
<V extends Serializable> Task.Orchestration<T>	define(String sName, V value)	Defines the Task.Properties for the Task.
Task.Orchestration<T>	filter(Remote.Predicate<? super com.oracle.coherence.concurrent.executor.TaskExecutorService.ExecutorInfo> predicate)	Limit the Executors to only those that satisfy the specified Remote.Predicate.
Task.Orchestration<T>	limit(int cLimit)	Limit the number of Executors to use when executing the Task.
Task.Orchestration<T>	retain(Duration duration)	Sets the Duration to retain the task after it is completed.
Task.Orchestration<T>	sequentially()	Specify that the Task should be executed sequentially on its assigned Executors.
Task.Orchestration<T>	with(Task.Option... options)	Sets the Task.Options for orchestration.

Methods inherited from interface com.oracle.coherence.concurrent.executor.Task.SubscribedOrchestration

submit, subscribe

Method Detail

concurrently

Task.Orchestration<T> concurrently()

Specify that the Task should be executed concurrently on its assigned Executors.

This is the default setting for execution.

Returns:

the Task.Orchestration to permit fluent-style method chaining

sequentially

Task.Orchestration<T> sequentially()

Specify that the Task should be executed sequentially on its assigned Executors.

Returns:

the Task.Orchestration to permit fluent-style method chaining

filter

Task.Orchestration<T> filter(Remote.Predicate<? super com.oracle.coherence.concurrent.executor.TaskExecutorService.ExecutorInfo> predicate)

Limit the Executors to only those that satisfy the specified Remote.Predicate.

Parameters:

predicate - the TaskExecutorService.ExecutorInfo predicate

Returns:

the Task.Orchestration to permit fluent-style method chaining

limit

Task.Orchestration<T> limit(int cLimit)

Limit the number of Executors to use when executing the Task.

Parameters:

cLimit - the number of Executors to use

Returns:

the Task.Orchestration to permit fluent-style method chaining

as

Task.Orchestration<T> as(String sIdentity)

Sets the unique identity for the Task when it is orchestrated.

Parameters:

sIdentity - the unique identity for the Task

Returns:

the Task.Orchestration to permit fluent-style method chaining

with

Task.Orchestration<T> with(Task.Option... options)

Sets the Task.Options for orchestration.

Parameters:

options - the Task.Option

Returns:

the Task.Orchestration to permit fluent-style method chaining

define

<V extends Serializable> Task.Orchestration<T> define(String sName,
                                                      V value)

Defines the Task.Properties for the Task.

Type Parameters:

V - the value type of the property

Parameters:

sName - the name of the property

value - the value of the property

Returns:

the Task.Orchestration to permit fluent-style method chaining

retain

Task.Orchestration<T> retain(Duration duration)

Sets the Duration to retain the task after it is completed.

Parameters:

duration - the duration to retain the task after it is completed.

Returns:

the Task.Orchestration to permit fluent-style method chaining

collect

<R> Task.Collectable<T,R> collect(Task.Collector<? super T,?,R> collector)

Creates a Task.Collectable for the Task using the specified Task.Collector, that will collect individual results from Tasks when they are executed with orchestrated Executors.

Type Parameters:

R - the collected result type

Parameters:

collector - the Task.Collector

Returns:

the Task.Collectable for the Task