Package fr.ens.biologie.genomique.eoulsan.core.schedulers

Class PausableThreadPoolExecutor

java.lang.Object

java.util.concurrent.AbstractExecutorService

java.util.concurrent.ThreadPoolExecutor

fr.ens.biologie.genomique.eoulsan.core.schedulers.PausableThreadPoolExecutor

All Implemented Interfaces:

Executor, ExecutorService

public class PausableThreadPoolExecutor
extends ThreadPoolExecutor

This class define a Pausable thread pool executor. This class is based on the javadoc documentation of the ThreadPoolExecutor class.

Since:

2.0

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
PausableThreadPoolExecutor(int threadNumber)	public constructor.

Method Summary

Modifier and Type	Method	Description
void	pause()	Pause the executor.
void	resume()	Resume the executor.
<T> Future<T>	submit(Runnable task, T result, int requiredProcessors)	Submit a task.

Methods inherited from class java.util.concurrent.ThreadPoolExecutor

allowCoreThreadTimeOut, allowsCoreThreadTimeOut, awaitTermination, execute, getActiveCount, getCompletedTaskCount, getCorePoolSize, getKeepAliveTime, getLargestPoolSize, getMaximumPoolSize, getPoolSize, getQueue, getRejectedExecutionHandler, getTaskCount, getThreadFactory, isShutdown, isTerminated, isTerminating, prestartAllCoreThreads, prestartCoreThread, purge, remove, setCorePoolSize, setKeepAliveTime, setMaximumPoolSize, setRejectedExecutionHandler, setThreadFactory, shutdown, shutdownNow, toString

Methods inherited from class java.util.concurrent.AbstractExecutorService

invokeAll, invokeAll, invokeAny, invokeAny, submit, submit, submit

Methods inherited from class java.lang.Object

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

Constructor Details

PausableThreadPoolExecutor

public PausableThreadPoolExecutor(int threadNumber)

public constructor.

Parameters:

threadNumber - number of threads

Method Details

submit

public <T> Future<T> submit(Runnable task,
 T result,
 int requiredProcessors)

Submit a task.

Type Parameters:

T - result class

Parameters:

task - the task to submmit

result - the result

requiredProcessors - the required processor number

Returns:

a Future task

pause

public void pause()

Pause the executor.

resume

public void resume()

Resume the executor.