org.jgroups.util

Class ThreadManagerThreadPoolExecutor

java.lang.Object

java.util.concurrent.AbstractExecutorService

java.util.concurrent.ThreadPoolExecutor

org.jgroups.util.ThreadManagerThreadPoolExecutor

All Implemented Interfaces:

Executor, ExecutorService, ThreadManager

public class ThreadManagerThreadPoolExecutor
extends ThreadPoolExecutor
implements ThreadManager

ThreadPoolExecutor subclass that implements @{link ThreadManager}.

Author:

Brian Stansberry

Nested Class Summary

Nested classes/interfaces inherited from class java.util.concurrent.ThreadPoolExecutor

ThreadPoolExecutor.AbortPolicy, ThreadPoolExecutor.CallerRunsPolicy, ThreadPoolExecutor.DiscardOldestPolicy, ThreadPoolExecutor.DiscardPolicy

Constructor Summary

Constructors

Constructor and Description
ThreadManagerThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, BlockingQueue<Runnable> workQueue)
ThreadManagerThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, BlockingQueue<Runnable> workQueue, RejectedExecutionHandler handler)
ThreadManagerThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, BlockingQueue<Runnable> workQueue, ThreadFactory threadFactory)
ThreadManagerThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, BlockingQueue<Runnable> workQueue, ThreadFactory threadFactory, RejectedExecutionHandler handler)

Method Summary

Methods

Modifier and Type	Method and Description
protected void	afterExecute(Runnable r, Throwable t) Invokes ThreadDecorator.threadReleased(Thread) on the current thread.
ThreadDecorator	getThreadDecorator() Gets the ThreadDecorator associated with this manager.
void	setThreadDecorator(ThreadDecorator decorator) Sets the ThreadDecorator associated this manager should use.

Methods inherited from class java.util.concurrent.ThreadPoolExecutor

allowCoreThreadTimeOut, allowsCoreThreadTimeOut, awaitTermination, beforeExecute, execute, finalize, getActiveCount, getCompletedTaskCount, getCorePoolSize, getKeepAliveTime, getLargestPoolSize, getMaximumPoolSize, getPoolSize, getQueue, getRejectedExecutionHandler, getTaskCount, getThreadFactory, isShutdown, isTerminated, isTerminating, prestartAllCoreThreads, prestartCoreThread, purge, remove, setCorePoolSize, setKeepAliveTime, setMaximumPoolSize, setRejectedExecutionHandler, setThreadFactory, shutdown, shutdownNow, terminated, toString

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, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

ThreadManagerThreadPoolExecutor

public ThreadManagerThreadPoolExecutor(int corePoolSize,
                               int maximumPoolSize,
                               long keepAliveTime,
                               TimeUnit unit,
                               BlockingQueue<Runnable> workQueue)

ThreadManagerThreadPoolExecutor

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

ThreadManagerThreadPoolExecutor

public ThreadManagerThreadPoolExecutor(int corePoolSize,
                               int maximumPoolSize,
                               long keepAliveTime,
                               TimeUnit unit,
                               BlockingQueue<Runnable> workQueue,
                               RejectedExecutionHandler handler)

ThreadManagerThreadPoolExecutor

public ThreadManagerThreadPoolExecutor(int corePoolSize,
                               int maximumPoolSize,
                               long keepAliveTime,
                               TimeUnit unit,
                               BlockingQueue<Runnable> workQueue,
                               ThreadFactory threadFactory,
                               RejectedExecutionHandler handler)

Method Detail

getThreadDecorator

public ThreadDecorator getThreadDecorator()

Description copied from interface: ThreadManager

Gets the ThreadDecorator associated with this manager.

Specified by:

getThreadDecorator in interface ThreadManager

Returns:

the ThreadDecorator, or null if there is none.

setThreadDecorator

public void setThreadDecorator(ThreadDecorator decorator)

Description copied from interface: ThreadManager

Sets the ThreadDecorator associated this manager should use.

Specified by:

setThreadDecorator in interface ThreadManager

Parameters:

decorator - the ThreadDecorator, or null.

afterExecute

protected void afterExecute(Runnable r,
                Throwable t)

Invokes ThreadDecorator.threadReleased(Thread) on the current thread.

Overrides:

afterExecute in class ThreadPoolExecutor