public class HashedTimingWheel extends Object implements TimeScheduler, Runnable
TimeScheduler
. Uses a hashed timing wheel [1].
[1] http://www.cse.wustl.edu/~cdgill/courses/cs6874/TimingWheels.pptModifier and Type | Class and Description |
---|---|
protected static class |
HashedTimingWheel.MyTask
Simple task wrapper, always executed by at most 1 thread.
|
TimeScheduler.Task
Modifier and Type | Field and Description |
---|---|
protected static Log |
log |
protected long |
ROTATION_TIME |
protected boolean |
running |
protected ThreadDecorator |
threadDecorator |
protected long |
tick_time |
protected ThreadFactory |
timer_thread_factory |
protected List<HashedTimingWheel.MyTask>[] |
wheel |
protected int |
wheel_position |
protected int |
wheel_size |
Constructor and Description |
---|
HashedTimingWheel()
Create a scheduler that executes tasks in dynamically adjustable intervals
|
HashedTimingWheel(int corePoolSize) |
HashedTimingWheel(ThreadFactory factory,
int min_threads,
int max_threads,
long keep_alive_time,
int max_queue_size,
int wheel_size,
long tick_time) |
Modifier and Type | Method and Description |
---|---|
protected void |
_run() |
String |
dumpTimerTasks()
Returns a list of tasks currently waiting for execution.
|
void |
execute(Runnable task)
Executes command with zero required delay.
|
int |
getCurrentThreads()
Returns the current threads in the pool, or -1 if not applicable
|
long |
getKeepAliveTime()
Returns the keep alive time (in ms) of the thread pool, or -1 if not applicable
|
int |
getMaxThreads()
Returns the configured max threads, or -1 if not applicable
|
int |
getMinThreads()
Returns the configured core threads, or -1 if not applicable
|
int |
getQueueSize() |
ThreadDecorator |
getThreadDecorator()
Gets the ThreadDecorator associated with this manager.
|
protected void |
init() |
boolean |
isShutdown()
Returns true if stop() has been called, false otherwise
|
void |
run() |
Future<?> |
schedule(Runnable work,
long delay,
TimeUnit unit)
Creates and executes a one-shot action that becomes enabled after the given delay.
|
Future<?> |
scheduleAtFixedRate(Runnable task,
long initial_delay,
long delay,
TimeUnit unit)
Creates and executes a periodic action that becomes enabled first
after the given initial delay, and subsequently with the given
period; that is executions will commence after
initialDelay then initialDelay+period, then
initialDelay + 2 * period, and so on.
|
Future<?> |
scheduleWithDynamicInterval(TimeScheduler.Task task)
Schedule a task for execution at varying intervals.
|
Future<?> |
scheduleWithFixedDelay(Runnable task,
long initial_delay,
long delay,
TimeUnit unit)
Creates and executes a periodic action that becomes enabled first after the given initial delay, and
subsequently with the given delay between the termination of one execution and the commencement of the next.
|
void |
setKeepAliveTime(long time)
Sets the keep alive time (in ms) of the thread pool.
|
void |
setMaxThreads(int size)
Sets the max pool size.
|
void |
setMinThreads(int size)
Sets the core pool size.
|
void |
setThreadDecorator(ThreadDecorator threadDecorator)
Sets the ThreadDecorator associated this manager should use.
|
void |
setThreadFactory(ThreadFactory factory) |
int |
size()
Returns the number of tasks currently in the timer
|
protected void |
startRunner() |
void |
stop()
Stops the timer, cancelling all tasks
|
protected void |
stopRunner() |
String |
toString() |
protected volatile boolean running
protected static final Log log
protected ThreadDecorator threadDecorator
protected ThreadFactory timer_thread_factory
protected int wheel_size
protected long tick_time
protected final long ROTATION_TIME
protected final List<HashedTimingWheel.MyTask>[] wheel
protected int wheel_position
public HashedTimingWheel()
public HashedTimingWheel(ThreadFactory factory, int min_threads, int max_threads, long keep_alive_time, int max_queue_size, int wheel_size, long tick_time)
public HashedTimingWheel(int corePoolSize)
public ThreadDecorator getThreadDecorator()
ThreadManager
getThreadDecorator
in interface ThreadManager
null
if there is none.public void setThreadDecorator(ThreadDecorator threadDecorator)
ThreadManager
setThreadDecorator
in interface ThreadManager
threadDecorator
- the ThreadDecorator, or null
.public void setThreadFactory(ThreadFactory factory)
setThreadFactory
in interface TimeScheduler
public int getMinThreads()
TimeScheduler
getMinThreads
in interface TimeScheduler
public void setMinThreads(int size)
TimeScheduler
setMinThreads
in interface TimeScheduler
public int getMaxThreads()
TimeScheduler
getMaxThreads
in interface TimeScheduler
public void setMaxThreads(int size)
TimeScheduler
setMaxThreads
in interface TimeScheduler
public long getKeepAliveTime()
TimeScheduler
getKeepAliveTime
in interface TimeScheduler
public void setKeepAliveTime(long time)
TimeScheduler
setKeepAliveTime
in interface TimeScheduler
public int getCurrentThreads()
TimeScheduler
getCurrentThreads
in interface TimeScheduler
public int getQueueSize()
public String dumpTimerTasks()
TimeScheduler
dumpTimerTasks
in interface TimeScheduler
public void execute(Runnable task)
TimeScheduler
execute
in interface TimeScheduler
task
- the task to executepublic Future<?> schedule(Runnable work, long delay, TimeUnit unit)
TimeScheduler
schedule
in interface TimeScheduler
work
- the task to executedelay
- the time from now to delay executionunit
- the time unit of the delay parameterpublic Future<?> scheduleWithFixedDelay(Runnable task, long initial_delay, long delay, TimeUnit unit)
TimeScheduler
scheduleWithFixedDelay
in interface TimeScheduler
task
- the task to executeinitial_delay
- the time to delay first executiondelay
- the delay between the termination of one execution and the commencement of the nextunit
- the time unit of the initialDelay and delay parameterspublic Future<?> scheduleAtFixedRate(Runnable task, long initial_delay, long delay, TimeUnit unit)
TimeScheduler
scheduleAtFixedRate
in interface TimeScheduler
task
- the task to executeinitial_delay
- the time to delay first executiondelay
- the period between successive executionsunit
- the time unit of the initialDelay and period parameterspublic Future<?> scheduleWithDynamicInterval(TimeScheduler.Task task)
org.jgroups.util.HashedTimingWheel.Task#nextInterval()
milliseconds. The task is neve done until nextInterval()
return a value <= 0 or the task is cancelled.scheduleWithDynamicInterval
in interface TimeScheduler
task
- the task to execute
Task is rescheduled relative to the last time it actually started execution
false:public int size()
size
in interface TimeScheduler
public void stop()
stop
in interface TimeScheduler
InterruptedException
- if interrupted while waiting for thread to returnpublic boolean isShutdown()
TimeScheduler
isShutdown
in interface TimeScheduler
protected void _run()
protected void init()
protected void startRunner()
protected void stopRunner()
Copyright © 2012 JBoss by Red Hat. All Rights Reserved.