eu.toolchain.concurrent

Class CoreAsync.Builder

java.lang.Object

eu.toolchain.concurrent.CoreAsync.Builder

Enclosing class:

CoreAsync

public static class CoreAsync.Builder
extends Object

Builder for CoreAsync.

Method Summary

Modifier and Type	Method and Description
CoreAsync	build()
CoreAsync.Builder	caller(Caller caller) Specify an asynchronous caller implementation.
CoreAsync.Builder	callerExecutor(ExecutorService callerExecutor) Specify a separate executor to use for caller (internal handle) invocation.
CoreAsync.Builder	clockSource(ClockSource clockSource) Configure clock source.
CoreAsync.Builder	executor(ExecutorService executor) Configure the default executor to use for caller invocation,and asynchronous tasks submitted through Async.call(Callable).
CoreAsync.Builder	managedOptions(ManagedOptions managedOptions)
CoreAsync.Builder	maxRecursionDepth(long maxRecursionDepth) Configure how many recursions should be allowed.
CoreAsync.Builder	recursionSafe(boolean recursionSafe) Configure that all caller invocations should use a recursion safe mechanism.
CoreAsync.Builder	scheduler(ScheduledExecutorService scheduler) Specify a scheduler to use with the built CoreAsync instance.
CoreAsync.Builder	threaded(boolean threaded) Configure that all caller invocation, and async tasks should be using a thread pool.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

threaded

public CoreAsync.Builder threaded(boolean threaded)

Configure that all caller invocation, and async tasks should be using a thread pool.

This will cause the configuration of TinyTask to throw an exception if an executor service is not available for all purposes.

Parameters:

threaded - true if all tasks should be executed on a thread pool

Returns:

this builder

recursionSafe

public CoreAsync.Builder recursionSafe(boolean recursionSafe)

Configure that all caller invocations should use a recursion safe mechanism. In the normal case this doesn't change the behaviour of caller and threadedCaller, but when deep recursion is detected in the current thread the next recursive doCall is deferred to a separate thread.

Recursion is tracked for all threads that doCall the AsyncCallers.

This will make even the non-threaded caller use a thread in the case of deep recursion.

Parameters:

recursionSafe - true if all caller invocations should be done with a recursion safe mechanism.

Returns:

this builder

maxRecursionDepth

public CoreAsync.Builder maxRecursionDepth(long maxRecursionDepth)

Configure how many recursions should be allowed.

This implies enabling recursionSafe.

Parameters:

maxRecursionDepth - The max number of times that a caller may go through Caller in a single thread.

Returns:

this builder

caller

public CoreAsync.Builder caller(Caller caller)

Specify an asynchronous caller implementation.

The 'caller' defines how handles are invoked. The simplest implementations are based of DirectCaller , which causes the doCall to be performed directly in the calling thread.

Parameters:

caller - caller to configure

Returns:

this builder

executor

public CoreAsync.Builder executor(ExecutorService executor)

Configure the default executor to use for caller invocation,and asynchronous tasks submitted through Async.call(Callable).

Parameters:

executor - Executor to use

Returns:

this builder

callerExecutor

public CoreAsync.Builder callerExecutor(ExecutorService callerExecutor)

Specify a separate executor to use for caller (internal handle) invocation.

Implies use of threaded caller.

Parameters:

callerExecutor - Executor to use for callers

Returns:

this builder

scheduler

public CoreAsync.Builder scheduler(ScheduledExecutorService scheduler)

Specify a scheduler to use with the built CoreAsync instance.

Parameters:

scheduler - The scheduler to use

Returns:

this builder

clockSource

public CoreAsync.Builder clockSource(ClockSource clockSource)

Configure clock source.

A clock source is used to determine what the current time is in order to do timing-related tasks like retrying an action until it has been completed with a back-off.

Parameters:

clockSource - clock source to configure

Returns:

this builder

See Also:

Async.retryUntilCompleted(java.util.concurrent.Callable, RetryPolicy)

managedOptions

public CoreAsync.Builder managedOptions(ManagedOptions managedOptions)

build

public CoreAsync build()