org.spf4j.concurrent

Class LifoThreadPoolExecutorSQP

java.lang.Object

java.util.concurrent.AbstractExecutorService

org.spf4j.concurrent.LifoThreadPoolExecutorSQP

All Implemented Interfaces:

Executor, ExecutorService, LifoThreadPool, MutableLifoThreadPool

@ParametersAreNonnullByDefault
public final class LifoThreadPoolExecutorSQP
extends AbstractExecutorService
implements MutableLifoThreadPool

Lifo scheduled java thread pool, based on talk: http://applicative.acm.org/speaker-BenMaurer.html This implementation behaves differently compared with a java Thread pool in that it prefers to spawn a thread if possible instead of queueing tasks. See LifoThreadPoolBuilder for conveniently constructing pools There are 3 data structures involved in the transfer of tasks to Threads. 1) Task Queue - a classic FIFO queue. RW controlled by a reentrant lock. only non-blockng read operations are done on this queue 2) Available Thread Queue - a classic LIFO queue, a thread end up here when there is nothing to process. 3) A "UnitQueue", is a queue with a capacity on 1, which a thread will listen on while in the available thread queue.

Author:

zoly

Constructor Summary

Constructors

Constructor and Description
LifoThreadPoolExecutorSQP(int maxNrThreads, String name)
LifoThreadPoolExecutorSQP(String poolName, int coreSize, int maxSize, int maxIdleTimeMillis, int queueSizeLimit)
LifoThreadPoolExecutorSQP(String poolName, int coreSize, int maxSize, int maxIdleTimeMillis, int queueSize, boolean daemonThreads)
LifoThreadPoolExecutorSQP(String poolName, int coreSize, int maxSize, int maxIdleTimeMillis, int queueSizeLimit, boolean daemonThreads, RejectedExecutionHandler rejectionHandler)
LifoThreadPoolExecutorSQP(String poolName, int coreSize, int maxSize, int maxIdleTimeMillis, int queueSizeLimit, boolean daemonThreads, RejectedExecutionHandler rejectionHandler, int threadPriority)

Method Summary

Modifier and Type	Method and Description
boolean	awaitTermination(long time, TimeUnit unit)
void	execute(Runnable command)
void	exportJmx()
int	getCoreThreadCount()
int	getMaxIdleTimeMillis()
int	getMaxThreadCount()
int	getNrQueuedTasks()
String	getPoolName()
int	getQueueSizeLimit()
ReentrantLock	getStateLock()
Queue<Runnable>	getTaskQueue()
int	getThreadCount()
int	getThreadPriority()
boolean	isDaemonThreads()
boolean	isShutdown()
boolean	isTerminated()
void	setCoreThreadCount(int coreThreadCount)
void	setDaemonThreads(boolean daemonThreads)
void	setMaxIdleTimeMillis(int maxIdleTimeMillis)
void	setMaxThreadCount(int maxThreadCount)
void	setQueueSizeLimit(int queueSizeLimit)
void	setThreadPriority(int threadPriority)
void	shutdown()
List<Runnable>	shutdownNow()
String	toString()
void	unregisterJmx()

Methods inherited from class java.util.concurrent.AbstractExecutorService

invokeAll, invokeAll, invokeAny, invokeAny, newTaskFor, newTaskFor, submit, submit, submit

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.concurrent.ExecutorService

invokeAll, invokeAll, invokeAny, invokeAny, submit, submit, submit

Constructor Detail

LifoThreadPoolExecutorSQP

public LifoThreadPoolExecutorSQP(int maxNrThreads,
                                 String name)

LifoThreadPoolExecutorSQP

public LifoThreadPoolExecutorSQP(String poolName,
                                 int coreSize,
                                 int maxSize,
                                 int maxIdleTimeMillis,
                                 int queueSize,
                                 boolean daemonThreads)

LifoThreadPoolExecutorSQP

public LifoThreadPoolExecutorSQP(String poolName,
                                 int coreSize,
                                 int maxSize,
                                 int maxIdleTimeMillis,
                                 int queueSizeLimit)

LifoThreadPoolExecutorSQP

public LifoThreadPoolExecutorSQP(String poolName,
                                 int coreSize,
                                 int maxSize,
                                 int maxIdleTimeMillis,
                                 int queueSizeLimit,
                                 boolean daemonThreads,
                                 RejectedExecutionHandler rejectionHandler)

LifoThreadPoolExecutorSQP

public LifoThreadPoolExecutorSQP(String poolName,
                                 int coreSize,
                                 int maxSize,
                                 int maxIdleTimeMillis,
                                 int queueSizeLimit,
                                 boolean daemonThreads,
                                 RejectedExecutionHandler rejectionHandler,
                                 int threadPriority)

Method Detail

exportJmx

public void exportJmx()

Specified by:

exportJmx in interface LifoThreadPool

execute

public void execute(Runnable command)

Specified by:

execute in interface Executor

shutdown

public void shutdown()

Specified by:

shutdown in interface ExecutorService

awaitTermination

public boolean awaitTermination(long time,
                                TimeUnit unit)
                         throws InterruptedException

Specified by:

awaitTermination in interface ExecutorService

Throws:

InterruptedException

shutdownNow

public List<Runnable> shutdownNow()

Specified by:

shutdownNow in interface ExecutorService

isShutdown

public boolean isShutdown()

Specified by:

isShutdown in interface ExecutorService

isDaemonThreads

public boolean isDaemonThreads()

Specified by:

isDaemonThreads in interface LifoThreadPool

isTerminated

public boolean isTerminated()

Specified by:

isTerminated in interface ExecutorService

getThreadCount

public int getThreadCount()

Specified by:

getThreadCount in interface LifoThreadPool

getMaxThreadCount

public int getMaxThreadCount()

Specified by:

getMaxThreadCount in interface LifoThreadPool

getCoreThreadCount

public int getCoreThreadCount()

Specified by:

getCoreThreadCount in interface LifoThreadPool

getStateLock

public ReentrantLock getStateLock()

Specified by:

getStateLock in interface LifoThreadPool

getNrQueuedTasks

public int getNrQueuedTasks()

Specified by:

getNrQueuedTasks in interface LifoThreadPool

getQueueSizeLimit

public int getQueueSizeLimit()

Specified by:

getQueueSizeLimit in interface LifoThreadPool

unregisterJmx

public void unregisterJmx()

Specified by:

unregisterJmx in interface LifoThreadPool

setDaemonThreads

public void setDaemonThreads(boolean daemonThreads)

Specified by:

setDaemonThreads in interface MutableLifoThreadPool

setMaxIdleTimeMillis

public void setMaxIdleTimeMillis(int maxIdleTimeMillis)

Specified by:

setMaxIdleTimeMillis in interface MutableLifoThreadPool

setMaxThreadCount

public void setMaxThreadCount(int maxThreadCount)

Specified by:

setMaxThreadCount in interface MutableLifoThreadPool

setCoreThreadCount

public void setCoreThreadCount(int coreThreadCount)

Specified by:

setCoreThreadCount in interface MutableLifoThreadPool

setQueueSizeLimit

public void setQueueSizeLimit(int queueSizeLimit)

Specified by:

setQueueSizeLimit in interface MutableLifoThreadPool

setThreadPriority

public void setThreadPriority(int threadPriority)

Specified by:

setThreadPriority in interface MutableLifoThreadPool

toString

public String toString()

Overrides:

toString in class Object

getTaskQueue

public Queue<Runnable> getTaskQueue()

Specified by:

getTaskQueue in interface LifoThreadPool

getMaxIdleTimeMillis

public int getMaxIdleTimeMillis()

Specified by:

getMaxIdleTimeMillis in interface LifoThreadPool

getPoolName

public String getPoolName()

Specified by:

getPoolName in interface LifoThreadPool

getThreadPriority

public int getThreadPriority()

Specified by:

getThreadPriority in interface LifoThreadPool