nonapi.io.github.classgraph.concurrency

Class AutoCloseableExecutorService

java.lang.Object

java.util.concurrent.AbstractExecutorService

java.util.concurrent.ThreadPoolExecutor

nonapi.io.github.classgraph.concurrency.AutoCloseableExecutorService

All Implemented Interfaces:

java.lang.AutoCloseable, java.util.concurrent.Executor, java.util.concurrent.ExecutorService

public class AutoCloseableExecutorService
extends java.util.concurrent.ThreadPoolExecutor
implements java.lang.AutoCloseable

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

Nested Class Summary

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

java.util.concurrent.ThreadPoolExecutor.AbortPolicy, java.util.concurrent.ThreadPoolExecutor.CallerRunsPolicy, java.util.concurrent.ThreadPoolExecutor.DiscardOldestPolicy, java.util.concurrent.ThreadPoolExecutor.DiscardPolicy

Field Summary

Fields

Modifier and Type	Field and Description
InterruptionChecker	interruptionChecker The InterruptionChecker.

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
void	afterExecute(java.lang.Runnable runnable, java.lang.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 java.util.concurrent.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 java.util.concurrent.AbstractExecutorService

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

Methods inherited from class java.lang.Object

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

Field Detail

interruptionChecker

public final InterruptionChecker interruptionChecker

The InterruptionChecker.

Constructor Detail

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 Detail

afterExecute

public void afterExecute(java.lang.Runnable runnable,
                         java.lang.Throwable throwable)

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

Overrides:

afterExecute in class java.util.concurrent.ThreadPoolExecutor

Parameters:

runnable - the Runnable

throwable - the Throwable

close

public void close()

Shut down thread pool on close().

Specified by:

close in interface java.lang.AutoCloseable