com.fr.third.jgroups.util

接口 TimeScheduler

所有已知实现类:

DefaultTimeScheduler, HashedTimingWheel, MockTimeScheduler, TimeScheduler2, TimeScheduler3

public interface TimeScheduler

Timer-like interface which allows for execution of tasks. Taks can be executed

• one time only
• at recurring time intervals. Intervals can be fixed-delay or fixed-rate, see ScheduledExecutorService for details
• dynamic; at the end of the task execution, a task is asked what the next execution time should be. To do this, method TimeScheduler.Task.nextInterval() needs to be implemented.

作者:

Bela Ban

嵌套类概要

嵌套类

限定符和类型	接口和说明
static interface	TimeScheduler.Task The interface that dynamic tasks (scheduleWithDynamicInterval(TimeScheduler.Task)) must implement

方法概要

方法

限定符和类型	方法和说明
java.lang.String	dumpTimerTasks() Returns a list of tasks currently waiting for execution.
void	execute(java.lang.Runnable command) 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
boolean	isShutdown() Returns true if stop() has been called, false otherwise
java.util.concurrent.Future<?>	schedule(java.lang.Runnable command, long delay, java.util.concurrent.TimeUnit unit) Creates and executes a one-shot action that becomes enabled after the given delay.
java.util.concurrent.Future<?>	scheduleAtFixedRate(java.lang.Runnable command, long initialDelay, long period, java.util.concurrent.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.
java.util.concurrent.Future<?>	scheduleWithDynamicInterval(TimeScheduler.Task task) Schedule a task for execution at varying intervals.
java.util.concurrent.Future<?>	scheduleWithFixedDelay(java.lang.Runnable command, long initialDelay, long delay, java.util.concurrent.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	setThreadFactory(ThreadFactory factory)
int	size() Returns the number of tasks currently in the queue.
void	stop() Stops the scheduler if running, cancelling all pending tasks

方法详细资料

execute

void execute(java.lang.Runnable command)

Executes command with zero required delay. This has effect equivalent to schedule(command, 0, anyUnit).

参数:

command - the task to execute

抛出:

java.util.concurrent.RejectedExecutionException - at discretion of RejectedExecutionHandler, if task cannot be accepted for execution because the executor has been shut down.

java.lang.NullPointerException - if command is null

schedule

java.util.concurrent.Future<?> schedule(java.lang.Runnable command,
                                      long delay,
                                      java.util.concurrent.TimeUnit unit)

Creates and executes a one-shot action that becomes enabled after the given delay.

参数:

command - the task to execute

delay - the time from now to delay execution

unit - the time unit of the delay parameter

返回:

a ScheduledFuture representing pending completion of the task and whose get() method will return null upon completion

抛出:

java.util.concurrent.RejectedExecutionException - if the task cannot be scheduled for execution

java.lang.NullPointerException - if command is null

scheduleWithFixedDelay

java.util.concurrent.Future<?> scheduleWithFixedDelay(java.lang.Runnable command,
                                                    long initialDelay,
                                                    long delay,
                                                    java.util.concurrent.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. If any execution of the task encounters an exception, subsequent executions are suppressed. Otherwise, the task will only terminate via cancellation or termination of the executor.

参数:

command - the task to execute

initialDelay - the time to delay first execution

delay - the delay between the termination of one execution and the commencement of the next

unit - the time unit of the initialDelay and delay parameters

返回:

a ScheduledFuture representing pending completion of the task, and whose get() method will throw an exception upon cancellation

抛出:

java.util.concurrent.RejectedExecutionException - if the task cannot be scheduled for execution

java.lang.NullPointerException - if command is null

java.lang.IllegalArgumentException - if delay less than or equal to zero

scheduleAtFixedRate

java.util.concurrent.Future<?> scheduleAtFixedRate(java.lang.Runnable command,
                                                 long initialDelay,
                                                 long period,
                                                 java.util.concurrent.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. If any execution of the task encounters an exception, subsequent executions are suppressed. Otherwise, the task will only terminate via cancellation or termination of the executor. If any execution of this task takes longer than its period, then subsequent executions may start late, but will not concurrently execute.

参数:

command - the task to execute

initialDelay - the time to delay first execution

period - the period between successive executions

unit - the time unit of the initialDelay and period parameters

返回:

a ScheduledFuture representing pending completion of the task, and whose get() method will throw an exception upon cancellation

抛出:

java.util.concurrent.RejectedExecutionException - if the task cannot be scheduled for execution

java.lang.NullPointerException - if command is null

java.lang.IllegalArgumentException - if period less than or equal to zero

scheduleWithDynamicInterval

java.util.concurrent.Future<?> scheduleWithDynamicInterval(TimeScheduler.Task task)

Schedule a task for execution at varying intervals. After execution, the task will get rescheduled after TimeScheduler.Task.nextInterval() milliseconds. The task is never done until nextInterval() return a value <= 0 or the task is cancelled.

参数:

task - the task to execute

setThreadFactory

void setThreadFactory(ThreadFactory factory)

dumpTimerTasks

java.lang.String dumpTimerTasks()

Returns a list of tasks currently waiting for execution. If there are a lot of tasks, the returned string should probably only return the number of tasks rather than a full dump.

返回:

getMinThreads

int getMinThreads()

Returns the configured core threads, or -1 if not applicable

返回:

setMinThreads

void setMinThreads(int size)

Sets the core pool size. Can be ignored if not applicable

getMaxThreads

int getMaxThreads()

Returns the configured max threads, or -1 if not applicable

返回:

setMaxThreads

void setMaxThreads(int size)

Sets the max pool size. Can be ignored if not applicable

getKeepAliveTime

long getKeepAliveTime()

Returns the keep alive time (in ms) of the thread pool, or -1 if not applicable

setKeepAliveTime

void setKeepAliveTime(long time)

Sets the keep alive time (in ms) of the thread pool. Can be ignored if not applicable

getCurrentThreads

int getCurrentThreads()

Returns the current threads in the pool, or -1 if not applicable

返回:

size

int size()

Returns the number of tasks currently in the queue.

返回:

The number of tasks currently in the queue.

stop

void stop()

Stops the scheduler if running, cancelling all pending tasks

isShutdown

boolean isShutdown()

Returns true if stop() has been called, false otherwise