Package dev.enola.common.concurrent

Class Executors

java.lang.Object

dev.enola.common.concurrent.Executors

public final class Executors
extends Object

Additional factory and utility methods for executors.

Use this instead of Executors, because it ensures that:

• the TLC is correctly propagated
• the returned Executor uses a ThreadFactory that is named,
• has an UncaughtExceptionHandler which logs to SLF4j
• can return (Guava's) ListenableFuture.

Field Summary

Fields

Modifier and Type	Field	Description
static final long	DEFAULT_TIMEOUT_FOR_SHUTDOWN
static final TimeUnit	DEFAULT_TIMEOUT_UNIT_FOR_SHUTDOWN

Method Summary

Modifier and Type	Method	Description
static ExecutorService	newCachedThreadPool(String namePrefix, org.slf4j.Logger logger)
static ExecutorService	newFixedThreadPool(int size, String namePrefix, org.slf4j.Logger logger)
static ListeningExecutorService	newListeningCachedThreadPool(String namePrefix, org.slf4j.Logger logger)
static ListeningExecutorService	newListeningDirectExecutor()	Creates an executor service that runs each task in the thread that invokes execute/submit.
static ListeningExecutorService	newListeningFixedThreadPool(int size, String namePrefix, org.slf4j.Logger logger)
static ListeningScheduledExecutorService	newListeningScheduledThreadPool(int corePoolSize, String namePrefix, org.slf4j.Logger logger)
static ListeningExecutorService	newListeningSingleThreadExecutor(String namePrefix, org.slf4j.Logger logger)	Creates a single thread executor with a ThreadFactory that uses the provided prefix for its thread names and logs uncaught exceptions with the specified Logger.
static ListeningScheduledExecutorService	newListeningSingleThreadScheduledExecutor(String namePrefix, org.slf4j.Logger logger)
static ExecutorService	newSingleThreadExecutor(String namePrefix, org.slf4j.Logger logger)
static void	shutdownAndAwaitTermination(ExecutorService executorService)

Methods inherited from class java.lang.Object

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

Field Details

DEFAULT_TIMEOUT_FOR_SHUTDOWN

public static final long DEFAULT_TIMEOUT_FOR_SHUTDOWN

See Also:

• Constant Field Values

DEFAULT_TIMEOUT_UNIT_FOR_SHUTDOWN

public static final TimeUnit DEFAULT_TIMEOUT_UNIT_FOR_SHUTDOWN

Method Details

newListeningDirectExecutor

public static ListeningExecutorService newListeningDirectExecutor()

Creates an executor service that runs each task in the thread that invokes execute/submit. This does not take namePrefix and Logger arguments, to make it clear they are not needed, because no separate new threads will ever be created. Note that a "scheduled direct Executor" variant doesn't really make sense conceptually (unless you would want it to just completely ignore all requested delays; which would be weird).

See Also:

• MoreExecutors.newDirectExecutorService()

newListeningSingleThreadExecutor

public static ListeningExecutorService newListeningSingleThreadExecutor(String namePrefix,
 org.slf4j.Logger logger)

Creates a single thread executor with a ThreadFactory that uses the provided prefix for its thread names and logs uncaught exceptions with the specified Logger.

Parameters:

namePrefix - Prefix for threads from this executor. For example, "rpc-pool", to create "rpc-pool-1/2/3" named threads. Note that this is a prefix, not a format, so you pass just "rpc-pool" instead of e.g. "rpc-pool-%d".

logger - Logger used to log uncaught exceptions from new threads created from this.

See Also:

• Executors.newSingleThreadExecutor()

newSingleThreadExecutor

public static ExecutorService newSingleThreadExecutor(String namePrefix,
 org.slf4j.Logger logger)

newListeningFixedThreadPool

public static ListeningExecutorService newListeningFixedThreadPool(int size,
 String namePrefix,
 org.slf4j.Logger logger)

See Also:

• Executors.newFixedThreadPool(int)

newFixedThreadPool

public static ExecutorService newFixedThreadPool(int size,
 String namePrefix,
 org.slf4j.Logger logger)

newListeningCachedThreadPool

public static ListeningExecutorService newListeningCachedThreadPool(String namePrefix,
 org.slf4j.Logger logger)

See Also:

• Executors.newCachedThreadPool()

newCachedThreadPool

public static ExecutorService newCachedThreadPool(String namePrefix,
 org.slf4j.Logger logger)

newListeningSingleThreadScheduledExecutor

public static ListeningScheduledExecutorService newListeningSingleThreadScheduledExecutor(String namePrefix,
 org.slf4j.Logger logger)

See Also:

• Executors.newSingleThreadScheduledExecutor()

newListeningScheduledThreadPool

public static ListeningScheduledExecutorService newListeningScheduledThreadPool(int corePoolSize,
 String namePrefix,
 org.slf4j.Logger logger)

See Also:

• Executors.newScheduledThreadPool(int)

shutdownAndAwaitTermination

public static void shutdownAndAwaitTermination(ExecutorService executorService)