private class DefaultExecutorService.DefaultDistributedTaskBuilder<T> extends java.lang.Object implements DistributedTaskBuilder<T>, DistributedTask<T>
Modifier and Type | Field and Description |
---|---|
private java.util.concurrent.Callable<T> |
callable |
private DistributedTaskExecutionPolicy |
executionPolicy |
private DistributedTaskFailoverPolicy |
failoverPolicy |
private long |
timeout |
Constructor and Description |
---|
DefaultExecutorService.DefaultDistributedTaskBuilder(long taskTimeout) |
Modifier and Type | Method and Description |
---|---|
DistributedTask<T> |
build()
Completes creation of DistributedTask with the currently provided attributes of this
DistributedTaskBuilder
|
DistributedTaskBuilder<T> |
callable(java.util.concurrent.Callable<T> callable)
Provide relevant
Callable for the DistributedTask |
DistributedTaskBuilder<T> |
executionPolicy(DistributedTaskExecutionPolicy policy)
Provide
DistributedTaskExecutionPolicy for the task being built |
DistributedTaskBuilder<T> |
failoverPolicy(DistributedTaskFailoverPolicy policy)
Provide
DistributedTaskFailoverPolicy for the task being built |
java.util.concurrent.Callable<T> |
getCallable()
Returns
Callable for this task |
DistributedTaskExecutionPolicy |
getTaskExecutionPolicy()
Returns custom
DistributedTaskExecutionPolicy for this task |
DistributedTaskFailoverPolicy |
getTaskFailoverPolicy()
Returns custom
DistributedTaskFailoverPolicy for this task |
long |
timeout()
Returns timeout for the execution of this task
|
DistributedTaskBuilder<T> |
timeout(long t,
java.util.concurrent.TimeUnit tu)
Provide
DistributedTask task timeout |
private java.util.concurrent.Callable<T> callable
private long timeout
private DistributedTaskExecutionPolicy executionPolicy
private DistributedTaskFailoverPolicy failoverPolicy
public DefaultExecutorService.DefaultDistributedTaskBuilder(long taskTimeout)
public DistributedTaskBuilder<T> callable(java.util.concurrent.Callable<T> callable)
DistributedTaskBuilder
Callable
for the DistributedTask
callable
in interface DistributedTaskBuilder<T>
callable
- for the DistribtuedTask being builtpublic DistributedTaskBuilder<T> timeout(long t, java.util.concurrent.TimeUnit tu)
DistributedTaskBuilder
DistributedTask
task timeouttimeout
in interface DistributedTaskBuilder<T>
t
- for the tasktu
- TimeUnit
for the task being builtpublic DistributedTaskBuilder<T> executionPolicy(DistributedTaskExecutionPolicy policy)
DistributedTaskBuilder
DistributedTaskExecutionPolicy
for the task being builtexecutionPolicy
in interface DistributedTaskBuilder<T>
policy
- DistributedTaskExecutionPolicy for the taskpublic DistributedTaskBuilder<T> failoverPolicy(DistributedTaskFailoverPolicy policy)
DistributedTaskBuilder
DistributedTaskFailoverPolicy
for the task being builtfailoverPolicy
in interface DistributedTaskBuilder<T>
policy
- DistributedTaskFailoverPolicy for the taskpublic DistributedTask<T> build()
DistributedTaskBuilder
build
in interface DistributedTaskBuilder<T>
public long timeout()
DistributedTask
timeout
in interface DistributedTask<T>
public DistributedTaskExecutionPolicy getTaskExecutionPolicy()
DistributedTask
DistributedTaskExecutionPolicy
for this taskgetTaskExecutionPolicy
in interface DistributedTask<T>
public DistributedTaskFailoverPolicy getTaskFailoverPolicy()
DistributedTask
DistributedTaskFailoverPolicy
for this taskgetTaskFailoverPolicy
in interface DistributedTask<T>
public java.util.concurrent.Callable<T> getCallable()
DistributedTask
Callable
for this taskgetCallable
in interface DistributedTask<T>