org.apache.solr.common.util

Class ExecutorUtil

java.lang.Object

org.apache.solr.common.util.ExecutorUtil

public class ExecutorUtil
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	ExecutorUtil.MDCAwareThreadPoolExecutor

Field Summary

Fields

Modifier and Type	Field and Description
static org.slf4j.Logger	log

Constructor Summary

Constructors

Constructor and Description
ExecutorUtil()

Method Summary

Methods

Modifier and Type	Method and Description
static ExecutorService	newMDCAwareCachedThreadPool(ThreadFactory threadFactory) See Executors.newCachedThreadPool(ThreadFactory)
static ExecutorService	newMDCAwareFixedThreadPool(int nThreads, ThreadFactory threadFactory) See Executors.newFixedThreadPool(int, ThreadFactory)
static ExecutorService	newMDCAwareSingleThreadExecutor(ThreadFactory threadFactory) See Executors.newSingleThreadExecutor(ThreadFactory)
static void	shutdownAndAwaitTermination(ExecutorService pool)
static void	shutdownAndAwaitTermination(ExecutorService pool, long timeout, TimeUnit timeUnit)
static void	shutdownNowAndAwaitTermination(ExecutorService pool)

Methods inherited from class java.lang.Object

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

Field Detail

log

public static org.slf4j.Logger log

Constructor Detail

ExecutorUtil

public ExecutorUtil()

Method Detail

shutdownNowAndAwaitTermination

public static void shutdownNowAndAwaitTermination(ExecutorService pool)

shutdownAndAwaitTermination

public static void shutdownAndAwaitTermination(ExecutorService pool)

shutdownAndAwaitTermination

public static void shutdownAndAwaitTermination(ExecutorService pool,
                               long timeout,
                               TimeUnit timeUnit)

newMDCAwareFixedThreadPool

public static ExecutorService newMDCAwareFixedThreadPool(int nThreads,
                                         ThreadFactory threadFactory)

See Executors.newFixedThreadPool(int, ThreadFactory)

newMDCAwareSingleThreadExecutor

public static ExecutorService newMDCAwareSingleThreadExecutor(ThreadFactory threadFactory)

See Executors.newSingleThreadExecutor(ThreadFactory)

newMDCAwareCachedThreadPool

public static ExecutorService newMDCAwareCachedThreadPool(ThreadFactory threadFactory)

See Executors.newCachedThreadPool(ThreadFactory)