Package org.apache.sshd.common.util.threads

Class ThreadUtils

java.lang.Object

org.apache.sshd.common.util.threads.ThreadUtils

public final class ThreadUtils
extends java.lang.Object

Utility class for thread pools.

Constructor Summary

Constructors

Modifier	Constructor	Description
private	ThreadUtils()

Method Summary

Modifier and Type	Method	Description
static <T> T	createDefaultInstance(java.lang.Class<?> anchor, java.lang.Class<? extends T> targetType, java.lang.String className)
static <T> T	createDefaultInstance(java.lang.ClassLoader cl, java.lang.Class<? extends T> targetType, java.lang.String className)
static <T> T	createDefaultInstance(java.lang.Iterable<? extends java.lang.ClassLoader> cls, java.lang.Class<? extends T> targetType, java.lang.String className)
static java.util.Iterator<java.lang.ClassLoader>	iterateDefaultClassLoaders(java.lang.Class<?> anchor)
static CloseableExecutorService	newCachedThreadPool(java.lang.String poolName)
static CloseableExecutorService	newCachedThreadPoolIf(CloseableExecutorService executorService, java.lang.String poolName)
static CloseableExecutorService	newFixedThreadPool(java.lang.String poolName, int nThreads)
static CloseableExecutorService	newFixedThreadPoolIf(CloseableExecutorService executorService, java.lang.String poolName, int nThreads)
static CloseableExecutorService	newSingleThreadExecutor(java.lang.String poolName)
static java.util.concurrent.ScheduledExecutorService	newSingleThreadScheduledExecutor(java.lang.String poolName)
static CloseableExecutorService	noClose(CloseableExecutorService executorService)
static CloseableExecutorService	protectExecutorServiceShutdown(CloseableExecutorService executorService, boolean shutdownOnExit)	Wraps an CloseableExecutorService in such a way as to "protect" it for calls to the ExecutorService.shutdown() or ExecutorService.shutdownNow().
static java.lang.Class<?>	resolveDefaultClass(java.lang.Class<?> anchor, java.lang.String className)
static java.lang.Class<?>	resolveDefaultClass(java.lang.Iterable<? extends java.lang.ClassLoader> cls, java.lang.String className)
static java.lang.ClassLoader	resolveDefaultClassLoader(java.lang.Class<?> anchor)	Attempts to find the most suitable ClassLoader as follows:
static java.lang.ClassLoader	resolveDefaultClassLoader(java.lang.Object anchor)
static java.lang.Iterable<java.lang.ClassLoader>	resolveDefaultClassLoaders(java.lang.Class<?> anchor)
static java.lang.Iterable<java.lang.ClassLoader>	resolveDefaultClassLoaders(java.lang.Object anchor)

Methods inherited from class java.lang.Object

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

Constructor Detail

ThreadUtils

private ThreadUtils()

Method Detail

protectExecutorServiceShutdown

public static CloseableExecutorService protectExecutorServiceShutdown(CloseableExecutorService executorService,
                                                                      boolean shutdownOnExit)

Wraps an CloseableExecutorService in such a way as to "protect" it for calls to the ExecutorService.shutdown() or ExecutorService.shutdownNow(). All other calls are delegated as-is to the original service. Note: the exposed wrapped proxy will answer correctly the ExecutorService.isShutdown() query if indeed one of the shutdown methods was invoked.

Parameters:

executorService - The original service - ignored if null

shutdownOnExit - If true then it is OK to shutdown the executor so no wrapping takes place.

Returns:

Either the original service or a wrapped one - depending on the value of the shutdownOnExit parameter

noClose

public static CloseableExecutorService noClose(CloseableExecutorService executorService)

resolveDefaultClassLoader

public static java.lang.ClassLoader resolveDefaultClassLoader(java.lang.Object anchor)

resolveDefaultClassLoaders

public static java.lang.Iterable<java.lang.ClassLoader> resolveDefaultClassLoaders(java.lang.Object anchor)

resolveDefaultClassLoaders

public static java.lang.Iterable<java.lang.ClassLoader> resolveDefaultClassLoaders(java.lang.Class<?> anchor)

resolveDefaultClass

public static java.lang.Class<?> resolveDefaultClass(java.lang.Class<?> anchor,
                                                     java.lang.String className)

resolveDefaultClass

public static java.lang.Class<?> resolveDefaultClass(java.lang.Iterable<? extends java.lang.ClassLoader> cls,
                                                     java.lang.String className)

createDefaultInstance

public static <T> T createDefaultInstance(java.lang.Class<?> anchor,
                                          java.lang.Class<? extends T> targetType,
                                          java.lang.String className)
                                   throws java.lang.ReflectiveOperationException

Throws:

java.lang.ReflectiveOperationException

createDefaultInstance

public static <T> T createDefaultInstance(java.lang.ClassLoader cl,
                                          java.lang.Class<? extends T> targetType,
                                          java.lang.String className)
                                   throws java.lang.ReflectiveOperationException

Throws:

java.lang.ReflectiveOperationException

createDefaultInstance

public static <T> T createDefaultInstance(java.lang.Iterable<? extends java.lang.ClassLoader> cls,
                                          java.lang.Class<? extends T> targetType,
                                          java.lang.String className)
                                   throws java.lang.ReflectiveOperationException

Throws:

java.lang.ReflectiveOperationException

resolveDefaultClassLoader

public static java.lang.ClassLoader resolveDefaultClassLoader(java.lang.Class<?> anchor)

Attempts to find the most suitable ClassLoader as follows:

• Check the Thread.getContextClassLoader() value

• If no thread context class loader then check the anchor class (if given) for its class loader

• If still no loader available, then use ClassLoader.getSystemClassLoader()

Parameters:

anchor - The anchor Class to use if no current thread context class loader - ignored if null

Returns:

The resolved ClassLoader - Note: might still be null if went all the way "down" to the system class loader and it was also null.

iterateDefaultClassLoaders

public static java.util.Iterator<java.lang.ClassLoader> iterateDefaultClassLoaders(java.lang.Class<?> anchor)

newFixedThreadPoolIf

public static CloseableExecutorService newFixedThreadPoolIf(CloseableExecutorService executorService,
                                                            java.lang.String poolName,
                                                            int nThreads)

newFixedThreadPool

public static CloseableExecutorService newFixedThreadPool(java.lang.String poolName,
                                                          int nThreads)

newCachedThreadPoolIf

public static CloseableExecutorService newCachedThreadPoolIf(CloseableExecutorService executorService,
                                                             java.lang.String poolName)

newCachedThreadPool

public static CloseableExecutorService newCachedThreadPool(java.lang.String poolName)

newSingleThreadScheduledExecutor

public static java.util.concurrent.ScheduledExecutorService newSingleThreadScheduledExecutor(java.lang.String poolName)

newSingleThreadExecutor

public static CloseableExecutorService newSingleThreadExecutor(java.lang.String poolName)