org.jboss.threads

Class DelegatingBlockingExecutorService

java.lang.Object

java.util.concurrent.AbstractExecutorService

org.jboss.threads.DelegatingBlockingExecutorService

All Implemented Interfaces:

java.util.concurrent.Executor, java.util.concurrent.ExecutorService, BlockingExecutor, BlockingExecutorService

class DelegatingBlockingExecutorService
extends java.util.concurrent.AbstractExecutorService
implements BlockingExecutorService

Field Summary

Fields

Modifier and Type	Field and Description
private BlockingExecutor	delegate

Constructor Summary

Constructors

Constructor and Description
DelegatingBlockingExecutorService(BlockingExecutor delegate)

Method Summary

Modifier and Type	Method and Description
boolean	awaitTermination(long timeout, java.util.concurrent.TimeUnit unit)
static java.util.concurrent.ExecutorService	directExecutorService()
void	execute(java.lang.Runnable command) Executes the given command at some time in the future.
void	executeBlocking(java.lang.Runnable task) Execute a task, blocking until it can be accepted, or until the calling thread is interrupted.
void	executeBlocking(java.lang.Runnable task, long timeout, java.util.concurrent.TimeUnit unit) Execute a task, blocking until it can be accepted, a timeout elapses, or the calling thread is interrupted.
void	executeNonBlocking(java.lang.Runnable task) Execute a task, without blocking.
boolean	isShutdown()
boolean	isTerminated()
void	shutdown()
java.util.List<java.lang.Runnable>	shutdownNow()
java.lang.String	toString()

Methods inherited from class java.util.concurrent.AbstractExecutorService

invokeAll, invokeAll, invokeAny, invokeAny, newTaskFor, newTaskFor, submit, submit, submit

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.concurrent.ExecutorService

invokeAll, invokeAll, invokeAny, invokeAny, submit, submit, submit

Field Detail

delegate

private final BlockingExecutor delegate

Constructor Detail

DelegatingBlockingExecutorService

DelegatingBlockingExecutorService(BlockingExecutor delegate)

Method Detail

execute

public void execute(java.lang.Runnable command)

Description copied from interface: BlockingExecutor

Executes the given command at some time in the future. The command may execute in a new thread, in a pooled thread, or in the calling thread, at the discretion of the Executor implementation. The call may block or not block, depending on the configuration of the executor.

Specified by:

execute in interface java.util.concurrent.Executor

Specified by:

execute in interface BlockingExecutor

Parameters:

command - the task to submit

isShutdown

public boolean isShutdown()

Specified by:

isShutdown in interface java.util.concurrent.ExecutorService

isTerminated

public boolean isTerminated()

Specified by:

isTerminated in interface java.util.concurrent.ExecutorService

awaitTermination

public boolean awaitTermination(long timeout,
                                java.util.concurrent.TimeUnit unit)
                         throws java.lang.InterruptedException

Specified by:

awaitTermination in interface java.util.concurrent.ExecutorService

Throws:

java.lang.InterruptedException

shutdown

public void shutdown()

Specified by:

shutdown in interface java.util.concurrent.ExecutorService

shutdownNow

public java.util.List<java.lang.Runnable> shutdownNow()

Specified by:

shutdownNow in interface java.util.concurrent.ExecutorService

executeBlocking

public void executeBlocking(java.lang.Runnable task)
                     throws java.util.concurrent.RejectedExecutionException,
                            java.lang.InterruptedException

Description copied from interface: BlockingExecutor

Execute a task, blocking until it can be accepted, or until the calling thread is interrupted.

Specified by:

executeBlocking in interface BlockingExecutor

Parameters:

task - the task to submit

Throws:

StoppedExecutorException - if the executor was shut down before the task was accepted

ThreadCreationException - if a thread could not be created for some reason

java.util.concurrent.RejectedExecutionException - if execution is rejected for some other reason

java.lang.InterruptedException - if the current thread was interrupted before the task could be accepted

executeBlocking

public void executeBlocking(java.lang.Runnable task,
                            long timeout,
                            java.util.concurrent.TimeUnit unit)
                     throws java.util.concurrent.RejectedExecutionException,
                            java.lang.InterruptedException

Description copied from interface: BlockingExecutor

Execute a task, blocking until it can be accepted, a timeout elapses, or the calling thread is interrupted.

Specified by:

executeBlocking in interface BlockingExecutor

Parameters:

task - the task to submit

timeout - the amount of time to wait

unit - the unit of time

Throws:

ExecutionTimedOutException - if the timeout elapsed before a task could be accepted

StoppedExecutorException - if the executor was shut down before the task was accepted

ThreadCreationException - if a thread could not be created for some reason

java.util.concurrent.RejectedExecutionException - if execution is rejected for some other reason

java.lang.InterruptedException - if the current thread was interrupted before the task could be accepted

executeNonBlocking

public void executeNonBlocking(java.lang.Runnable task)
                        throws java.util.concurrent.RejectedExecutionException

Description copied from interface: BlockingExecutor

Execute a task, without blocking.

Specified by:

executeNonBlocking in interface BlockingExecutor

Parameters:

task - the task to submit

Throws:

StoppedExecutorException - if the executor was shut down before the task was accepted

ThreadCreationException - if a thread could not be created for some reason

java.util.concurrent.RejectedExecutionException - if execution is rejected for some other reason

directExecutorService

public static java.util.concurrent.ExecutorService directExecutorService()

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object