public interface WorkQueue
| Modifier and Type | Method | Description |
|---|---|---|
void |
await() |
Blocks until all work associated with this queue is complete.
|
<T extends WorkParameters> |
submit(Class<? extends WorkAction<T>> workActionClass,
Action<? super T> parameterAction) |
Submits a piece of work to be executed asynchronously.
|
<T extends WorkParameters> void submit(Class<? extends WorkAction<T>> workActionClass, Action<? super T> parameterAction)
WorkerExecutor.processIsolation() will execute in an idle daemon that meets the requirements set
in the ProcessWorkerSpec. If no idle daemons are available, a new daemon will be started. Any errors
will be thrown from await() or from the surrounding task action if await() is not used.void await()
throws WorkerExecutionException
WorkerExecutionException - when a failure occurs while executing the work.