io.zeebe.util.sched.testing

Class ControlledActorThread

java.lang.Object

java.lang.Thread

io.zeebe.util.sched.ActorThread

io.zeebe.util.sched.testing.ControlledActorThread

All Implemented Interfaces:

Runnable, java.util.function.Consumer<Runnable>

public class ControlledActorThread
extends ActorThread

Nested Class Summary

Nested classes/interfaces inherited from class io.zeebe.util.sched.ActorThread

ActorThread.ActorTaskRunnerIdleStrategy, ActorThread.ActorThreadState

Nested classes/interfaces inherited from class java.lang.Thread

Thread.State, Thread.UncaughtExceptionHandler

Field Summary

Fields inherited from class io.zeebe.util.sched.ActorThread

idleStrategy, submittedCallbacks, timerJobQueue

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor and Description
ControlledActorThread(String name, int id, ActorThreadGroup threadGroup, TaskScheduler taskScheduler, ActorClock clock, ActorThreadMetrics metrics, ActorTimerQueue timerQueue)

Method Summary

Modifier and Type	Method and Description
void	workUntilDone()

Methods inherited from class io.zeebe.util.sched.ActorThread

accept, close, current, getActorThreadGroup, getClock, getCurrentJob, getCurrentTask, getMetrics, getRunnerId, hintWorkAvailable, newJob, removeTimer, run, scheduleTimer, start

Methods inherited from class java.lang.Thread

activeCount, checkAccess, clone, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, stop, stop, suspend, toString, yield

Methods inherited from class java.lang.Object

equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface java.util.function.Consumer

andThen

Constructor Detail

ControlledActorThread

public ControlledActorThread(String name,
                             int id,
                             ActorThreadGroup threadGroup,
                             TaskScheduler taskScheduler,
                             ActorClock clock,
                             ActorThreadMetrics metrics,
                             ActorTimerQueue timerQueue)

Method Detail

workUntilDone

public void workUntilDone()