Package org.eclipse.aether.util.concurrency

Class ExecutorUtils

java.lang.Object

org.eclipse.aether.util.concurrency.ExecutorUtils

public final class ExecutorUtils
extends Object

Utilities for executors and sizing them.

Since:

1.9.5

Field Summary

Fields

Modifier and Type	Field	Description
static final Executor	DIRECT_EXECUTOR	Shared instance of "direct executor".

Constructor Summary

Constructors

Constructor	Description
ExecutorUtils()

Method Summary

Modifier and Type	Method	Description
static Executor	executor(int size, String namePrefix)	Returns DIRECT_EXECUTOR or result of threadPool(int, String) depending on value of size parameter.
static void	shutdown(Executor executor)	To be used with result of executor(int, String) method, shuts down instance if it is ExecutorService.
static int	threadCount(RepositorySystemSession session, int defaultValue, String... keys)	Retrieves and validates requested thread count based on session and specified keys, or if none provided, the provided default value.
static ExecutorService	threadPool(int poolSize, String namePrefix)	Creates new thread pool ExecutorService.

Methods inherited from class java.lang.Object

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

Field Details

DIRECT_EXECUTOR

public static final Executor DIRECT_EXECUTOR

Shared instance of "direct executor".

Constructor Details

ExecutorUtils

public ExecutorUtils()

Method Details

threadPool

public static ExecutorService threadPool(int poolSize,
 String namePrefix)

Creates new thread pool ExecutorService. The poolSize parameter but be greater than 1.

executor

public static Executor executor(int size,
 String namePrefix)

Returns DIRECT_EXECUTOR or result of threadPool(int, String) depending on value of size parameter.

shutdown

public static void shutdown(Executor executor)

To be used with result of executor(int, String) method, shuts down instance if it is ExecutorService.

threadCount

public static int threadCount(RepositorySystemSession session,
 int defaultValue,
 String... keys)

Retrieves and validates requested thread count based on session and specified keys, or if none provided, the provided default value. This method validates result on top of what ConfigUtils does.

Throws:

IllegalArgumentException - if default value is less than 1.

See Also:

• ConfigUtils.getInteger(RepositorySystemSession, int, String...)