public interface WorkQueue
Modifier and Type | Method | Description |
---|---|---|
void |
await() |
Blocks until all work associated with this queue is complete.
|
<T extends WorkParameters> |
submit(java.lang.Class<? extends WorkAction<T>> workActionClass,
Action<? super T> parameterAction) |
Submits a piece of work to be executed asynchronously.
|
<T extends WorkParameters> void submit(java.lang.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.