Package kilim.timerservice

Class TimerService

java.lang.Object

kilim.timerservice.TimerService

public class TimerService
extends java.lang.Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) static class	TimerService.DaemonFactory
private class	TimerService.Empty
static interface	TimerService.WatchdogContext
static class	TimerService.WatchdogTask
private class	TimerService.Watcher

Field Summary

Fields

Modifier and Type	Field	Description
private TimerService.WatchdogTask	argos	a recent, but not necessarily the most recent, watchdog
private static int	c1
private static int	c2
private static int	c3
private static boolean	debugStats
TimerService.WatchdogContext	defaultExec
static java.util.concurrent.ThreadFactory	factory
private java.util.concurrent.locks.Lock	lock
private TimerPriorityHeap	timerHeap
private java.util.concurrent.ScheduledExecutorService	timerProxy
private MPSCQueue<Timer>	timerQueue

Constructor Summary

Constructors

Constructor	Description
TimerService(TimerService.WatchdogContext doghouse)

Method Summary

Modifier and Type	Method	Description
private long	doTrigger(long currentTime)
private boolean	empty()
boolean	isEmptyLazy(TimerService.WatchdogContext executor)	return true if empty at a particular moment during the call allowing false negatives if operations are ongoing
void	shutdown()
void	submit(Timer t)
void	trigger(TimerService.WatchdogContext doghouse)

Methods inherited from class java.lang.Object

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

Field Detail

timerQueue

private final MPSCQueue<Timer> timerQueue

timerHeap

private final TimerPriorityHeap timerHeap

timerProxy

private java.util.concurrent.ScheduledExecutorService timerProxy

lock

private final java.util.concurrent.locks.Lock lock

debugStats

private static boolean debugStats

argos

private volatile TimerService.WatchdogTask argos

a recent, but not necessarily the most recent, watchdog

c1

private static volatile int c1

c2

private static volatile int c2

c3

private static volatile int c3

factory

public static java.util.concurrent.ThreadFactory factory

defaultExec

public TimerService.WatchdogContext defaultExec

Constructor Detail

TimerService

public TimerService(TimerService.WatchdogContext doghouse)

Method Detail

shutdown

public void shutdown()

submit

public void submit(Timer t)

empty

private boolean empty()

isEmptyLazy

public boolean isEmptyLazy(TimerService.WatchdogContext executor)

return true if empty at a particular moment during the call allowing false negatives if operations are ongoing

trigger

public void trigger(TimerService.WatchdogContext doghouse)

doTrigger

private long doTrigger(long currentTime)