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 and 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	newFixedThreadPool(String threadName, int poolSize)
static ExecutorService	newFixedThreadPool(String threadName, ThreadGroup parentThreadGroup, int poolSize)
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 Detail

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)

newFixedThreadPool

public static ExecutorService newFixedThreadPool(String threadName,
                                                 int poolSize)

newFixedThreadPool

public static ExecutorService newFixedThreadPool(String threadName,
                                                 ThreadGroup parentThreadGroup,
                                                 int poolSize)

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)