io.zeebe.util.sched

Class ActorThread

java.lang.Object

java.lang.Thread

io.zeebe.util.sched.ActorThread

All Implemented Interfaces:

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

Direct Known Subclasses:

ControlledActorThread

public class ActorThread
extends Thread
implements java.util.function.Consumer<Runnable>

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected class	ActorThread.ActorTaskRunnerIdleStrategy
static class	ActorThread.ActorThreadState

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

Thread.State, Thread.UncaughtExceptionHandler

Field Summary

Fields

Modifier and Type	Field and Description
protected ActorThread.ActorTaskRunnerIdleStrategy	idleStrategy
org.agrona.concurrent.ManyToManyConcurrentArrayQueue<Runnable>	submittedCallbacks
protected ActorTimerQueue	timerJobQueue

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
void	accept(Runnable t)
CompletableFuture<Void>	close()
static ActorThread	current() Returns the current ActorThread or null if the current thread is not an ActorThread.
ActorThreadGroup	getActorThreadGroup()
ActorClock	getClock()
ActorJob	getCurrentJob()
ActorTask	getCurrentTask()
ActorThreadMetrics	getMetrics()
int	getRunnerId()
void	hintWorkAvailable()
ActorJob	newJob()
void	removeTimer(TimerSubscription timer) Must be called from this thread, remove a scheduled job.
void	run()
void	scheduleTimer(TimerSubscription timer) Must be called from this thread, schedules a job to be run later.
void	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

Field Detail

submittedCallbacks

public final org.agrona.concurrent.ManyToManyConcurrentArrayQueue<Runnable> submittedCallbacks

timerJobQueue

protected final ActorTimerQueue timerJobQueue

idleStrategy

protected ActorThread.ActorTaskRunnerIdleStrategy idleStrategy

Constructor Detail

ActorThread

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

Method Detail

run

public void run()

Specified by:

run in interface Runnable

Overrides:

run in class Thread

hintWorkAvailable

public void hintWorkAvailable()

scheduleTimer

public void scheduleTimer(TimerSubscription timer)

Must be called from this thread, schedules a job to be run later.

removeTimer

public void removeTimer(TimerSubscription timer)

Must be called from this thread, remove a scheduled job.

current

public static ActorThread current()

Returns the current ActorThread or null if the current thread is not an ActorThread.

Returns:

the current ActorThread or null

newJob

public ActorJob newJob()

getRunnerId

public int getRunnerId()

getMetrics

public ActorThreadMetrics getMetrics()

start

public void start()

Overrides:

start in class Thread

close

public CompletableFuture<Void> close()

getCurrentJob

public ActorJob getCurrentJob()

getCurrentTask

public ActorTask getCurrentTask()

getClock

public ActorClock getClock()

getActorThreadGroup

public ActorThreadGroup getActorThreadGroup()

accept

public void accept(Runnable t)

Specified by:

accept in interface java.util.function.Consumer<Runnable>