com.atlassian.bamboo.concurrent

Class BambooExecutors

java.lang.Object

com.atlassian.bamboo.concurrent.BambooExecutors

public final class BambooExecutors
extends Object

Method Summary

Modifier and Type	Method and Description
static ExecutorService	newBlockingThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, BlockingQueue<Runnable> workQueue, ThreadFactory threadFactory) Creates an executor that will block execute() calls when thread pool depth reaches maximumPoolSize and workQueue is full.
static ExecutorService	newBlockingThreadPoolExecutor(int poolSize, long keepAliveTime, TimeUnit unit, BlockingQueue<Runnable> workQueue, ThreadFactory threadFactory)

Methods inherited from class java.lang.Object

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

Method Detail

newBlockingThreadPoolExecutor

public static ExecutorService newBlockingThreadPoolExecutor(int corePoolSize,
                                                            int maximumPoolSize,
                                                            long keepAliveTime,
                                                            TimeUnit unit,
                                                            BlockingQueue<Runnable> workQueue,
                                                            ThreadFactory threadFactory)

Creates an executor that will block execute() calls when thread pool depth reaches maximumPoolSize and workQueue is full. Note that the blocked execute calls will be continued in a random order. Make sure corePoolSize equals to maximumPoolSize as this ExecutorService allows timeout of core threads. See ThreadPoolExecutor.ThreadPoolExecutor(int, int, long, TimeUnit, BlockingQueue, ThreadFactory)

newBlockingThreadPoolExecutor

public static ExecutorService newBlockingThreadPoolExecutor(int poolSize,
                                                            long keepAliveTime,
                                                            TimeUnit unit,
                                                            BlockingQueue<Runnable> workQueue,
                                                            ThreadFactory threadFactory)