public class DeferredCommandContext extends Object
| Modifier and Type | Field and Description |
|---|---|
protected java.util.function.Consumer<Runnable> |
cmdConsumer |
protected org.agrona.concurrent.ManyToOneConcurrentLinkedQueue<Runnable> |
cmdQueue |
| Constructor and Description |
|---|
DeferredCommandContext() |
| Modifier and Type | Method and Description |
|---|---|
void |
doWork() |
<T> CompletableFuture<T> |
runAsync(java.util.function.Consumer<CompletableFuture<T>> action) |
void |
runAsync(Runnable r)
Use this when no future is required.
|
protected final org.agrona.concurrent.ManyToOneConcurrentLinkedQueue<Runnable> cmdQueue
protected final java.util.function.Consumer<Runnable> cmdConsumer
public <T> CompletableFuture<T> runAsync(java.util.function.Consumer<CompletableFuture<T>> action)
public void runAsync(Runnable r)
public void doWork()
Copyright © 2017–2019 camunda services GmbH. All rights reserved.