public class TaskManager<K,T extends ITaskType<K,T>,R>
extends java.lang.Object
| Constructor and Description |
|---|
TaskManager(Scheduler<K,T,R> schedulerIn) |
| Modifier and Type | Method and Description |
|---|---|
java.util.concurrent.CompletableFuture<R> |
addToBatch(K key) |
java.util.concurrent.CompletableFuture<R> |
finishBatch() |
void |
shutdown() |
void |
startBatch() |
public void shutdown()
throws java.lang.InterruptedException
java.lang.InterruptedExceptionpublic void startBatch()
public java.util.concurrent.CompletableFuture<R> finishBatch()