| Interface | Description |
|---|---|
| BasicTask.TaskFinalizer | |
| CanSetName | |
| DeferredSupplier<T> |
A class that supplies objects of a single type.
|
| ExecutionListener | |
| TaskInternal<T> |
All tasks being passed to the
ExecutionManager should implement this. |
| TaskScheduler |
The scheduler is an internal mechanism to decorate
Tasks. |
| Class | Description |
|---|---|
| AbstractExecutionContext | |
| BasicExecutionContext |
A means of executing tasks against an ExecutionManager with a given bucket/set of tags pre-defined
(so that it can look like an
Executor and also supply ExecutorService.submit(Callable) |
| BasicExecutionManager |
Manages the execution of atomic tasks and scheduled (recurring) tasks,
including setting tags and invoking callbacks.
|
| BasicTask<T> |
The basic concrete implementation of a
Task to be executed. |
| BasicTask.SubmissionErrorCatchingExecutor | |
| CompoundTask<T> | |
| DynamicSequentialTask<T> |
Represents a task whose run() method can create other tasks
which are run sequentially, but that sequence runs in parallel to this task
|
| DynamicSequentialTask.FailureHandlingConfig | |
| DynamicTasks |
Contains static methods which detect and use the current
TaskQueueingContext to execute tasks. |
| DynamicTasks.TaskQueueingResult<T> | |
| ExecutionUtils | |
| ForwardingTask<T> | |
| ListenableForwardingFuture<T> |
Wraps a Future, making it a ListenableForwardingFuture, but with the caller having the resposibility to:
invoke the listeners on job completion (success or error)
invoke the listeners on cancel
|
| ParallelTask<T> |
Runs
Tasks in parallel. |
| ScheduledTask |
A task which runs with a fixed period.
|
| SequentialTask<T> |
runs tasks in order, waiting for one to finish before starting the next; return value here is TBD;
(currently is all the return values of individual tasks, but we
might want some pipeline support and eventually only to return final value...)
|
| SingleThreadedScheduler |
Instances of this class ensures that
Tasks execute with in-order
single-threaded semantics. |
| TaskBuilder<T> |
Convenience for creating tasks; note that DynamicSequentialTask is the default
|
| Tasks | |
| TaskTags | |
| ValueResolver<T> |
Resolves a given object, as follows:
If it is a
Tasks or a DeferredSupplier then get its contents
If it's a map and ValueResolver.deep(boolean) is requested, it applies resolution to contents
It applies coercion |
| ValueResolver.ResolverBuilderPretype |
| Exception | Description |
|---|---|
| DynamicSequentialTask.QueueAbortedException |