public class ActorExecutor extends Object
ActorTasks and Blocking Actions to the scheduler's internal
runners and queues.| Constructor and Description |
|---|
ActorExecutor(ActorScheduler.ActorSchedulerBuilder builder) |
| Modifier and Type | Method and Description |
|---|---|
CompletableFuture<Void> |
closeAsync() |
java.time.Duration |
getBlockingTasksShutdownTime() |
ActorThreadGroup |
getCpuBoundThreads() |
ActorThreadGroup |
getIoBoundThreads() |
MetricsManager |
getMetricsManager() |
void |
setBlockingTasksShutdownTime(java.time.Duration duration) |
void |
start() |
void |
submitBlocking(Runnable action)
Sumbit a blocking action to run using the scheduler's blocking thread pool
|
ActorFuture<Void> |
submitCpuBound(ActorTask task,
boolean collectTaskMetrics)
Initially submit a non-blocking actor to be managed by this schedueler.
|
ActorFuture<Void> |
submitIoBoundTask(ActorTask task,
boolean collectTaskMetrics) |
public ActorExecutor(ActorScheduler.ActorSchedulerBuilder builder)
public ActorFuture<Void> submitCpuBound(ActorTask task, boolean collectTaskMetrics)
task - the task to submitcollectTaskMetrics - Controls whether metrics should be collected. (See ActorScheduler.submitActor(Actor, boolean))public ActorFuture<Void> submitIoBoundTask(ActorTask task, boolean collectTaskMetrics)
public void submitBlocking(Runnable action)
action - the action to submitpublic void start()
public CompletableFuture<Void> closeAsync()
public MetricsManager getMetricsManager()
public ActorThreadGroup getCpuBoundThreads()
public ActorThreadGroup getIoBoundThreads()
public java.time.Duration getBlockingTasksShutdownTime()
public void setBlockingTasksShutdownTime(java.time.Duration duration)
Copyright © 2017–2019 camunda services GmbH. All rights reserved.