Class AutoCloseableExecutorService

java.lang.Object

java.util.concurrent.AbstractExecutorService

java.util.concurrent.ThreadPoolExecutor

nonapi.io.github.classgraph.concurrency.AutoCloseableExecutorService

All Implemented Interfaces:

AutoCloseable, Executor, ExecutorService

public class AutoCloseableExecutorService
extends ThreadPoolExecutor
implements AutoCloseable

A ThreadPoolExecutor that can be used in a try-with-resources block.

Nested Class Summary

Nested classes/interfaces inherited from class ThreadPoolExecutor

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

Field Summary

Fields

Modifier and Type	Field	Description
final InterruptionChecker	interruptionChecker	The InterruptionChecker.

Constructor Summary

Constructors

Constructor	Description
AutoCloseableExecutorService(int numThreads)	A ThreadPoolExecutor that can be used in a try-with-resources block.

Method Summary

Modifier and Type	Method	Description
void	afterExecute(Runnable runnable, Throwable throwable)	Catch exceptions from both submit() and execute(), and call InterruptionChecker.interrupt() to interrupt all threads.
void	close()	Shut down thread pool on close().

Methods inherited from class ThreadPoolExecutor

allowCoreThreadTimeOut, allowsCoreThreadTimeOut, awaitTermination, beforeExecute, execute, finalize, 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, terminated, toString

Methods inherited from class AbstractExecutorService

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

Methods inherited from class Object

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

Field Details

interruptionChecker

public final InterruptionChecker interruptionChecker

The InterruptionChecker.

Constructor Details

AutoCloseableExecutorService

public AutoCloseableExecutorService(int numThreads)

A ThreadPoolExecutor that can be used in a try-with-resources block.

Parameters:

numThreads - The number of threads to allocate.

Method Details

afterExecute

public void afterExecute(Runnable runnable,
 Throwable throwable)

Catch exceptions from both submit() and execute(), and call InterruptionChecker.interrupt() to interrupt all threads.

Overrides:

afterExecute in class ThreadPoolExecutor

Parameters:

runnable - the Runnable

throwable - the Throwable

close

public void close()

Shut down thread pool on close().

Specified by:

close in interface AutoCloseable

Specified by:

close in interface ExecutorService