Package | Description |
---|---|
org.jboss.threads |
Modifier and Type | Interface and Description |
---|---|
interface |
DirectExecutorService
A direct executor service.
|
Modifier and Type | Method and Description |
---|---|
static DirectExecutor |
JBossExecutors.cleanupExecutor(DirectExecutor delegate,
Runnable cleaner)
Create an executor which runs the given cleanup task after running its given task.
|
static DirectExecutor |
JBossExecutors.contextClassLoaderExecutor(DirectExecutor delegate,
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,
Logger log)
Create a direct executor which consumes and logs errors that are thrown.
|
static DirectExecutor |
JBossExecutors.exceptionLoggingExecutor(DirectExecutor delegate,
Logger log,
Logger.Level level)
Create a direct executor which consumes and logs errors that are thrown.
|
static DirectExecutor |
JBossExecutors.initializingExecutor(DirectExecutor delegate,
Runnable initializer)
Create an executor which runs the given initialization task before running its given task.
|
static <A> DirectExecutor |
JBossExecutors.notifyingDirectExecutor(DirectExecutor delegate,
TaskNotifier<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,
AccessControlContext context)
Create a direct executor which runs with the privileges given by the supplied
AccessControlContext instance. |
static DirectExecutor |
JBossExecutors.privilegedExecutor(DirectExecutor delegate,
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(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,
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,
String newName)
Create a direct executor which changes the thread name for the duration of a task.
|
static DirectExecutor |
JBossExecutors.threadNameNotateExecutor(DirectExecutor delegate,
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,
Runnable cleaner)
Create an executor which runs the given cleanup task after running its given task.
|
static DirectExecutor |
JBossExecutors.contextClassLoaderExecutor(DirectExecutor delegate,
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,
Logger log)
Create a direct executor which consumes and logs errors that are thrown.
|
static DirectExecutor |
JBossExecutors.exceptionLoggingExecutor(DirectExecutor delegate,
Logger log,
Logger.Level level)
Create a direct executor which consumes and logs errors that are thrown.
|
void |
WrappingExecutor.execute(DirectExecutor directExecutor,
Runnable task)
Run the given task within the given wrapper.
|
static Executor |
JBossExecutors.executor(WrappingExecutor delegate,
DirectExecutor taskWrapper)
An executor which delegates to a wrapping executor, wrapping each task in a task wrapper.
|
static Runnable |
JBossExecutors.executorTask(DirectExecutor executor,
Runnable task)
Get a task that runs the given task through the given direct executor.
|
static DirectExecutor |
JBossExecutors.initializingExecutor(DirectExecutor delegate,
Runnable initializer)
Create an executor which runs the given initialization task before running its given task.
|
static <A> DirectExecutor |
JBossExecutors.notifyingDirectExecutor(DirectExecutor delegate,
TaskNotifier<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,
AccessControlContext context)
Create a direct executor which runs with the privileges given by the supplied
AccessControlContext instance. |
static DirectExecutor |
JBossExecutors.privilegedExecutor(DirectExecutor delegate,
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 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(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,
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,
String newName)
Create a direct executor which changes the thread name for the duration of a task.
|
static DirectExecutor |
JBossExecutors.threadNameNotateExecutor(DirectExecutor delegate,
String notation)
Create a direct executor which adds a note to the thread name for the duration of a task.
|
static Executor |
JBossExecutors.wrappingExecutor(DirectExecutor taskWrapper,
Executor delegate)
An executor which delegates to another executor, wrapping each task in a task wrapper.
|
static ThreadFactory |
JBossExecutors.wrappingThreadFactory(DirectExecutor taskWrapper,
ThreadFactory delegate)
Creates a thread factory which executes the thread task via the given task wrapping executor.
|
Constructor and Description |
---|
QueueExecutor(int coreThreads,
int maxThreads,
long keepAliveTime,
TimeUnit keepAliveTimeUnit,
Queue<Runnable> queue,
ThreadFactory threadFactory,
boolean blocking,
Executor handoffExecutor,
DirectExecutor taskExecutor)
Create a new instance.
|
QueuelessExecutor(ThreadFactory threadFactory,
DirectExecutor taskExecutor,
Executor handoffExecutor,
long keepAliveTime) |
Copyright © 2012 JBoss by Red Hat. All Rights Reserved.