public class CronThreadPoolExecutor extends java.util.concurrent.ScheduledThreadPoolExecutor implements CronExecutorService
java.util.concurrent.ThreadPoolExecutor.AbortPolicy, java.util.concurrent.ThreadPoolExecutor.CallerRunsPolicy, java.util.concurrent.ThreadPoolExecutor.DiscardOldestPolicy, java.util.concurrent.ThreadPoolExecutor.DiscardPolicy
Modifier and Type | Field and Description |
---|---|
protected static Logger |
logger |
Constructor and Description |
---|
CronThreadPoolExecutor(int corePoolSize)
Constructs a new CronThreadPoolExecutor.
|
CronThreadPoolExecutor(int corePoolSize,
java.util.concurrent.RejectedExecutionHandler handler)
Constructs a new CronThreadPoolExecutor.
|
Modifier and Type | Method and Description |
---|---|
void |
schedule(java.lang.Runnable task,
org.quartz.CronExpression expression)
Schedules the specified task to execute according to the specified cron expression.
|
decorateTask, decorateTask, execute, getContinueExistingPeriodicTasksAfterShutdownPolicy, getExecuteExistingDelayedTasksAfterShutdownPolicy, getQueue, getRemoveOnCancelPolicy, schedule, schedule, scheduleAtFixedRate, scheduleWithFixedDelay, setContinueExistingPeriodicTasksAfterShutdownPolicy, setExecuteExistingDelayedTasksAfterShutdownPolicy, setRemoveOnCancelPolicy, shutdown, shutdownNow, submit, submit, submit
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
invokeAll, invokeAll, invokeAny, invokeAny, newTaskFor, newTaskFor
clone, equals, getClass, hashCode, notify, notifyAll, wait, wait, wait
protected static Logger logger
public CronThreadPoolExecutor(int corePoolSize, java.util.concurrent.RejectedExecutionHandler handler)
corePoolSize
- handler
- public CronThreadPoolExecutor(int corePoolSize)
corePoolSize
- public void schedule(java.lang.Runnable task, org.quartz.CronExpression expression)
CronExecutorService
schedule
in interface CronExecutorService
task
- the Runnable task to scheduleexpression
- a cron expressionCronExecutorService.schedule(java.lang.Runnable, org.quartz.CronExpression)