org.apache.sshd.common.util.threads

Class ThreadUtils

java.lang.Object

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

public final class ThreadUtils
extends Object

Utility class for thread pools.

Author:

Apache MINA SSHD Project

Method Summary

Modifier and Type	Method and Description
static <T> T	createDefaultInstance(Class<?> anchor, Class<T> targetType, String className)
static <T> T	createDefaultInstance(ClassLoader cl, Class<T> targetType, String className)
static <T> T	createDefaultInstance(Iterable<ClassLoader> cls, Class<T> targetType, String className)
static CloseableExecutorService	newCachedThreadPool(String poolName)
static CloseableExecutorService	newCachedThreadPoolIf(CloseableExecutorService executorService, String poolName)
static CloseableExecutorService	newFixedThreadPool(String poolName, int nThreads)
static CloseableExecutorService	newFixedThreadPoolIf(CloseableExecutorService executorService, String poolName, int nThreads)
static CloseableExecutorService	newSingleThreadExecutor(String poolName)
static ScheduledExecutorService	newSingleThreadScheduledExecutor(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 ClassLoader	resolveDefaultClassLoader(Class<?> anchor) Attempts to find the most suitable ClassLoader as follows:
static ClassLoader	resolveDefaultClassLoader(Object anchor)
static Iterable<ClassLoader>	resolveDefaultClassLoaders(Class<?> anchor)
static Iterable<ClassLoader>	resolveDefaultClassLoaders(Object anchor)

Methods inherited from class java.lang.Object

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

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 ClassLoader resolveDefaultClassLoader(Object anchor)

resolveDefaultClassLoaders

public static Iterable<ClassLoader> resolveDefaultClassLoaders(Object anchor)

createDefaultInstance

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

Throws:

ReflectiveOperationException

createDefaultInstance

public static <T> T createDefaultInstance(ClassLoader cl,
                                          Class<T> targetType,
                                          String className)
                                   throws ReflectiveOperationException

Throws:

ReflectiveOperationException

createDefaultInstance

public static <T> T createDefaultInstance(Iterable<ClassLoader> cls,
                                          Class<T> targetType,
                                          String className)
                                   throws ReflectiveOperationException

Throws:

ReflectiveOperationException

resolveDefaultClassLoader

public static ClassLoader resolveDefaultClassLoader(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 - ignored if null context class loader

Returns:

The resolver ClassLoader

resolveDefaultClassLoaders

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

newFixedThreadPoolIf

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

newFixedThreadPool

public static CloseableExecutorService newFixedThreadPool(String poolName,
                                                          int nThreads)

newCachedThreadPoolIf

public static CloseableExecutorService newCachedThreadPoolIf(CloseableExecutorService executorService,
                                                             String poolName)

newCachedThreadPool

public static CloseableExecutorService newCachedThreadPool(String poolName)

newSingleThreadScheduledExecutor

public static ScheduledExecutorService newSingleThreadScheduledExecutor(String poolName)

newSingleThreadExecutor

public static CloseableExecutorService newSingleThreadExecutor(String poolName)