org.jboss.threads

Interface BlockingExecutor

All Superinterfaces:

java.util.concurrent.Executor

All Known Subinterfaces:

BlockingExecutorService

All Known Implementing Classes:

DelegatingBlockingExecutor, DelegatingBlockingExecutorService, DelegatingDirectBlockingExecutor, JBossThreadPoolExecutor, OrderedExecutor, QueueExecutor, QueuelessExecutor, ThreadFactoryExecutor

public interface BlockingExecutor
extends java.util.concurrent.Executor

An executor which can optionally block or not block on task submission.

Method Summary

Modifier and Type	Method and Description
void	execute(java.lang.Runnable task) 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.

Method Detail

execute

void execute(java.lang.Runnable task)

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

Parameters:

task - the task to submit

Throws:

ExecutionInterruptedException - if the executor is configured to block, and the thread was interrupted while waiting for the task to 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.NullPointerException - if command is null

executeBlocking

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

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

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

java.lang.NullPointerException - if command is null

executeBlocking

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

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

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

java.lang.NullPointerException - if command is null

executeNonBlocking

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

Execute a task, without blocking.

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.NullPointerException - if command is null