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.InterruptedException
public void startBatch()
public java.util.concurrent.CompletableFuture<R> finishBatch()