| Package | Description |
|---|---|
| io.zeebe.util.sched | |
| io.zeebe.util.sched.channel |
| Modifier and Type | Method and Description |
|---|---|
ActorJob |
ClosedQueue.element() |
ActorJob |
ActorThread.getCurrentJob() |
ActorJob |
ClosedQueue.getFirst() |
ActorJob |
BlockingPollSubscription.getJob() |
ActorJob |
ActorConditionImpl.getJob() |
ActorJob |
ActorFutureSubscription.getJob() |
ActorJob |
ActorSubscription.getJob()
called by the
ActorThread after ActorSubscription.poll() returned true to get the job to be run |
ActorJob |
TimerSubscription.getJob() |
ActorJob |
ClosedQueue.getLast() |
ActorJob |
ActorThread.newJob() |
ActorJob |
ClosedQueue.peek() |
ActorJob |
ClosedQueue.peekFirst() |
ActorJob |
ClosedQueue.peekLast() |
ActorJob |
ClosedQueue.poll() |
ActorJob |
ClosedQueue.pollFirst() |
ActorJob |
ClosedQueue.pollLast() |
ActorJob |
ClosedQueue.pop() |
ActorJob |
ClosedQueue.remove() |
ActorJob |
ClosedQueue.removeFirst() |
ActorJob |
ClosedQueue.removeLast() |
| Modifier and Type | Method and Description |
|---|---|
Iterator<ActorJob> |
ClosedQueue.descendingIterator() |
Iterator<ActorJob> |
ClosedQueue.iterator() |
| Modifier and Type | Method and Description |
|---|---|
boolean |
ClosedQueue.add(ActorJob e) |
void |
ClosedQueue.addFirst(ActorJob actorJob) |
void |
ClosedQueue.addLast(ActorJob actorJob) |
void |
ActorTask.insertJob(ActorJob job) |
boolean |
ActorControl.isCalledFromWithinActor(ActorJob job) |
boolean |
ClosedQueue.offer(ActorJob e) |
boolean |
ClosedQueue.offerFirst(ActorJob actorJob) |
boolean |
ClosedQueue.offerLast(ActorJob actorJob) |
void |
ClosedQueue.push(ActorJob actorJob) |
void |
ActorTask.submit(ActorJob job)
Used to externally submit a job.
|
| Modifier and Type | Method and Description |
|---|---|
boolean |
ClosedQueue.addAll(Collection<? extends ActorJob> c) |
| Constructor and Description |
|---|
ActorConditionImpl(String conditionName,
ActorJob job) |
ActorFutureSubscription(ActorFuture<?> future,
ActorJob callbackJob,
int phaseMask) |
BlockingPollSubscription(ActorJob subscriptionJob,
Runnable blockingAction,
ActorExecutor actorTaskExecutor,
boolean isRecurring) |
TimerSubscription(ActorJob job,
long deadline,
TimeUnit timeUnit,
boolean isRecurring) |
| Modifier and Type | Method and Description |
|---|---|
ActorJob |
ChannelConsumerCondition.getJob() |
| Constructor and Description |
|---|
ChannelConsumerCondition(ActorJob job,
ConsumableChannel channel) |
Copyright © 2017–2019 camunda services GmbH. All rights reserved.