public Class AutoCloseableExecutorService

Class Inheritance

extends ThreadPoolExecutor
implements AutoCloseable

All Implemented Interfaces

java.lang.AutoCloseable

Imports

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

Field Summary

Modifier and Type	Field and Description
public final InterruptionChecker	interruptionChecker The `InterruptionChecker`.

Access	Constructor and Description
public	AutoCloseableExecutorService(final int The number of threads to allocate. numThreads) A ThreadPoolExecutor that can be used in a try-with-resources block.

Modifier and Type	Method and Description
public void	afterExecute(final Runnable the Runnable runnable, final Throwable the Throwable throwable) Overrides java.util.concurrent.ThreadPoolExecutor.afterExecute. Catch exceptions from both submit() and execute(), and call `InterruptionChecker#interrupt()` to interrupt all threads.
public void	close() Overrides default java.util.concurrent.ExecutorService.close. Implements java.lang.AutoCloseable.close. Shut down thread pool on close().

interruptionChecker	back to summary
public final InterruptionChecker interruptionChecker The `InterruptionChecker`.

AutoCloseableExecutorService	back to summary
public AutoCloseableExecutorService(final int numThreads) A ThreadPoolExecutor that can be used in a try-with-resources block. Parameters numThreads:int The number of threads to allocate.

AutoCloseableExecutorService

public AutoCloseableExecutorService(final int numThreads)

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

Parameters

afterExecute back to summary

afterExecute	back to summary
public void afterExecute(final Runnable runnable, final Throwable throwable) Overrides java.util.concurrent.ThreadPoolExecutor.afterExecute. Catch exceptions from both submit() and execute(), and call `InterruptionChecker#interrupt()` to interrupt all threads. Parameters runnable:Runnable the Runnable throwable:Throwable the Throwable Annotations @Override

public void afterExecute(final Runnable runnable, final Throwable throwable)

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

Parameters

Annotations

close	back to summary
public void close() Overrides default java.util.concurrent.ExecutorService.close. Implements java.lang.AutoCloseable.close. Shut down thread pool on close(). Annotations @Override

public void close()

Shut down thread pool on close().

Annotations