com.alipay.sofa.jraft.util.timer

Class HashedWheelTimer

java.lang.Object

com.alipay.sofa.jraft.util.timer.HashedWheelTimer

All Implemented Interfaces:

Timer

public class HashedWheelTimer
extends Object
implements Timer

Implementation Details

HashedWheelTimer is based on George Varghese and Tony Lauck's paper, 'Hashed and Hierarchical Timing Wheels: data structures to efficiently implement a timer facility'. More comprehensive slides are located here.

Forked from Netty.

Field Summary

Fields

Modifier and Type	Field and Description
static int	WORKER_STATE_INIT
static int	WORKER_STATE_SHUTDOWN
static int	WORKER_STATE_STARTED

Constructor Summary

Constructors

Constructor and Description
HashedWheelTimer() Creates a new timer with the default thread factory (Executors.defaultThreadFactory()), default tick duration, and default number of ticks per wheel.
HashedWheelTimer(long tickDuration, TimeUnit unit) Creates a new timer with the default thread factory (Executors.defaultThreadFactory()) and default number of ticks per wheel.
HashedWheelTimer(long tickDuration, TimeUnit unit, int ticksPerWheel) Creates a new timer with the default thread factory (Executors.defaultThreadFactory()).
HashedWheelTimer(ThreadFactory threadFactory) Creates a new timer with the default tick duration and default number of ticks per wheel.
HashedWheelTimer(ThreadFactory threadFactory, long tickDuration, TimeUnit unit) Creates a new timer with the default number of ticks per wheel.
HashedWheelTimer(ThreadFactory threadFactory, long tickDuration, TimeUnit unit, int ticksPerWheel) Creates a new timer.
HashedWheelTimer(ThreadFactory threadFactory, long tickDuration, TimeUnit unit, int ticksPerWheel, long maxPendingTimeouts) Creates a new timer.

Method Summary

Modifier and Type	Method and Description
protected void	finalize()
Timeout	newTimeout(TimerTask task, long delay, TimeUnit unit) Schedules the specified TimerTask for one-time execution after the specified delay.
long	pendingTimeouts() Returns the number of pending timeouts of this Timer.
void	start() Starts the background thread explicitly.
Set<Timeout>	stop() Releases all resources acquired by this Timer and cancels all tasks which were scheduled but not executed yet.

Methods inherited from class java.lang.Object

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

Field Detail

WORKER_STATE_INIT

public static final int WORKER_STATE_INIT

See Also:

Constant Field Values

WORKER_STATE_STARTED

public static final int WORKER_STATE_STARTED

See Also:

Constant Field Values

WORKER_STATE_SHUTDOWN

public static final int WORKER_STATE_SHUTDOWN

See Also:

Constant Field Values

Constructor Detail

HashedWheelTimer

public HashedWheelTimer()

Creates a new timer with the default thread factory (Executors.defaultThreadFactory()), default tick duration, and default number of ticks per wheel.

HashedWheelTimer

public HashedWheelTimer(long tickDuration,
                        TimeUnit unit)

Creates a new timer with the default thread factory (Executors.defaultThreadFactory()) and default number of ticks per wheel.

Parameters:

tickDuration - the duration between tick

unit - the time unit of the tickDuration

Throws:

NullPointerException - if unit is null

IllegalArgumentException - if tickDuration is <= 0

HashedWheelTimer

public HashedWheelTimer(long tickDuration,
                        TimeUnit unit,
                        int ticksPerWheel)

Creates a new timer with the default thread factory (Executors.defaultThreadFactory()).

Parameters:

tickDuration - the duration between tick

unit - the time unit of the tickDuration

ticksPerWheel - the size of the wheel

Throws:

NullPointerException - if unit is null

IllegalArgumentException - if either of tickDuration and ticksPerWheel is <= 0

HashedWheelTimer

public HashedWheelTimer(ThreadFactory threadFactory)

Creates a new timer with the default tick duration and default number of ticks per wheel.

Parameters:

threadFactory - a ThreadFactory that creates a background Thread which is dedicated to TimerTask execution.

Throws:

NullPointerException - if threadFactory is null

HashedWheelTimer

public HashedWheelTimer(ThreadFactory threadFactory,
                        long tickDuration,
                        TimeUnit unit)

Creates a new timer with the default number of ticks per wheel.

Parameters:

threadFactory - a ThreadFactory that creates a background Thread which is dedicated to TimerTask execution.

tickDuration - the duration between tick

unit - the time unit of the tickDuration

Throws:

NullPointerException - if either of threadFactory and unit is null

IllegalArgumentException - if tickDuration is <= 0

HashedWheelTimer

public HashedWheelTimer(ThreadFactory threadFactory,
                        long tickDuration,
                        TimeUnit unit,
                        int ticksPerWheel)

Creates a new timer.

Parameters:

threadFactory - a ThreadFactory that creates a background Thread which is dedicated to TimerTask execution.

tickDuration - the duration between tick

unit - the time unit of the tickDuration

ticksPerWheel - the size of the wheel

Throws:

NullPointerException - if either of threadFactory and unit is null

IllegalArgumentException - if either of tickDuration and ticksPerWheel is <= 0

HashedWheelTimer

public HashedWheelTimer(ThreadFactory threadFactory,
                        long tickDuration,
                        TimeUnit unit,
                        int ticksPerWheel,
                        long maxPendingTimeouts)

Creates a new timer.

Parameters:

threadFactory - a ThreadFactory that creates a background Thread which is dedicated to TimerTask execution.

tickDuration - the duration between tick

unit - the time unit of the tickDuration

ticksPerWheel - the size of the wheel

maxPendingTimeouts - The maximum number of pending timeouts after which call to newTimeout will result in RejectedExecutionException being thrown. No maximum pending timeouts limit is assumed if this value is 0 or negative.

Throws:

NullPointerException - if either of threadFactory and unit is null

IllegalArgumentException - if either of tickDuration and ticksPerWheel is <= 0

Method Detail

finalize

protected void finalize()
                 throws Throwable

Overrides:

finalize in class Object

Throws:

Throwable

start

public void start()

Starts the background thread explicitly. The background thread will start automatically on demand even if you did not call this method.

Throws:

IllegalStateException - if this timer has been stopped already

stop

public Set<Timeout> stop()

Description copied from interface: Timer

Releases all resources acquired by this Timer and cancels all tasks which were scheduled but not executed yet.

Specified by:

stop in interface Timer

Returns:

the handles associated with the tasks which were canceled by this method

newTimeout

public Timeout newTimeout(TimerTask task,
                          long delay,
                          TimeUnit unit)

Description copied from interface: Timer

Schedules the specified TimerTask for one-time execution after the specified delay.

Specified by:

newTimeout in interface Timer

Returns:

a handle which is associated with the specified task

pendingTimeouts

public long pendingTimeouts()

Returns the number of pending timeouts of this Timer.