| Package | Description |
|---|---|
| io.zeebe.util.sched | |
| io.zeebe.util.sched.future |
| Modifier and Type | Method and Description |
|---|---|
ActorTask |
ActorThread.getCurrentTask() |
protected ActorTask |
WorkStealingGroup.getNextTask()
Attempts to acquire the next task to execute
|
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) |
ActorTask |
MultiLevelWorkstealingGroup.getNextTask(int level) |
ActorTask |
ActorJob.getTask() |
ActorTask |
ActorTaskQueue.pop() |
ActorTask |
ActorTaskQueue.trySteal()
Attempts to steal a task from this list.
|
| Modifier and Type | Method and Description |
|---|---|
void |
ActorTaskQueue.append(ActorTask task)
appends a task at the end (tail) of the list
|
protected int |
IoThreadGroup.getLevel(ActorTask actorTask) |
protected int |
CpuThreadGroup.getLevel(ActorTask actorTask) |
protected abstract int |
ActorThreadGroup.getLevel(ActorTask actorTask) |
void |
ActorJob.onJobAddedToTask(ActorTask task) |
default void |
TaskScheduler.onTaskReleased(ActorTask task) |
void |
ActorThreadGroup.submit(ActorTask actorTask) |
void |
WorkStealingGroup.submit(ActorTask task,
int threadId)
Submit the task into the provided thread's queue
|
void |
MultiLevelWorkstealingGroup.submit(ActorTask task,
int level,
int threadId) |
ActorFuture<Void> |
ActorExecutor.submitCpuBound(ActorTask task,
boolean collectTaskMetrics)
Initially submit a non-blocking actor to be managed by this schedueler.
|
ActorFuture<Void> |
ActorExecutor.submitIoBoundTask(ActorTask task,
boolean collectTaskMetrics) |
| Constructor and Description |
|---|
PriorityScheduler(java.util.function.IntFunction<ActorTask> getTaskFn,
double[] quotas) |
| Modifier and Type | Method and Description |
|---|---|
void |
CompletableActorFuture.block(ActorTask onCompletion) |
void |
ActorFuture.block(ActorTask onCompletion)
To be used by scheduler only
|
Copyright © 2017–2019 camunda services GmbH. All rights reserved.