| Package | Description |
|---|---|
| io.zeebe.util.sched | |
| io.zeebe.util.sched.testing |
| Modifier and Type | Class and Description |
|---|---|
class |
CpuThreadGroup
Thread group for the non-blocking, CPU bound, tasks.
|
class |
IoThreadGroup |
| Modifier and Type | Method and Description |
|---|---|
ActorThreadGroup |
ActorThread.getActorThreadGroup() |
ActorThreadGroup |
ActorTask.getActorThreadGroup() |
ActorThreadGroup |
ActorScheduler.ActorSchedulerBuilder.getCpuBoundActorThreads() |
ActorThreadGroup |
ActorExecutor.getCpuBoundThreads() |
ActorThreadGroup |
ActorScheduler.ActorSchedulerBuilder.getIoBoundActorThreads() |
ActorThreadGroup |
ActorExecutor.getIoBoundThreads() |
| Modifier and Type | Method and Description |
|---|---|
ActorThread |
ActorScheduler.ActorThreadFactory.newThread(String name,
int id,
ActorThreadGroup threadGroup,
TaskScheduler taskScheduler,
ActorClock clock,
ActorThreadMetrics metrics,
ActorTimerQueue timerQueue) |
ActorThread |
ActorScheduler.DefaultActorThreadFactory.newThread(String name,
int id,
ActorThreadGroup threadGroup,
TaskScheduler taskScheduler,
ActorClock clock,
ActorThreadMetrics metrics,
ActorTimerQueue timerQueue) |
ActorFuture<Void> |
ActorTask.onTaskScheduled(ActorExecutor actorExecutor,
ActorThreadGroup actorThreadGroup,
TaskMetrics taskMetrics)
called when the task is initially scheduled.
|
| Constructor and Description |
|---|
ActorThread(String name,
int id,
ActorThreadGroup threadGroup,
TaskScheduler taskScheduler,
ActorClock clock,
ActorThreadMetrics metrics,
ActorTimerQueue timerQueue) |
| Constructor and Description |
|---|
ControlledActorThread(String name,
int id,
ActorThreadGroup threadGroup,
TaskScheduler taskScheduler,
ActorClock clock,
ActorThreadMetrics metrics,
ActorTimerQueue timerQueue) |
Copyright © 2017–2019 camunda services GmbH. All rights reserved.