io.zeebe.util.sched

Class ActorTask

java.lang.Object

io.zeebe.util.sched.ActorTask

public class ActorTask
extends Object

A task executed by the scheduler. For each actor (instance), exactly one task is created. Each invocation of one of the actor's methods is an ActorJob.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	ActorTask.ActorLifecyclePhase An actor task's lifecycle phases
static class	ActorTask.TaskSchedulingState Describes an actor's scheduling state

Field Summary

Fields

Modifier and Type	Field and Description
CompletableActorFuture<Void>	closeFuture

Constructor Summary

Constructors

Constructor and Description
ActorTask(Actor actor)

Method Summary

Modifier and Type	Method and Description
void	addSubscription(ActorSubscription subscription)
boolean	claim(long stateCount)
boolean	execute(ActorThread runner)
Actor	getActor()
ActorExecutor	getActorExecutor()
ActorThreadGroup	getActorThreadGroup()
ActorTask.ActorLifecyclePhase	getLifecyclePhase()
TaskMetrics	getMetrics()
String	getName()
int	getPriority()
CompletableActorFuture<Void>	getStartingFuture()
ActorTask.TaskSchedulingState	getState()
long	getStateCount()
void	insertJob(ActorJob job)
boolean	isClosing()
boolean	isCollectTaskMetrics()
boolean	isHasWarnedJumbo()
void	onFailure(Exception failure)
void	onSubscriptionCancelled(ActorSubscription subscription)
ActorFuture<Void>	onTaskScheduled(ActorExecutor actorExecutor, ActorThreadGroup actorThreadGroup, TaskMetrics taskMetrics) called when the task is initially scheduled.
void	reportExecutionTime(long t)
void	requestClose()
void	resubmit()
void	setPriority(int priority)
void	setUpdatedSchedulingHints(int hints)
void	submit(ActorJob job) Used to externally submit a job.
String	toString()
boolean	tryWakeup()
void	warnMaxTaskExecutionTimeExceeded(long taskExecutionTime)
void	yield()

Methods inherited from class java.lang.Object

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

Field Detail

closeFuture

public final CompletableActorFuture<Void> closeFuture

Constructor Detail

ActorTask

public ActorTask(Actor actor)

Method Detail

onTaskScheduled

public ActorFuture<Void> onTaskScheduled(ActorExecutor actorExecutor,
                                         ActorThreadGroup actorThreadGroup,
                                         TaskMetrics taskMetrics)

called when the task is initially scheduled.

submit

public void submit(ActorJob job)

Used to externally submit a job.

execute

public boolean execute(ActorThread runner)

requestClose

public void requestClose()

onFailure

public void onFailure(Exception failure)

claim

public boolean claim(long stateCount)

tryWakeup

public boolean tryWakeup()

getState

public ActorTask.TaskSchedulingState getState()

toString

public String toString()

Overrides:

toString in class Object

yield

public void yield()

getMetrics

public TaskMetrics getMetrics()

isCollectTaskMetrics

public boolean isCollectTaskMetrics()

reportExecutionTime

public void reportExecutionTime(long t)

warnMaxTaskExecutionTimeExceeded

public void warnMaxTaskExecutionTimeExceeded(long taskExecutionTime)

isHasWarnedJumbo

public boolean isHasWarnedJumbo()

getStateCount

public long getStateCount()

getActorThreadGroup

public ActorThreadGroup getActorThreadGroup()

getName

public String getName()

getActor

public Actor getActor()

isClosing

public boolean isClosing()

getPriority

public int getPriority()

setPriority

public void setPriority(int priority)

getActorExecutor

public ActorExecutor getActorExecutor()

getLifecyclePhase

public ActorTask.ActorLifecyclePhase getLifecyclePhase()

getStartingFuture

public CompletableActorFuture<Void> getStartingFuture()

addSubscription

public void addSubscription(ActorSubscription subscription)

onSubscriptionCancelled

public void onSubscriptionCancelled(ActorSubscription subscription)

setUpdatedSchedulingHints

public void setUpdatedSchedulingHints(int hints)

resubmit

public void resubmit()

insertJob

public void insertJob(ActorJob job)