-
Method Summary
<T> com.google.common.util.concurrent.ListenableFuture<T>
Enqueues a job in nodeconfigurator.
-
Method Details
-
enqueueJob
<T>
com.google.common.util.concurrent.ListenableFuture<T> enqueueJob(String key,
Callable<com.google.common.util.concurrent.ListenableFuture<T>> mainWorker)
Enqueues a job in nodeconfigurator.
- Parameters:
key
- The job's key. Jobs with the same key are run sequentially.
Jobs with different keys are run in parallel.
mainWorker
- The task that runs for the job.
- Returns:
- the result of the enqueued job.