org.apache.river.thread

Class SynchronousExecutors

java.lang.Object

org.apache.river.thread.SynchronousExecutors

All Implemented Interfaces:

Startable

public class SynchronousExecutors
extends Object
implements Startable

The intent of this Executor is to share a single thread pool among tasks with dependencies that prevent them running concurrently.

Author:

peter

Constructor Summary

Constructors

Constructor and Description
SynchronousExecutors(ScheduledExecutorService pool)

Method Summary

Modifier and Type	Method and Description
<T> ExecutorService	newSerialExecutor(BlockingQueue<Callable<T>> queue) The ExecutorService returned, supports a subset of ExecutorService methods, the intent of this executor is to serialize the execution of tasks, it is up to the BlockingQueue or caller to ensure order, only one task will execute at a time, that task will be retried if it fails, using a back off strategy of 1, 5 and 10 seconds, followed by 1, 1 and 5 minutes thereafter forever, no other task will execute until the task at the head of the queue is completed successfully.
void	shutdown()
void	start() Called after construction, this method enables objects to delay starting threads or exporting until after construction is complete, to allow safe publication of the service in accordance with the JMM.

Methods inherited from class java.lang.Object

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

Constructor Detail

SynchronousExecutors

public SynchronousExecutors(ScheduledExecutorService pool)

Method Detail

start

public void start()
           throws Exception

Description copied from interface: Startable

Called after construction, this method enables objects to delay starting threads or exporting until after construction is complete, to allow safe publication of the service in accordance with the JMM.

In addition to starting threads after construction, it also allows objects to avoid throwing an exception during construction to avoid finalizer attacks.

The implementation is required to ensure start() is idempotent (only executed once, additional invocations must return immediately).

Specified by:

start in interface Startable

Throws:

Exception - if there's a problem with construction or startup.

shutdown

public void shutdown()

newSerialExecutor

public <T> ExecutorService newSerialExecutor(BlockingQueue<Callable<T>> queue)

The ExecutorService returned, supports a subset of ExecutorService methods, the intent of this executor is to serialize the execution of tasks, it is up to the BlockingQueue or caller to ensure order, only one task will execute at a time, that task will be retried if it fails, using a back off strategy of 1, 5 and 10 seconds, followed by 1, 1 and 5 minutes thereafter forever, no other task will execute until the task at the head of the queue is completed successfully. Tasks submitted must implement Callable, Runnable is not supported.

Type Parameters:

T -

Parameters:

queue -

Returns: