JBossExecutors

java.lang.Object
- org.jboss.threads.JBossExecutors

```
public final class JBossExecutors
extends java.lang.Object
```
JBoss thread- and executor-related utility and factory methods.

Field Summary

Fields
Modifier and Type	Field and Description
`private static java.util.concurrent.RejectedExecutionHandler`	`ABORT_POLICY`
`private static BlockingExecutor`	`BLOCKING_DIRECT_EXECUTOR`
`private static BlockingExecutor`	`BLOCKING_DISCARDING_EXECUTOR`
`private static BlockingExecutor`	`BLOCKING_REJECTING_EXECUTOR`
`private static java.util.concurrent.RejectedExecutionHandler`	`CALLER_RUNS_POLICY`
`private static java.lang.RuntimePermission`	`COPY_CONTEXT_CLASSLOADER_PERMISSION`
`private static DirectExecutorService`	`DIRECT_EXECUTOR_SERVICE`
`private static java.util.concurrent.RejectedExecutionHandler`	`DISCARD_OLDEST_POLICY`
`private static java.util.concurrent.RejectedExecutionHandler`	`DISCARD_POLICY`
`private static DirectExecutorService`	`DISCARDING_EXECUTOR_SERVICE`
`private static java.lang.Thread.UncaughtExceptionHandler`	`LOGGING_HANDLER`
`private static java.lang.RuntimePermission`	`MODIFY_THREAD_PERMISSION`
`private static java.lang.Runnable`	`NULL_RUNNABLE`
`private static DirectExecutorService`	`REJECTING_EXECUTOR_SERVICE`
`private static java.lang.Runnable`	`TCCL_RESETTER`
`private static org.jboss.logging.Logger`	`THREAD_ERROR_LOGGER`
`private static java.lang.Runnable`	`THREAD_LOCAL_RESETTER`

Constructor Summary

Constructors
Modifier Constructor and Description

private JBossExecutors()

Constructors
Modifier	Constructor and Description
`private`	`JBossExecutors()`

Method Summary

All Methods Static Methods Concrete Methods
Modifier and Type	Method and Description
`static java.util.concurrent.RejectedExecutionHandler`	`abortPolicy()` Get the abort policy for a `ThreadPoolExecutor`.
`static BlockingExecutor`	`blockingDirectExecutor()` Get an executor which executes tasks in the current thread, which implements `BlockingExecutor`.
`static BlockingExecutor`	`blockingDiscardingExecutor()` Get an executor which discards all tasks, which implements `BlockingExecutor`.
`static BlockingExecutor`	`blockingRejectingExecutor()` Get an executor which rejects all tasks, which implements `BlockingExecutor`.
`static java.util.concurrent.RejectedExecutionHandler`	`callerRunsPolicy()` Get the caller-runs policy for a `ThreadPoolExecutor`.
`(package private) static void`	`checkAccess(java.security.Permission permission)`
`static java.lang.Runnable`	`classLoaderPreservingTask(java.lang.Runnable delegate)` Create a task that delegates to the given task, preserving the context classloader which was in effect when this method was invoked.
`static DirectExecutor`	`cleanupExecutor(DirectExecutor delegate, java.lang.Runnable cleaner)` Create an executor which runs the given cleanup task after running its given task.
`static java.lang.Runnable`	`compositeTask(java.util.Collection<java.lang.Runnable> runnables)` Create a task that is a composite of several other tasks.
`static java.lang.Runnable`	`compositeTask(java.lang.Runnable... runnables)` Create a task that is a composite of several other tasks.
`static DirectExecutor`	`contextClassLoaderExecutor(DirectExecutor delegate, java.lang.ClassLoader taskClassLoader)` Create a direct executor which runs tasks with the given context class loader.
`static java.lang.Runnable`	`contextClassLoaderResetter()` Get a `Runnable` which, when executed, clears the thread context class loader (if the caller has sufficient privileges).
`static DependencyTaskBuilder`	`dependencyTaskBuilder(java.util.concurrent.Executor executor, java.lang.Runnable task)` Create a builder for a dependent task.
`static BlockingExecutor`	`directBlockingExecutor(DirectExecutor delegate)` An executor which delegates to the given direct executor, but implements the blocking executor interface.
`static DirectExecutor`	`directExecutor()` Get the direct executor.
`static DirectExecutorService`	`directExecutorService()` Get the direct executor service.
`static DirectExecutor`	`discardingExecutor()` Get the discarding executor.
`static DirectExecutorService`	`discardingExecutorService()` Get the discarding executor service.
`static java.util.concurrent.RejectedExecutionHandler`	`discardOldestPolicy()` Get the discard-oldest policy for a `ThreadPoolExecutor`.
`static java.util.concurrent.RejectedExecutionHandler`	`discardPolicy()` Get the discard policy for a `ThreadPoolExecutor`.
`static DirectExecutor`	`exceptionLoggingExecutor(DirectExecutor delegate)` Create a direct executor which consumes and logs errors that are thrown to the default thread error category `"org.jboss.threads.errors"`.
`static DirectExecutor`	`exceptionLoggingExecutor(DirectExecutor delegate, org.jboss.logging.Logger log)` Create a direct executor which consumes and logs errors that are thrown.
`static DirectExecutor`	`exceptionLoggingExecutor(DirectExecutor delegate, org.jboss.logging.Logger log, org.jboss.logging.Logger.Level level)` Create a direct executor which consumes and logs errors that are thrown.
`static void`	`executeUninterruptibly(java.util.concurrent.Executor executor, java.lang.Runnable task)` Execute a task uninterruptibly.
`static java.util.concurrent.Executor`	`executor(WrappingExecutor delegate, DirectExecutor taskWrapper)` An executor which delegates to a wrapping executor, wrapping each task in a task wrapper.
`static java.lang.Runnable`	`executorTask(DirectExecutor executor, java.lang.Runnable task)` Get a task that runs the given task through the given direct executor.
`private static <R extends java.lang.Runnable,A> void`	`failed(TaskNotifier<? super R,? super A> notifier, java.lang.Throwable reason, R runnable, A attachment)`
`private static <R extends java.lang.Runnable,A> void`	`finished(TaskNotifier<? super R,? super A> notifier, R runnable, A attachment)`
`(package private) static java.lang.ClassLoader`	`getAndSetContextClassLoader(java.lang.Thread thread, java.lang.ClassLoader newClassLoader)` Privileged method to get and set the context class loader of the given thread.
`(package private) static java.lang.ClassLoader`	`getContextClassLoader(java.lang.Thread thread)` Privileged method to get the context class loader of the given thread.
`static java.util.concurrent.RejectedExecutionHandler`	`handoffPolicy(java.util.concurrent.Executor target)` Get a handoff policy for a `ThreadPoolExecutor`.
`static DirectExecutor`	`initializingExecutor(DirectExecutor delegate, java.lang.Runnable initializer)` Create an executor which runs the given initialization task before running its given task.
`private static <R extends java.lang.Runnable> void`	`logError(R runnable, java.lang.Throwable t, java.lang.String method)`
`static java.lang.Thread.UncaughtExceptionHandler`	`loggingExceptionHandler()` Get an uncaught exception handler which logs to the default error logger.
`static java.lang.Thread.UncaughtExceptionHandler`	`loggingExceptionHandler(org.jboss.logging.Logger log)` Get an uncaught exception handler which logs to the given logger.
`static java.lang.Thread.UncaughtExceptionHandler`	`loggingExceptionHandler(java.lang.String categoryName)` Get an uncaught exception handler which logs to the given logger.
`static <A> DirectExecutor`	`notifyingDirectExecutor(DirectExecutor delegate, TaskNotifier<java.lang.Runnable,? super A> notifier, A attachment)` Get a notifying direct executor.
`static <R extends java.lang.Runnable,A> java.lang.Runnable`	`notifyingRunnable(R task, TaskNotifier<? super R,? super A> notifier, A attachment)` Get a notifying runnable wrapper for a task.
`static java.lang.Runnable`	`nullRunnable()` Get the null runnable which does nothing.
`static DirectExecutor`	`privilegedExecutor(DirectExecutor delegate)` Create a direct executor which runs with the privileges given by the current access control context.
`static DirectExecutor`	`privilegedExecutor(DirectExecutor delegate, java.security.AccessControlContext context)` Create a direct executor which runs with the privileges given by the supplied `AccessControlContext` instance.
`static DirectExecutor`	`privilegedExecutor(DirectExecutor delegate, java.lang.Class<?> targetClass)` Create a direct executor which runs with the privileges given by the supplied class' protection domain.
`static BlockingExecutor`	`protectedBlockingExecutor(BlockingExecutor target)`
`static BlockingExecutorService`	`protectedBlockingExecutorService(BlockingExecutor target)` Wrap a blocking executor with an `BlockingExecutorService` instance which supports all the features of `BlockingExecutorService` except for shutting down the executor.
`static DirectExecutorService`	`protectedDirectExecutorService(DirectExecutor target)` Wrap a direct executor with an `DirectExecutorService` instance which supports all the features of `ExecutorService` except for shutting down the executor.
`static java.util.concurrent.ExecutorService`	`protectedExecutorService(java.util.concurrent.Executor target)` Wrap an executor with an `ExecutorService` instance which supports all the features of `ExecutorService` except for shutting down the executor.
`static java.util.concurrent.ScheduledExecutorService`	`protectedScheduledExecutorService(java.util.concurrent.ScheduledExecutorService target)` Wrap a scheduled executor with a `ScheduledExecutorService` instance which supports all the features of `ScheduledExecutorService` except for shutting down the executor.
`static DirectExecutor`	`rejectingExecutor()` Get the rejecting executor.
`static DirectExecutor`	`rejectingExecutor(java.lang.String message)` Get a rejecting executor.
`static DirectExecutorService`	`rejectingExecutorService()` Get the rejecting executor service.
`static DirectExecutorService`	`rejectingExecutorService(java.lang.String message)` Get the rejecting executor service.
`static DirectExecutor`	`resettingExecutor(DirectExecutor delegate)` Create a direct executor which delegates tasks to the given executor, and then clears all thread-local data after each task completes (regardless of outcome).
`static java.util.concurrent.ThreadFactory`	`resettingThreadFactory(java.util.concurrent.ThreadFactory delegate)` Create a thread factory which resets all thread-local storage and delegates to the given thread factory.
`static <R extends java.lang.Runnable,A> void`	`run(R task, DirectExecutor directExecutor, TaskNotifier<? super R,? super A> notifier, A attachment)` Run a task through the given direct executor, invoking the given notifier with the given attachment.
`static <R extends java.lang.Runnable,A> void`	`run(R task, TaskNotifier<? super R,? super A> notifier, A attachment)` Run a task, invoking the given notifier with the given attachment.
`(package private) static void`	`setContextClassLoader(java.lang.Thread thread, java.lang.ClassLoader classLoader)` Privileged method to set the context class loader of the given thread.
`private static <R extends java.lang.Runnable,A> void`	`started(TaskNotifier<? super R,? super A> notifier, R runnable, A attachment)`
`static BlockingExecutor`	`threadFactoryExecutor(java.util.concurrent.ThreadFactory factory)` Create an executor that executes each task in a new thread.
`static BlockingExecutor`	`threadFactoryExecutor(java.util.concurrent.ThreadFactory factory, int maxThreads)` Create an executor that executes each task in a new thread.
`static BlockingExecutor`	`threadFactoryExecutor(java.util.concurrent.ThreadFactory factory, int maxThreads, boolean blocking)` Create an executor that executes each task in a new thread.
`static BlockingExecutor`	`threadFactoryExecutor(java.util.concurrent.ThreadFactory factory, int maxThreads, boolean blocking, DirectExecutor taskExecutor)` Create an executor that executes each task in a new thread.
`static DirectExecutor`	`threadFormattedNameExecutor(DirectExecutor delegate, java.lang.String newName)` Create a direct executor which changes the thread name for the duration of a task using a formatted name.
`static java.lang.Runnable`	`threadLocalResetter()` Get a `Runnable` which, when executed, clears the thread-local storage of the calling thread.
`static DirectExecutor`	`threadNameExecutor(DirectExecutor delegate, java.lang.String newName)` Create a direct executor which changes the thread name for the duration of a task.
`static DirectExecutor`	`threadNameNotateExecutor(DirectExecutor delegate, java.lang.String notation)` Create a direct executor which adds a note to the thread name for the duration of a task.
`static java.util.concurrent.Executor`	`uninterruptibleExecutor(java.util.concurrent.Executor delegate)` Get an executor which executes tasks uninterruptibly in the event of blocking.
`static java.util.concurrent.Executor`	`wrappingExecutor(DirectExecutor taskWrapper, java.util.concurrent.Executor delegate)` An executor which delegates to another executor, wrapping each task in a task wrapper.
`static WrappingExecutor`	`wrappingExecutor(java.util.concurrent.Executor delegate)` Create a wrapping executor for a delegate executor which creates an `executorTask(DirectExecutor, Runnable)` for each task.
`static java.util.concurrent.ThreadFactory`	`wrappingThreadFactory(DirectExecutor taskWrapper, java.util.concurrent.ThreadFactory delegate)` Creates a thread factory which executes the thread task via the given task wrapping executor.

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Field Detail
  - THREAD_ERROR_LOGGER
```
private static final org.jboss.logging.Logger THREAD_ERROR_LOGGER
```
  - MODIFY_THREAD_PERMISSION
```
private static final java.lang.RuntimePermission MODIFY_THREAD_PERMISSION
```
  - COPY_CONTEXT_CLASSLOADER_PERMISSION
```
private static final java.lang.RuntimePermission COPY_CONTEXT_CLASSLOADER_PERMISSION
```
  - DIRECT_EXECUTOR_SERVICE
```
private static final DirectExecutorService DIRECT_EXECUTOR_SERVICE
```
  - REJECTING_EXECUTOR_SERVICE
```
private static final DirectExecutorService REJECTING_EXECUTOR_SERVICE
```
  - DISCARDING_EXECUTOR_SERVICE
```
private static final DirectExecutorService DISCARDING_EXECUTOR_SERVICE
```
  - BLOCKING_DIRECT_EXECUTOR
```
private static final BlockingExecutor BLOCKING_DIRECT_EXECUTOR
```
  - BLOCKING_REJECTING_EXECUTOR
```
private static final BlockingExecutor BLOCKING_REJECTING_EXECUTOR
```
  - BLOCKING_DISCARDING_EXECUTOR
```
private static final BlockingExecutor BLOCKING_DISCARDING_EXECUTOR
```
  - ABORT_POLICY
```
private static final java.util.concurrent.RejectedExecutionHandler ABORT_POLICY
```
  - CALLER_RUNS_POLICY
```
private static final java.util.concurrent.RejectedExecutionHandler CALLER_RUNS_POLICY
```
  - DISCARD_OLDEST_POLICY
```
private static final java.util.concurrent.RejectedExecutionHandler DISCARD_OLDEST_POLICY
```
  - DISCARD_POLICY
```
private static final java.util.concurrent.RejectedExecutionHandler DISCARD_POLICY
```
  - TCCL_RESETTER
```
private static final java.lang.Runnable TCCL_RESETTER
```
  - NULL_RUNNABLE
```
private static final java.lang.Runnable NULL_RUNNABLE
```
  - THREAD_LOCAL_RESETTER
```
private static final java.lang.Runnable THREAD_LOCAL_RESETTER
```
  - LOGGING_HANDLER
```
private static final java.lang.Thread.UncaughtExceptionHandler LOGGING_HANDLER
```
- Constructor Detail
  - JBossExecutors
```
private JBossExecutors()
```
- Method Detail
  - directExecutor
```
public static DirectExecutor directExecutor()
```
    Get the direct executor. This executor will immediately run any task it is given, and propagate back any run-time exceptions thrown.
    
    Returns:
    
    the direct executor instance
  - directExecutorService
```
public static DirectExecutorService directExecutorService()
```
    Get the direct executor service. This executor will immediately run any task it is given, and propagate back any run-time exceptions thrown. It cannot be shut down.
    
    Returns:
    
    the direct executor service instance
  - rejectingExecutor
```
public static DirectExecutor rejectingExecutor()
```
    Get the rejecting executor. This executor will reject any task submitted to it.
    
    Returns:
    
    the rejecting executor instance
  - rejectingExecutor
```
public static DirectExecutor rejectingExecutor(java.lang.String message)
```
    Get a rejecting executor. This executor will reject any task submitted to it with the given message.
    
    Parameters:
    
    message - the reject message
    
    Returns:
    
    the rejecting executor instance
  - rejectingExecutorService
```
public static DirectExecutorService rejectingExecutorService()
```
    Get the rejecting executor service. This executor will reject any task submitted to it. It cannot be shut down.
    
    Returns:
    
    the rejecting executor service instance
  - rejectingExecutorService
```
public static DirectExecutorService rejectingExecutorService(java.lang.String message)
```
    Get the rejecting executor service. This executor will reject any task submitted to it with the given message. It cannot be shut down.
    
    Parameters:
    
    message - the reject message
    
    Returns:
    
    the rejecting executor service instance
  - discardingExecutor
```
public static DirectExecutor discardingExecutor()
```
    Get the discarding executor. This executor will silently discard any task submitted to it.
    
    Returns:
    
    the discarding executor instance
  - discardingExecutorService
```
public static DirectExecutorService discardingExecutorService()
```
    Get the discarding executor service. This executor will silently discard any task submitted to it. It cannot be shut down.
    
    Returns:
    
    the discarding executor service instance
  - privilegedExecutor
```
public static DirectExecutor privilegedExecutor(DirectExecutor delegate,
                                                java.security.AccessControlContext context)
```
    Create a direct executor which runs with the privileges given by the supplied AccessControlContext instance.
    
    Parameters:
    
    delegate - the executor to delegate to at the privileged level
    
    context - the AccessControlContext to use
    
    Returns:
    
    the new direct executor
  - privilegedExecutor
```
public static DirectExecutor privilegedExecutor(DirectExecutor delegate,
                                                java.lang.Class<?> targetClass)
                                         throws java.lang.SecurityException
```
    Create a direct executor which runs with the privileges given by the supplied class' protection domain.
    
    Parameters:
    
    delegate - the executor to delegate to at the privileged level
    
    targetClass - the target class whose protection domain should be used
    
    Returns:
    
    the new direct executor
    
    Throws:
    
    java.lang.SecurityException - if there is a security manager installed and the caller lacks the "getProtectionDomain" RuntimePermission
  - privilegedExecutor
```
public static DirectExecutor privilegedExecutor(DirectExecutor delegate)
```
    Create a direct executor which runs with the privileges given by the current access control context.
    
    Parameters:
    
    delegate - the executor to delegate to at the privileged level
    
    Returns:
    
    the new direct executor
  - contextClassLoaderExecutor
```
public static DirectExecutor contextClassLoaderExecutor(DirectExecutor delegate,
                                                        java.lang.ClassLoader taskClassLoader)
```
    Create a direct executor which runs tasks with the given context class loader.
    
    Parameters:
    
    delegate - the executor to delegate to
    
    taskClassLoader - the context class loader to use
    
    Returns:
    
    the new direct executor
  - threadNameExecutor
```
public static DirectExecutor threadNameExecutor(DirectExecutor delegate,
                                                java.lang.String newName)
```
    Create a direct executor which changes the thread name for the duration of a task.
    
    Parameters:
    
    delegate - the executor to delegate to
    
    newName - the thread name to use
    
    Returns:
    
    the new direct executor
  - threadFormattedNameExecutor
```
public static DirectExecutor threadFormattedNameExecutor(DirectExecutor delegate,
                                                         java.lang.String newName)
```
    Create a direct executor which changes the thread name for the duration of a task using a formatted name. The thread must be a JBossThread.
    
    Parameters:
    
    delegate - the executor to delegate to
    
    newName - the thread name to use
    
    Returns:
    
    the new direct executor
  - threadNameNotateExecutor
```
public static DirectExecutor threadNameNotateExecutor(DirectExecutor delegate,
                                                      java.lang.String notation)
```
    Create a direct executor which adds a note to the thread name for the duration of a task.
    
    Parameters:
    
    delegate - the executor to delegate to
    
    notation - the note to use
    
    Returns:
    
    the new direct executor
  - exceptionLoggingExecutor
```
public static DirectExecutor exceptionLoggingExecutor(DirectExecutor delegate,
                                                      org.jboss.logging.Logger log)
```
    Create a direct executor which consumes and logs errors that are thrown.
    
    Parameters:
    
    delegate - the executor to delegate to
    
    log - the logger to which exceptions are written at the error level
    
    Returns:
    
    the new direct executor
  - exceptionLoggingExecutor
```
public static DirectExecutor exceptionLoggingExecutor(DirectExecutor delegate,
                                                      org.jboss.logging.Logger log,
                                                      org.jboss.logging.Logger.Level level)
```
    Create a direct executor which consumes and logs errors that are thrown.
    
    Parameters:
    
    delegate - the executor to delegate to
    
    log - the logger to which exceptions are written
    
    level - the level at which to log exceptions
    
    Returns:
    
    the new direct executor
  - exceptionLoggingExecutor
```
public static DirectExecutor exceptionLoggingExecutor(DirectExecutor delegate)
```
    Create a direct executor which consumes and logs errors that are thrown to the default thread error category "org.jboss.threads.errors".
    
    Parameters:
    
    delegate - the executor to delegate to
    
    Returns:
    
    the new direct executor
  - resettingExecutor
```
public static DirectExecutor resettingExecutor(DirectExecutor delegate)
                                        throws java.lang.SecurityException
```
    Create a direct executor which delegates tasks to the given executor, and then clears all thread-local data after each task completes (regardless of outcome). You must have the RuntimePermission("modifyThread") permission to use this method.
    
    Parameters:
    
    delegate - the delegate direct executor
    
    Returns:
    
    a resetting executor
    
    Throws:
    
    java.lang.SecurityException - if the caller does not have the RuntimePermission("modifyThread") permission
  - initializingExecutor
```
public static DirectExecutor initializingExecutor(DirectExecutor delegate,
                                                  java.lang.Runnable initializer)
```
    Create an executor which runs the given initialization task before running its given task.
    
    Parameters:
    
    delegate - the delegate direct executor
    
    initializer - the initialization task
    
    Returns:
    
    an initializing executor
  - cleanupExecutor
```
public static DirectExecutor cleanupExecutor(DirectExecutor delegate,
                                             java.lang.Runnable cleaner)
```
    Create an executor which runs the given cleanup task after running its given task.
    
    Parameters:
    
    delegate - the delegate direct executor
    
    cleaner - the cleanup task
    
    Returns:
    
    an initializing executor
  - blockingDirectExecutor
```
public static BlockingExecutor blockingDirectExecutor()
```
    Get an executor which executes tasks in the current thread, which implements BlockingExecutor.
    
    Returns:
    
    the blocking direct executor
  - blockingDiscardingExecutor
```
public static BlockingExecutor blockingDiscardingExecutor()
```
    Get an executor which discards all tasks, which implements BlockingExecutor.
    
    Returns:
    
    the executor
  - blockingRejectingExecutor
```
public static BlockingExecutor blockingRejectingExecutor()
```
    Get an executor which rejects all tasks, which implements BlockingExecutor.
    
    Returns:
    
    the executor
  - wrappingExecutor
```
public static java.util.concurrent.Executor wrappingExecutor(DirectExecutor taskWrapper,
                                                             java.util.concurrent.Executor delegate)
```
    An executor which delegates to another executor, wrapping each task in a task wrapper.
    
    Parameters:
    
    taskWrapper - the task wrapper
    
    delegate - the delegate executor
    
    Returns:
    
    a wrapping executor
  - directBlockingExecutor
```
public static BlockingExecutor directBlockingExecutor(DirectExecutor delegate)
```
    An executor which delegates to the given direct executor, but implements the blocking executor interface. Since direct executors always execute tasks in the current thread, no blocking is possible; therefore the methods of BlockingExecutors always succeed or fail instantly.
    
    Parameters:
    
    delegate - the delegate direct executor
    
    Returns:
    
    the blocking executor
  - wrappingExecutor
```
public static WrappingExecutor wrappingExecutor(java.util.concurrent.Executor delegate)
```
    Create a wrapping executor for a delegate executor which creates an executorTask(DirectExecutor, Runnable) for each task.
    
    Parameters:
    
    delegate - the delegate executor
    
    Returns:
    
    the wrapping executor
  - executor
```
public static java.util.concurrent.Executor executor(WrappingExecutor delegate,
                                                     DirectExecutor taskWrapper)
```
    An executor which delegates to a wrapping executor, wrapping each task in a task wrapper.
    
    Parameters:
    
    delegate - the delegate executor
    
    taskWrapper - the task wrapper
    
    Returns:
    
    a wrapping executor
  - threadFactoryExecutor
```
public static BlockingExecutor threadFactoryExecutor(java.util.concurrent.ThreadFactory factory)
```
    Create an executor that executes each task in a new thread.
    
    Parameters:
    
    factory - the thread factory to use
    
    Returns:
    
    the executor
  - threadFactoryExecutor
```
public static BlockingExecutor threadFactoryExecutor(java.util.concurrent.ThreadFactory factory,
                                                     int maxThreads)
```
    Create an executor that executes each task in a new thread. By default up to the given number of threads may run concurrently, after which new tasks will be rejected.
    
    Parameters:
    
    factory - the thread factory to use
    
    maxThreads - the maximum number of allowed threads
    
    Returns:
    
    the executor
  - threadFactoryExecutor
```
public static BlockingExecutor threadFactoryExecutor(java.util.concurrent.ThreadFactory factory,
                                                     int maxThreads,
                                                     boolean blocking)
```
    Create an executor that executes each task in a new thread. By default up to the given number of threads may run concurrently, after which the caller will block or new tasks will be rejected, according to the setting of the blocking parameter.
    
    Parameters:
    
    factory - the thread factory to use
    
    maxThreads - the maximum number of allowed threads
    
    blocking - true if the submitter should block when the maximum number of threads has been reached
    
    Returns:
    
    the executor
  - threadFactoryExecutor
```
public static BlockingExecutor threadFactoryExecutor(java.util.concurrent.ThreadFactory factory,
                                                     int maxThreads,
                                                     boolean blocking,
                                                     DirectExecutor taskExecutor)
```
    Create an executor that executes each task in a new thread. By default up to the given number of threads may run concurrently, after which the caller will block or new tasks will be rejected, according to the setting of the blocking parameter.
    
    Parameters:
    
    factory - the thread factory to use
    
    maxThreads - the maximum number of allowed threads
    
    blocking - true if the submitter should block when the maximum number of threads has been reached
    
    taskExecutor - the executor which should run each task
    
    Returns:
    
    the executor
  - abortPolicy
```
public static java.util.concurrent.RejectedExecutionHandler abortPolicy()
```
    Get the abort policy for a ThreadPoolExecutor.
    
    Returns:
    
    the abort policy
    
    See Also:
    
    ThreadPoolExecutor.AbortPolicy
  - callerRunsPolicy
```
public static java.util.concurrent.RejectedExecutionHandler callerRunsPolicy()
```
    Get the caller-runs policy for a ThreadPoolExecutor.
    
    Returns:
    
    the caller-runs policy
    
    See Also:
    
    ThreadPoolExecutor.CallerRunsPolicy
  - discardOldestPolicy
```
public static java.util.concurrent.RejectedExecutionHandler discardOldestPolicy()
```
    Get the discard-oldest policy for a ThreadPoolExecutor.
    
    Returns:
    
    the discard-oldest policy
    
    See Also:
    
    ThreadPoolExecutor.DiscardOldestPolicy
  - discardPolicy
```
public static java.util.concurrent.RejectedExecutionHandler discardPolicy()
```
    Get the discard policy for a ThreadPoolExecutor.
    
    Returns:
    
    the discard policy
    
    See Also:
    
    ThreadPoolExecutor.DiscardPolicy
  - handoffPolicy
```
public static java.util.concurrent.RejectedExecutionHandler handoffPolicy(java.util.concurrent.Executor target)
```
    Get a handoff policy for a ThreadPoolExecutor. The returned instance will delegate to another executor in the event that the task is rejected.
    
    Parameters:
    
    target - the target executor
    
    Returns:
    
    the new handoff policy implementation
  - protectedBlockingExecutor
```
public static BlockingExecutor protectedBlockingExecutor(BlockingExecutor target)
```
  - protectedExecutorService
```
public static java.util.concurrent.ExecutorService protectedExecutorService(java.util.concurrent.Executor target)
```
    Wrap an executor with an ExecutorService instance which supports all the features of ExecutorService except for shutting down the executor.
    
    Parameters:
    
    target - the target executor
    
    Returns:
    
    the executor service
  - protectedDirectExecutorService
```
public static DirectExecutorService protectedDirectExecutorService(DirectExecutor target)
```
    Wrap a direct executor with an DirectExecutorService instance which supports all the features of ExecutorService except for shutting down the executor.
    
    Parameters:
    
    target - the target executor
    
    Returns:
    
    the executor service
  - protectedScheduledExecutorService
```
public static java.util.concurrent.ScheduledExecutorService protectedScheduledExecutorService(java.util.concurrent.ScheduledExecutorService target)
```
    Wrap a scheduled executor with a ScheduledExecutorService instance which supports all the features of ScheduledExecutorService except for shutting down the executor.
    
    Parameters:
    
    target - the target executor
    
    Returns:
    
    the executor service
  - protectedBlockingExecutorService
```
public static BlockingExecutorService protectedBlockingExecutorService(BlockingExecutor target)
```
    Wrap a blocking executor with an BlockingExecutorService instance which supports all the features of BlockingExecutorService except for shutting down the executor.
    
    Parameters:
    
    target - the target executor
    
    Returns:
    
    the executor service
  - resettingThreadFactory
```
public static java.util.concurrent.ThreadFactory resettingThreadFactory(java.util.concurrent.ThreadFactory delegate)
                                                                 throws java.lang.SecurityException
```
    Create a thread factory which resets all thread-local storage and delegates to the given thread factory. You must have the RuntimePermission("modifyThread") permission to use this method.
    
    Parameters:
    
    delegate - the delegate thread factory
    
    Returns:
    
    the resetting thread factory
    
    Throws:
    
    java.lang.SecurityException - if the caller does not have the RuntimePermission("modifyThread") permission
  - wrappingThreadFactory
```
public static java.util.concurrent.ThreadFactory wrappingThreadFactory(DirectExecutor taskWrapper,
                                                                       java.util.concurrent.ThreadFactory delegate)
```
    Creates a thread factory which executes the thread task via the given task wrapping executor.
    
    Parameters:
    
    taskWrapper - the task wrapping executor
    
    delegate - the delegate thread factory
    
    Returns:
    
    the wrapping thread factory
  - nullRunnable
```
public static java.lang.Runnable nullRunnable()
```
    Get the null runnable which does nothing.
    
    Returns:
    
    the null runnable
  - threadLocalResetter
```
public static java.lang.Runnable threadLocalResetter()
                                              throws java.lang.SecurityException
```
    Get a Runnable which, when executed, clears the thread-local storage of the calling thread. You must have the RuntimePermission("modifyThread") permission to use this method.
    
    Returns:
    
    the runnable
    
    Throws:
    
    java.lang.SecurityException - if the caller does not have the RuntimePermission("modifyThread") permission
  - contextClassLoaderResetter
```
public static java.lang.Runnable contextClassLoaderResetter()
```
    Get a Runnable which, when executed, clears the thread context class loader (if the caller has sufficient privileges).
    
    Returns:
    
    the runnable
  - executorTask
```
public static java.lang.Runnable executorTask(DirectExecutor executor,
                                              java.lang.Runnable task)
```
    Get a task that runs the given task through the given direct executor.
    
    Parameters:
    
    executor - the executor to run the task through
    
    task - the task to run
    
    Returns:
    
    an encapsulating task
  - compositeTask
```
public static java.lang.Runnable compositeTask(java.lang.Runnable... runnables)
```
    Create a task that is a composite of several other tasks.
    
    Parameters:
    
    runnables - the tasks
    
    Returns:
    
    the composite task
  - classLoaderPreservingTask
```
public static java.lang.Runnable classLoaderPreservingTask(java.lang.Runnable delegate)
                                                    throws java.lang.SecurityException
```
    Create a task that delegates to the given task, preserving the context classloader which was in effect when this method was invoked.
    
    Parameters:
    
    delegate - the delegate runnable
    
    Returns:
    
    the wrapping runnable
    
    Throws:
    
    java.lang.SecurityException - if a security manager exists and the caller does not have the "copyClassLoader" RuntimePermission.
  - getContextClassLoader
```
static java.lang.ClassLoader getContextClassLoader(java.lang.Thread thread)
```
    Privileged method to get the context class loader of the given thread.
    
    Parameters:
    
    thread - the thread to introspect
    
    Returns:
    
    the context class loader
  - getAndSetContextClassLoader
```
static java.lang.ClassLoader getAndSetContextClassLoader(java.lang.Thread thread,
                                                         java.lang.ClassLoader newClassLoader)
```
    Privileged method to get and set the context class loader of the given thread.
    
    Parameters:
    
    thread - the thread to introspect
    
    newClassLoader - the new context class loader
    
    Returns:
    
    the old context class loader
  - setContextClassLoader
```
static void setContextClassLoader(java.lang.Thread thread,
                                  java.lang.ClassLoader classLoader)
```
    Privileged method to set the context class loader of the given thread.
    
    Parameters:
    
    thread - the thread to introspect
    
    classLoader - the new context class loader
  - compositeTask
```
public static java.lang.Runnable compositeTask(java.util.Collection<java.lang.Runnable> runnables)
```
    Create a task that is a composite of several other tasks.
    
    Parameters:
    
    runnables - the tasks
    
    Returns:
    
    the composite task
  - checkAccess
```
static void checkAccess(java.security.Permission permission)
```
  - loggingExceptionHandler
```
public static java.lang.Thread.UncaughtExceptionHandler loggingExceptionHandler(org.jboss.logging.Logger log)
```
    Get an uncaught exception handler which logs to the given logger.
    
    Parameters:
    
    log - the logger
    
    Returns:
    
    the handler
  - loggingExceptionHandler
```
public static java.lang.Thread.UncaughtExceptionHandler loggingExceptionHandler(java.lang.String categoryName)
```
    Get an uncaught exception handler which logs to the given logger.
    
    Parameters:
    
    categoryName - the name of the logger category to log to
    
    Returns:
    
    the handler
  - loggingExceptionHandler
```
public static java.lang.Thread.UncaughtExceptionHandler loggingExceptionHandler()
```
    Get an uncaught exception handler which logs to the default error logger.
    
    Returns:
    
    the handler
  - logError
```
private static <R extends java.lang.Runnable> void logError(R runnable,
                                                            java.lang.Throwable t,
                                                            java.lang.String method)
```
  - started
```
private static <R extends java.lang.Runnable,A> void started(TaskNotifier<? super R,? super A> notifier,
                                                             R runnable,
                                                             A attachment)
```
  - finished
```
private static <R extends java.lang.Runnable,A> void finished(TaskNotifier<? super R,? super A> notifier,
                                                              R runnable,
                                                              A attachment)
```
  - failed
```
private static <R extends java.lang.Runnable,A> void failed(TaskNotifier<? super R,? super A> notifier,
                                                            java.lang.Throwable reason,
                                                            R runnable,
                                                            A attachment)
```
  - run
```
public static <R extends java.lang.Runnable,A> void run(R task,
                                                        DirectExecutor directExecutor,
                                                        TaskNotifier<? super R,? super A> notifier,
                                                        A attachment)
```
    Run a task through the given direct executor, invoking the given notifier with the given attachment.
    
    Type Parameters:
    
    R - the task type
    
    A - the attachment type
    
    Parameters:
    
    task - the task
    
    directExecutor - the executor
    
    notifier - the notifier
    
    attachment - the attachment
  - run
```
public static <R extends java.lang.Runnable,A> void run(R task,
                                                        TaskNotifier<? super R,? super A> notifier,
                                                        A attachment)
```
    Run a task, invoking the given notifier with the given attachment.
    
    Type Parameters:
    
    R - the task type
    
    A - the attachment type
    
    Parameters:
    
    task - the task
    
    notifier - the notifier
    
    attachment - the attachment
  - notifyingRunnable
```
public static <R extends java.lang.Runnable,A> java.lang.Runnable notifyingRunnable(R task,
                                                                                    TaskNotifier<? super R,? super A> notifier,
                                                                                    A attachment)
```
    Get a notifying runnable wrapper for a task. The notifier will be invoked when the task is run.
    
    Type Parameters:
    
    R - the task type
    
    A - the attachment type
    
    Parameters:
    
    task - the task
    
    notifier - the notifier
    
    attachment - the attachment
    
    Returns:
    
    the wrapping runnable
  - notifyingDirectExecutor
```
public static <A> DirectExecutor notifyingDirectExecutor(DirectExecutor delegate,
                                                         TaskNotifier<java.lang.Runnable,? super A> notifier,
                                                         A attachment)
```
    Get a notifying direct executor. The notifier will be invoked when each task is run.
    
    Type Parameters:
    
    A - the attachment type
    
    Parameters:
    
    delegate - the executor which will actually run the task
    
    notifier - the notifier
    
    attachment - the attachment
    
    Returns:
    
    the direct executor
  - executeUninterruptibly
```
public static void executeUninterruptibly(java.util.concurrent.Executor executor,
                                          java.lang.Runnable task)
                                   throws java.util.concurrent.RejectedExecutionException
```
    Execute a task uninterruptibly.
    
    Parameters:
    
    executor - the executor to delegate to
    
    task - the task to execute
    
    Throws:
    
    java.util.concurrent.RejectedExecutionException - if the task was rejected by the executor
  - uninterruptibleExecutor
```
public static java.util.concurrent.Executor uninterruptibleExecutor(java.util.concurrent.Executor delegate)
```
    Get an executor which executes tasks uninterruptibly in the event of blocking.
    
    Parameters:
    
    delegate - the delegate executor
    
    Returns:
    
    the uninterruptible executor
  - dependencyTaskBuilder
```
public static DependencyTaskBuilder dependencyTaskBuilder(java.util.concurrent.Executor executor,
                                                          java.lang.Runnable task)
```
    Create a builder for a dependent task.
    
    Parameters:
    
    executor - the executor to use
    
    task - the task to run when all dependencies are met
    
    Returns:
    
    the builder

Class JBossExecutors

Field Summary

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Field Detail

THREAD_ERROR_LOGGER

MODIFY_THREAD_PERMISSION

COPY_CONTEXT_CLASSLOADER_PERMISSION

DIRECT_EXECUTOR_SERVICE

REJECTING_EXECUTOR_SERVICE

DISCARDING_EXECUTOR_SERVICE

BLOCKING_DIRECT_EXECUTOR

BLOCKING_REJECTING_EXECUTOR

BLOCKING_DISCARDING_EXECUTOR

ABORT_POLICY

CALLER_RUNS_POLICY

DISCARD_OLDEST_POLICY

DISCARD_POLICY

TCCL_RESETTER

NULL_RUNNABLE

THREAD_LOCAL_RESETTER

LOGGING_HANDLER

Constructor Detail

JBossExecutors

Method Detail

directExecutor

directExecutorService

rejectingExecutor

rejectingExecutor

rejectingExecutorService

rejectingExecutorService

discardingExecutor

discardingExecutorService

privilegedExecutor

privilegedExecutor

privilegedExecutor

contextClassLoaderExecutor

threadNameExecutor

threadFormattedNameExecutor

threadNameNotateExecutor

exceptionLoggingExecutor

exceptionLoggingExecutor

exceptionLoggingExecutor

resettingExecutor

initializingExecutor

cleanupExecutor

blockingDirectExecutor

blockingDiscardingExecutor

blockingRejectingExecutor

wrappingExecutor

directBlockingExecutor

wrappingExecutor

executor

threadFactoryExecutor

threadFactoryExecutor

threadFactoryExecutor

threadFactoryExecutor

abortPolicy

callerRunsPolicy

discardOldestPolicy

discardPolicy

handoffPolicy

protectedBlockingExecutor

protectedExecutorService

protectedDirectExecutorService

protectedScheduledExecutorService

protectedBlockingExecutorService

resettingThreadFactory

wrappingThreadFactory

nullRunnable

threadLocalResetter

contextClassLoaderResetter

executorTask

compositeTask

classLoaderPreservingTask

getContextClassLoader

getAndSetContextClassLoader

setContextClassLoader

compositeTask