Package com.orientechnologies.common.thread

Class OThreadPoolExecutors

java.lang.Object

com.orientechnologies.common.thread.OThreadPoolExecutors

public class OThreadPoolExecutors
extends Object

Method Summary

Modifier and Type	Method	Description
static ExecutorService	newBlockingScalingThreadPool(String threadName, ThreadGroup parentThreadGroup, int corePoolSize, int maxPoolSize, int targetQueueCapacity, int maxQueueCapacity, long timeout, TimeUnit timeoutUnit)
static ExecutorService	newCachedThreadPool(String threadName)
static ExecutorService	newCachedThreadPool(String threadName, ThreadGroup parentThreadGroup)
static ExecutorService	newCachedThreadPool(String threadName, ThreadGroup parentThreadGroup, int maxThreads, int maxQueue)
static ExecutorService	newScalingThreadPool(String threadName, int corePoolSize, int maxPoolSize, int queueCapacity, long timeout, TimeUnit timeoutUnit)
static ExecutorService	newScalingThreadPool(String threadName, ThreadGroup parentThreadGroup, int corePoolSize, int maxPoolSize, int queueCapacity, long timeout, TimeUnit timeoutUnit)
static ExecutorService	newSingleThreadPool(String threadName)
static ExecutorService	newSingleThreadPool(String threadName, int maxQueue, RejectedExecutionHandler rejectHandler)
static ExecutorService	newSingleThreadPool(String threadName, ThreadGroup parentThreadGroup)
static ScheduledExecutorService	newSingleThreadScheduledPool(String threadName)
static ScheduledExecutorService	newSingleThreadScheduledPool(String threadName, ThreadGroup parentThreadGroup)

Methods inherited from class java.lang.Object

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

Method Details

newScalingThreadPool

public static ExecutorService newScalingThreadPool(String threadName,
 int corePoolSize,
 int maxPoolSize,
 int queueCapacity,
 long timeout,
 TimeUnit timeoutUnit)

newScalingThreadPool

public static ExecutorService newScalingThreadPool(String threadName,
 ThreadGroup parentThreadGroup,
 int corePoolSize,
 int maxPoolSize,
 int queueCapacity,
 long timeout,
 TimeUnit timeoutUnit)

newBlockingScalingThreadPool

public static ExecutorService newBlockingScalingThreadPool(String threadName,
 ThreadGroup parentThreadGroup,
 int corePoolSize,
 int maxPoolSize,
 int targetQueueCapacity,
 int maxQueueCapacity,
 long timeout,
 TimeUnit timeoutUnit)

newCachedThreadPool

public static ExecutorService newCachedThreadPool(String threadName)

newCachedThreadPool

public static ExecutorService newCachedThreadPool(String threadName,
 ThreadGroup parentThreadGroup)

newCachedThreadPool

public static ExecutorService newCachedThreadPool(String threadName,
 ThreadGroup parentThreadGroup,
 int maxThreads,
 int maxQueue)

newSingleThreadPool

public static ExecutorService newSingleThreadPool(String threadName)

newSingleThreadPool

public static ExecutorService newSingleThreadPool(String threadName,
 ThreadGroup parentThreadGroup)

newSingleThreadPool

public static ExecutorService newSingleThreadPool(String threadName,
 int maxQueue,
 RejectedExecutionHandler rejectHandler)

newSingleThreadScheduledPool

public static ScheduledExecutorService newSingleThreadScheduledPool(String threadName)

newSingleThreadScheduledPool

public static ScheduledExecutorService newSingleThreadScheduledPool(String threadName,
 ThreadGroup parentThreadGroup)