io.zeebe.util.sched

Class ActorTimerQueue

java.lang.Object

org.agrona.DeadlineTimerWheel

io.zeebe.util.sched.ActorTimerQueue

public class ActorTimerQueue
extends org.agrona.DeadlineTimerWheel

Nested Class Summary

Nested classes/interfaces inherited from class org.agrona.DeadlineTimerWheel

org.agrona.DeadlineTimerWheel.TimerConsumer, org.agrona.DeadlineTimerWheel.TimerHandler

Field Summary

Fields inherited from class org.agrona.DeadlineTimerWheel

NULL_TIMER

Constructor Summary

Constructors

Constructor and Description
ActorTimerQueue(ActorClock clock)
ActorTimerQueue(ActorClock clock, int ticksPerWheel)

Method Summary

Modifier and Type	Method and Description
void	processExpiredTimers(ActorClock clock)
void	remove(TimerSubscription timer)
void	schedule(TimerSubscription timer, ActorClock now)

Methods inherited from class org.agrona.DeadlineTimerWheel

cancelTimer, currentTickTime, deadline, forEach, poll, resetStartTime, scheduleTimer, tickResolution, timerCount, timeUnit

Methods inherited from class java.lang.Object

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

Constructor Detail

ActorTimerQueue

public ActorTimerQueue(ActorClock clock)

ActorTimerQueue

public ActorTimerQueue(ActorClock clock,
                       int ticksPerWheel)

Method Detail

processExpiredTimers

public void processExpiredTimers(ActorClock clock)

schedule

public void schedule(TimerSubscription timer,
                     ActorClock now)

remove

public void remove(TimerSubscription timer)