public class MockTimeScheduler extends java.lang.Object implements TimeScheduler
TimeScheduler
, used by unit testsTimeScheduler.Task
Constructor and Description |
---|
MockTimeScheduler() |
Modifier and Type | Method and Description |
---|---|
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
|
public void execute(java.lang.Runnable command)
TimeScheduler
execute
in interface TimeScheduler
command
- the task to executepublic java.util.concurrent.Future<?> schedule(java.lang.Runnable command, long delay, java.util.concurrent.TimeUnit unit)
TimeScheduler
schedule
in interface TimeScheduler
command
- the task to executedelay
- the time from now to delay executionunit
- the time unit of the delay parameterpublic java.util.concurrent.Future<?> scheduleWithFixedDelay(java.lang.Runnable command, long initialDelay, long delay, java.util.concurrent.TimeUnit unit)
TimeScheduler
scheduleWithFixedDelay
in interface TimeScheduler
command
- the task to executeinitialDelay
- 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 java.util.concurrent.Future<?> scheduleAtFixedRate(java.lang.Runnable command, long initialDelay, long period, java.util.concurrent.TimeUnit unit)
TimeScheduler
scheduleAtFixedRate
in interface TimeScheduler
command
- the task to executeinitialDelay
- the time to delay first executionperiod
- the period between successive executionsunit
- the time unit of the initialDelay and period parameterspublic java.util.concurrent.Future<?> scheduleWithDynamicInterval(TimeScheduler.Task task)
TimeScheduler
TimeScheduler.Task.nextInterval()
milliseconds. This is delay-based and not
rate-based.
The task is never done until nextInterval() return a value <= 0 or the task is cancelled.scheduleWithDynamicInterval
in interface TimeScheduler
task
- the task to executepublic void setThreadFactory(ThreadFactory factory)
setThreadFactory
in interface TimeScheduler
public java.lang.String dumpTimerTasks()
TimeScheduler
dumpTimerTasks
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 size()
TimeScheduler
size
in interface TimeScheduler
public void stop()
TimeScheduler
stop
in interface TimeScheduler
public boolean isShutdown()
TimeScheduler
isShutdown
in interface TimeScheduler
Copyright © 1998-2020 Red Hat. All Rights Reserved.