Package org.kquiet.concurrent

Class PausableScheduledThreadPoolExecutor

java.lang.Object

java.util.concurrent.AbstractExecutorService

java.util.concurrent.ThreadPoolExecutor

java.util.concurrent.ScheduledThreadPoolExecutor

org.kquiet.concurrent.PausableScheduledThreadPoolExecutor

All Implemented Interfaces:

Executor, ExecutorService, ScheduledExecutorService

public class PausableScheduledThreadPoolExecutor
extends ScheduledThreadPoolExecutor

Pausable ScheduledThreadPoolExecutor. This class is for internal use.

Author:

Kimberly

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	Description
PausableScheduledThreadPoolExecutor()	Create a PausableScheduledThreadPoolExecutor with core/maximum pool size set to one.
PausableScheduledThreadPoolExecutor(String poolPrefix, int corePoolSize)	Create a PausableScheduledThreadPoolExecutor with specified parameters.
PausableScheduledThreadPoolExecutor(String poolPrefix, int corePoolSize, Consumer<Runnable> afterExecuteFunc)	Create a PausableScheduledThreadPoolExecutor with specified parameters.

Method Summary

Modifier and Type	Method	Description
protected void	afterExecute(Runnable r, Throwable t)
protected void	beforeExecute(Thread t, Runnable r)
boolean	isPaused()	Check if the execution of this PausableScheduledThreadPoolExecutor is paused.
void	pause()	Pause the execution of this PausableScheduledThreadPoolExecutor.
void	resume()	Resume the execution of this PausableScheduledThreadPoolExecutor.

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

allowCoreThreadTimeOut, allowsCoreThreadTimeOut, awaitTermination, 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 Details

PausableScheduledThreadPoolExecutor

public PausableScheduledThreadPoolExecutor()

Create a PausableScheduledThreadPoolExecutor with core/maximum pool size set to one.

PausableScheduledThreadPoolExecutor

public PausableScheduledThreadPoolExecutor(String poolPrefix,
 int corePoolSize)

Create a PausableScheduledThreadPoolExecutor with specified parameters.

Parameters:

poolPrefix - prefix name of thread pool

corePoolSize - core pool size

PausableScheduledThreadPoolExecutor

public PausableScheduledThreadPoolExecutor(String poolPrefix,
 int corePoolSize,
 Consumer<Runnable> afterExecuteFunc)

Create a PausableScheduledThreadPoolExecutor with specified parameters.

Parameters:

poolPrefix - prefix name of thread pool

corePoolSize - core pool size

afterExecuteFunc - the function to execute after any task is executed

Method Details

beforeExecute

protected void beforeExecute(Thread t,
 Runnable r)

Overrides:

beforeExecute in class ThreadPoolExecutor

afterExecute

protected void afterExecute(Runnable r,
 Throwable t)

Overrides:

afterExecute in class ThreadPoolExecutor

pause

public void pause()

Pause the execution of this PausableScheduledThreadPoolExecutor. Any executing task is not affected.

resume

public void resume()

Resume the execution of this PausableScheduledThreadPoolExecutor.

isPaused

public boolean isPaused()

Check if the execution of this PausableScheduledThreadPoolExecutor is paused.

Returns:

whether this PausableScheduledThreadPoolExecutor is paused.