| Package | Description |
|---|---|
| io.zeebe.util.sched | |
| io.zeebe.util.sched.clock | |
| io.zeebe.util.sched.testing |
| Modifier and Type | Method and Description |
|---|---|
ActorClock |
ActorScheduler.ActorSchedulerBuilder.getActorClock() |
ActorClock |
ActorThread.getClock() |
| Modifier and Type | Method and Description |
|---|---|
ActorTask |
PriorityScheduler.getNextTask(ActorClock clock)
calculates and returns the next task to execute or null if no such task can be determined.
|
ActorTask |
IoScheduler.getNextTask(ActorClock now) |
ActorTask |
TaskScheduler.getNextTask(ActorClock now) |
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) |
void |
ActorTimerQueue.processExpiredTimers(ActorClock clock) |
void |
ActorTimerQueue.schedule(TimerSubscription timer,
ActorClock now) |
ActorScheduler.ActorSchedulerBuilder |
ActorScheduler.ActorSchedulerBuilder.setActorClock(ActorClock actorClock) |
| Constructor and Description |
|---|
ActorThread(String name,
int id,
ActorThreadGroup threadGroup,
TaskScheduler taskScheduler,
ActorClock clock,
ActorThreadMetrics metrics,
ActorTimerQueue timerQueue) |
ActorTimerQueue(ActorClock clock) |
ActorTimerQueue(ActorClock clock,
int ticksPerWheel) |
| Modifier and Type | Class and Description |
|---|---|
class |
ControlledActorClock
For testcases
|
class |
DefaultActorClock
Default actor clock implementation; minimizes calls to
System.currentTimeMillis() to once
per millisecond. |
| Modifier and Type | Method and Description |
|---|---|
static ActorClock |
ActorClock.current() |
| Constructor and Description |
|---|
ActorSchedulerRule(ActorClock clock) |
ActorSchedulerRule(int numOfThreads,
ActorClock clock) |
ActorSchedulerRule(int numOfThreads,
int numOfIoThreads,
ActorClock clock) |
ControlledActorThread(String name,
int id,
ActorThreadGroup threadGroup,
TaskScheduler taskScheduler,
ActorClock clock,
ActorThreadMetrics metrics,
ActorTimerQueue timerQueue) |
Copyright © 2017–2019 camunda services GmbH. All rights reserved.