org.fusesource.hawtdispatch.internal.util

Class TimerHeap<V>

java.lang.Object

org.fusesource.hawtdispatch.internal.util.TimerHeap<V>

public abstract class TimerHeap<V>
extends java.lang.Object

Field Summary

Fields

Modifier and Type	Field and Description
private java.util.concurrent.TimeUnit	resolution
private int	size
private java.util.TreeMap<java.lang.Long,java.util.LinkedList<V>>	timers

Constructor Summary

Constructors

Constructor and Description
TimerHeap()

Method Summary

Modifier and Type	Method and Description
void	addAbsolute(V timed, long time, java.util.concurrent.TimeUnit timeUnit)
private void	addInternal(V timed, long eTime)
void	addRelative(V timed, long delay, java.util.concurrent.TimeUnit timeUnit)
java.util.List<V>	clear()
abstract void	execute(V ready) Subclass must override this to execute ready timers
void	executeReadyTimers() Executes ready timers.
int	size()
long	timeToNext(java.util.concurrent.TimeUnit unit) Returns the time of the next scheduled event.

Methods inherited from class java.lang.Object

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

Field Detail

timers

private final java.util.TreeMap<java.lang.Long,java.util.LinkedList<V>> timers

resolution

private final java.util.concurrent.TimeUnit resolution

size

private int size

Constructor Detail

TimerHeap

public TimerHeap()

Method Detail

addAbsolute

public final void addAbsolute(V timed,
                              long time,
                              java.util.concurrent.TimeUnit timeUnit)

addRelative

public final void addRelative(V timed,
                              long delay,
                              java.util.concurrent.TimeUnit timeUnit)

addInternal

private void addInternal(V timed,
                         long eTime)

size

public int size()

timeToNext

public final long timeToNext(java.util.concurrent.TimeUnit unit)

Returns the time of the next scheduled event.

Returns:

-1 if there are no events, otherwise the time that the next timer should fire.

executeReadyTimers

public final void executeReadyTimers()

Executes ready timers.

clear

public java.util.List<V> clear()

execute

public abstract void execute(V ready)

Subclass must override this to execute ready timers

Parameters:

ready - The ready operation.