| Package | Description |
|---|---|
| org.trancecode.concurrent | |
| org.trancecode.event | |
| org.trancecode.xproc |
| Modifier and Type | Method and Description |
|---|---|
static TaskExecutor |
TaskExecutors.directExecutor()
Returns a
TaskExecutor that executes tasks as soon as they get
submitted. |
static TaskExecutor |
TaskExecutors.forExecutorService(ExecutorService executor) |
static TaskExecutor |
TaskExecutors.onDemandExecutor()
Returns a
TaskExecutor which executes tasks when the
Future.get() method is invoked. |
| Modifier and Type | Method and Description |
|---|---|
static <T> com.google.common.base.Function<Callable<T>,Future<T>> |
CallableFunctions.submit(TaskExecutor executor) |
static <T> Iterable<Future<T>> |
TcFutures.submit(TaskExecutor executor,
Iterable<Callable<T>> tasks) |
| Modifier and Type | Method and Description |
|---|---|
static <T extends Event> |
EventDispatchers.newEventDispatcher(boolean blockingNotification,
TaskExecutor executor,
AbstractEventObservable.NotificationFailurePolicy notificationFailurePolicy) |
| Constructor and Description |
|---|
AbstractEventObservable(boolean blockingNotification,
TaskExecutor executor,
AbstractEventObservable.NotificationFailurePolicy notificationFailurePolicy) |
| Modifier and Type | Method and Description |
|---|---|
TaskExecutor |
PipelineContext.getExecutor() |
| Modifier and Type | Method and Description |
|---|---|
void |
PipelineConfiguration.setExecutor(TaskExecutor executor) |
Copyright © 2009-2012 TranceCode. All Rights Reserved.