org.aredis.util

Class DefaultRedisTimer

java.lang.Object

java.util.concurrent.AbstractExecutorService

java.util.concurrent.ThreadPoolExecutor

java.util.concurrent.ScheduledThreadPoolExecutor

org.aredis.util.DefaultRedisTimer

All Implemented Interfaces:

Executor, ExecutorService, ScheduledExecutorService, RedisTimer

public class DefaultRedisTimer
extends ScheduledThreadPoolExecutor
implements RedisTimer

Default Redis Timer which is a ScheduledThreadPoolExecutor with poolSize 1.

Author:

Suresh

Nested Class Summary

Nested classes/interfaces inherited from class java.util.concurrent.ThreadPoolExecutor

ThreadPoolExecutor.AbortPolicy, ThreadPoolExecutor.CallerRunsPolicy, ThreadPoolExecutor.DiscardOldestPolicy, ThreadPoolExecutor.DiscardPolicy

Constructor Summary

Constructors

Constructor and Description
DefaultRedisTimer()

Method Summary

Methods

Modifier and Type	Method and Description
void	schedule(Runnable command, long delayMillis) Schedule a command to run once after the given delay.
void	scheduleWithFixedDelay(Runnable command, long initialDelayMillis, long delayMillis) Schedule a command to run with a fixed delay.

Methods inherited from class java.util.concurrent.ScheduledThreadPoolExecutor

decorateTask, decorateTask, execute, getContinueExistingPeriodicTasksAfterShutdownPolicy, getExecuteExistingDelayedTasksAfterShutdownPolicy, getQueue, getRemoveOnCancelPolicy, schedule, schedule, scheduleAtFixedRate, scheduleWithFixedDelay, setContinueExistingPeriodicTasksAfterShutdownPolicy, setExecuteExistingDelayedTasksAfterShutdownPolicy, setRemoveOnCancelPolicy, shutdown, shutdownNow, submit, submit, submit

Methods inherited from class java.util.concurrent.ThreadPoolExecutor

afterExecute, allowCoreThreadTimeOut, allowsCoreThreadTimeOut, awaitTermination, beforeExecute, finalize, getActiveCount, getCompletedTaskCount, getCorePoolSize, getKeepAliveTime, getLargestPoolSize, getMaximumPoolSize, getPoolSize, getRejectedExecutionHandler, getTaskCount, getThreadFactory, isShutdown, isTerminated, isTerminating, prestartAllCoreThreads, prestartCoreThread, purge, remove, setCorePoolSize, setKeepAliveTime, setMaximumPoolSize, setRejectedExecutionHandler, setThreadFactory, terminated, toString

Methods inherited from class java.util.concurrent.AbstractExecutorService

invokeAll, invokeAll, invokeAny, invokeAny, newTaskFor, newTaskFor

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.concurrent.ExecutorService

awaitTermination, invokeAll, invokeAll, invokeAny, invokeAny, isShutdown, isTerminated

Constructor Detail

DefaultRedisTimer

public DefaultRedisTimer()

Method Detail

schedule

public void schedule(Runnable command,
            long delayMillis)

Description copied from interface: RedisTimer

Schedule a command to run once after the given delay.

Specified by:

schedule in interface RedisTimer

Parameters:

command - Command

delayMillis - Delay in milliseconds

scheduleWithFixedDelay

public void scheduleWithFixedDelay(Runnable command,
                          long initialDelayMillis,
                          long delayMillis)

Description copied from interface: RedisTimer

Schedule a command to run with a fixed delay.

Specified by:

scheduleWithFixedDelay in interface RedisTimer

Parameters:

command - Command

initialDelayMillis - Initial delay before the command is first run, in milliseconds

delayMillis - delay between successive runs, in milliseconds