org.infinispan.distexec

Interface DistributedTaskBuilder<T>

All Known Implementing Classes:

DefaultExecutorService.DefaultDistributedTaskBuilder

public interface DistributedTaskBuilder<T>

DistributedTaskBuilder is a factory interface for DistributedTask

Since:

5.2

Author:

Manik Surtani, Vladimir Blagojevic

Method Summary

Methods

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
DistributedTaskBuilder<T>	timeout(long timeout, java.util.concurrent.TimeUnit tu) Provide DistributedTask task timeout

Method Detail

callable

DistributedTaskBuilder<T> callable(java.util.concurrent.Callable<T> callable)

Provide relevant Callable for the DistributedTask

Parameters:

callable - for the DistribtuedTask being built

Returns:

this DistributedTaskBuilder

timeout

DistributedTaskBuilder<T> timeout(long timeout,
                                java.util.concurrent.TimeUnit tu)

Provide DistributedTask task timeout

Parameters:

timeout - for the task

tu - TimeUnit for the task being built

Returns:

this DistributedTaskBuilder

executionPolicy

DistributedTaskBuilder<T> executionPolicy(DistributedTaskExecutionPolicy policy)

Provide DistributedTaskExecutionPolicy for the task being built

Parameters:

policy - DistributedTaskExecutionPolicy for the task

Returns:

this DistributedTaskBuilder

failoverPolicy

DistributedTaskBuilder<T> failoverPolicy(DistributedTaskFailoverPolicy policy)

Provide DistributedTaskFailoverPolicy for the task being built

Parameters:

policy - DistributedTaskFailoverPolicy for the task

Returns:

this DistributedTaskBuilder

build

DistributedTask<T> build()

Completes creation of DistributedTask with the currently provided attributes of this DistributedTaskBuilder

Returns:

the built task ready for use