| Package | Description |
|---|---|
| org.jboss.threads |
| Modifier and Type | Interface and Description |
|---|---|
interface |
DirectExecutorService
A direct executor service.
|
| Modifier and Type | Class and Description |
|---|---|
(package private) class |
CleanupExecutor |
(package private) class |
ContextClassLoaderExecutor |
(package private) class |
DelegatingDirectBlockingExecutor |
(package private) class |
DelegatingDirectExecutor
A direct executor that simply delegates to another direct executor.
|
(package private) class |
DelegatingDirectExecutorService
A
DirectExecutor version of ProtectedExecutorService. |
(package private) class |
DiscardingExecutor |
(package private) class |
ExceptionLoggingExecutor |
(package private) class |
InitializingExecutor |
(package private) class |
NotifyingDirectExecutor<A> |
(package private) class |
PrivilegedExecutor |
(package private) class |
RejectingExecutor |
(package private) class |
SimpleDirectExecutor |
(package private) class |
ThreadFormattedNameExecutor |
(package private) class |
ThreadNameExecutor |
(package private) class |
ThreadNameNotatingExecutor |
| Modifier and Type | Field and Description |
|---|---|
private static DirectExecutor |
CleanupExecutor.CLEANER_EXECUTOR |
private DirectExecutor |
ExceptionLoggingExecutor.delegate |
private DirectExecutor |
ContextClassLoaderExecutor.delegate |
private DirectExecutor |
ThreadNameExecutor.delegate |
private DirectExecutor |
CleanupExecutor.delegate |
private DirectExecutor |
InitializingExecutor.delegate |
private DirectExecutor |
ThreadNameNotatingExecutor.delegate |
private DirectExecutor |
PrivilegedExecutor.delegate |
private DirectExecutor |
DelegatingDirectBlockingExecutor.delegate |
private DirectExecutor |
ThreadFormattedNameExecutor.delegate |
private DirectExecutor |
ExecutorTask.executor |
(package private) static DirectExecutor |
SimpleDirectExecutor.INSTANCE |
private DirectExecutor |
QueuelessExecutor.taskExecutor |
private DirectExecutor |
ThreadFactoryExecutor.taskExecutor |
private DirectExecutor |
QueueExecutor.taskExecutor |
private DirectExecutor |
WrappingThreadFactory.taskWrapper |
private DirectExecutor |
DelegatingWrappedExecutor.taskWrapper |
| Modifier and Type | Method and Description |
|---|---|
static DirectExecutor |
JBossExecutors.cleanupExecutor(DirectExecutor delegate,
java.lang.Runnable cleaner)
Create an executor which runs the given cleanup task after running its given task.
|
static DirectExecutor |
JBossExecutors.contextClassLoaderExecutor(DirectExecutor delegate,
java.lang.ClassLoader taskClassLoader)
Create a direct executor which runs tasks with the given context class loader.
|
static DirectExecutor |
JBossExecutors.directExecutor()
Get the direct executor.
|
static DirectExecutor |
JBossExecutors.discardingExecutor()
Get the discarding executor.
|
static DirectExecutor |
JBossExecutors.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 |
JBossExecutors.exceptionLoggingExecutor(DirectExecutor delegate,
org.jboss.logging.Logger log)
Create a direct executor which consumes and logs errors that are thrown.
|
static DirectExecutor |
JBossExecutors.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.
|
protected DirectExecutor |
DelegatingDirectExecutor.getDelegate() |
static DirectExecutor |
JBossExecutors.initializingExecutor(DirectExecutor delegate,
java.lang.Runnable initializer)
Create an executor which runs the given initialization task before running its given task.
|
static <A> DirectExecutor |
JBossExecutors.notifyingDirectExecutor(DirectExecutor delegate,
TaskNotifier<java.lang.Runnable,? super A> notifier,
A attachment)
Get a notifying direct executor.
|
static DirectExecutor |
JBossExecutors.privilegedExecutor(DirectExecutor delegate)
Create a direct executor which runs with the privileges given by the current access control context.
|
static DirectExecutor |
JBossExecutors.privilegedExecutor(DirectExecutor delegate,
java.security.AccessControlContext context)
Create a direct executor which runs with the privileges given by the supplied
AccessControlContext instance. |
static DirectExecutor |
JBossExecutors.privilegedExecutor(DirectExecutor delegate,
java.lang.Class<?> targetClass)
Create a direct executor which runs with the privileges given by the supplied class' protection domain.
|
static DirectExecutor |
JBossExecutors.rejectingExecutor()
Get the rejecting executor.
|
static DirectExecutor |
JBossExecutors.rejectingExecutor(java.lang.String message)
Get a rejecting executor.
|
static DirectExecutor |
JBossExecutors.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 DirectExecutor |
JBossExecutors.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 DirectExecutor |
JBossExecutors.threadNameExecutor(DirectExecutor delegate,
java.lang.String newName)
Create a direct executor which changes the thread name for the duration of a task.
|
static DirectExecutor |
JBossExecutors.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.
|
| Modifier and Type | Method and Description |
|---|---|
static DirectExecutor |
JBossExecutors.cleanupExecutor(DirectExecutor delegate,
java.lang.Runnable cleaner)
Create an executor which runs the given cleanup task after running its given task.
|
static DirectExecutor |
JBossExecutors.contextClassLoaderExecutor(DirectExecutor delegate,
java.lang.ClassLoader taskClassLoader)
Create a direct executor which runs tasks with the given context class loader.
|
static BlockingExecutor |
JBossExecutors.directBlockingExecutor(DirectExecutor delegate)
An executor which delegates to the given direct executor, but implements the blocking executor interface.
|
static DirectExecutor |
JBossExecutors.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 |
JBossExecutors.exceptionLoggingExecutor(DirectExecutor delegate,
org.jboss.logging.Logger log)
Create a direct executor which consumes and logs errors that are thrown.
|
static DirectExecutor |
JBossExecutors.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.
|
void |
WrappingExecutor.execute(DirectExecutor directExecutor,
java.lang.Runnable task)
Run the given task within the given wrapper.
|
void |
DelegatingWrappingExecutor.execute(DirectExecutor directExecutor,
java.lang.Runnable task) |
static void |
JBossThread.executeWithInterruptDeferred(DirectExecutor directExecutor,
java.lang.Runnable task)
Defer interrupts for the duration of some task.
|
static java.util.concurrent.Executor |
JBossExecutors.executor(WrappingExecutor delegate,
DirectExecutor taskWrapper)
An executor which delegates to a wrapping executor, wrapping each task in a task wrapper.
|
static java.lang.Runnable |
JBossExecutors.executorTask(DirectExecutor executor,
java.lang.Runnable task)
Get a task that runs the given task through the given direct executor.
|
static DirectExecutor |
JBossExecutors.initializingExecutor(DirectExecutor delegate,
java.lang.Runnable initializer)
Create an executor which runs the given initialization task before running its given task.
|
static <A> DirectExecutor |
JBossExecutors.notifyingDirectExecutor(DirectExecutor delegate,
TaskNotifier<java.lang.Runnable,? super A> notifier,
A attachment)
Get a notifying direct executor.
|
static DirectExecutor |
JBossExecutors.privilegedExecutor(DirectExecutor delegate)
Create a direct executor which runs with the privileges given by the current access control context.
|
static DirectExecutor |
JBossExecutors.privilegedExecutor(DirectExecutor delegate,
java.security.AccessControlContext context)
Create a direct executor which runs with the privileges given by the supplied
AccessControlContext instance. |
static DirectExecutor |
JBossExecutors.privilegedExecutor(DirectExecutor delegate,
java.lang.Class<?> targetClass)
Create a direct executor which runs with the privileges given by the supplied class' protection domain.
|
static DirectExecutorService |
JBossExecutors.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 DirectExecutor |
JBossExecutors.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 <R extends java.lang.Runnable,A> |
JBossExecutors.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 BlockingExecutor |
JBossExecutors.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 |
JBossExecutors.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 DirectExecutor |
JBossExecutors.threadNameExecutor(DirectExecutor delegate,
java.lang.String newName)
Create a direct executor which changes the thread name for the duration of a task.
|
static DirectExecutor |
JBossExecutors.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 |
JBossExecutors.wrappingExecutor(DirectExecutor taskWrapper,
java.util.concurrent.Executor delegate)
An executor which delegates to another executor, wrapping each task in a task wrapper.
|
static java.util.concurrent.ThreadFactory |
JBossExecutors.wrappingThreadFactory(DirectExecutor taskWrapper,
java.util.concurrent.ThreadFactory delegate)
Creates a thread factory which executes the thread task via the given task wrapping executor.
|
| Constructor and Description |
|---|
CleanupExecutor(java.lang.Runnable cleaner,
DirectExecutor delegate) |
ContextClassLoaderExecutor(java.lang.ClassLoader taskClassLoader,
DirectExecutor delegate) |
DelegatingDirectBlockingExecutor(DirectExecutor delegate) |
DelegatingDirectExecutor(DirectExecutor delegate) |
DelegatingDirectExecutorService(DirectExecutor delegate) |
DelegatingWrappedExecutor(WrappingExecutor delegate,
DirectExecutor taskWrapper) |
ExceptionLoggingExecutor(DirectExecutor delegate,
org.jboss.logging.Logger log) |
ExceptionLoggingExecutor(DirectExecutor delegate,
org.jboss.logging.Logger log,
org.jboss.logging.Logger.Level level) |
ExecutorTask(DirectExecutor executor,
java.lang.Runnable task) |
InitializingExecutor(java.lang.Runnable initializer,
DirectExecutor delegate) |
NotifyingDirectExecutor(DirectExecutor delegate,
TaskNotifier<java.lang.Runnable,? super A> notifier,
A attachment) |
PrivilegedExecutor(DirectExecutor delegate,
java.security.AccessControlContext context) |
PrivilegedExecutor(DirectExecutor delegate,
java.lang.Class<?> targetClass) |
QueueExecutor(int coreThreads,
int maxThreads,
long keepAliveTime,
java.util.concurrent.TimeUnit keepAliveTimeUnit,
java.util.Queue<java.lang.Runnable> queue,
java.util.concurrent.ThreadFactory threadFactory,
boolean blocking,
java.util.concurrent.Executor handoffExecutor,
DirectExecutor taskExecutor)
Create a new instance.
|
QueuelessExecutor(java.util.concurrent.ThreadFactory threadFactory,
DirectExecutor taskExecutor,
java.util.concurrent.Executor handoffExecutor,
long keepAliveTime) |
ThreadFactoryExecutor(java.util.concurrent.ThreadFactory factory,
int maxThreads,
boolean blocking,
DirectExecutor taskExecutor) |
ThreadFormattedNameExecutor(java.lang.String nameFormat,
DirectExecutor delegate) |
ThreadNameExecutor(java.lang.String newName,
DirectExecutor delegate) |
ThreadNameNotatingExecutor(java.lang.String notation,
DirectExecutor delegate) |
WrappingThreadFactory(java.util.concurrent.ThreadFactory delegate,
DirectExecutor taskWrapper) |