Package org.jgroups.util

Class ThreadManagerThreadPoolExecutor

java.lang.Object

java.util.concurrent.AbstractExecutorService

java.util.concurrent.ThreadPoolExecutor

org.jgroups.util.ThreadManagerThreadPoolExecutor

All Implemented Interfaces:

ThreadManager

public class ThreadManagerThreadPoolExecutor
extends java.util.concurrent.ThreadPoolExecutor
implements ThreadManager

ThreadPoolExecutor subclass that implements @{link ThreadManager}.

Version:

$Id: ThreadManagerThreadPoolExecutor.java,v 1.1.2.1 2008/05/26 09:14:39 belaban Exp $

Author:

Brian Stansberry

Nested Class Summary

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

java.util.concurrent.ThreadPoolExecutor.AbortPolicy, java.util.concurrent.ThreadPoolExecutor.CallerRunsPolicy, java.util.concurrent.ThreadPoolExecutor.DiscardOldestPolicy, java.util.concurrent.ThreadPoolExecutor.DiscardPolicy

Constructor Summary

Constructors

Constructor	Description
ThreadManagerThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, java.util.concurrent.TimeUnit unit, java.util.concurrent.BlockingQueue<java.lang.Runnable> workQueue)
ThreadManagerThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, java.util.concurrent.TimeUnit unit, java.util.concurrent.BlockingQueue<java.lang.Runnable> workQueue, java.util.concurrent.RejectedExecutionHandler handler)
ThreadManagerThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, java.util.concurrent.TimeUnit unit, java.util.concurrent.BlockingQueue<java.lang.Runnable> workQueue, java.util.concurrent.ThreadFactory threadFactory)
ThreadManagerThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, java.util.concurrent.TimeUnit unit, java.util.concurrent.BlockingQueue<java.lang.Runnable> workQueue, java.util.concurrent.ThreadFactory threadFactory, java.util.concurrent.RejectedExecutionHandler handler)

Method Summary

Modifier and Type	Method	Description
protected void	afterExecute(java.lang.Runnable r, java.lang.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.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

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

Constructor Detail

ThreadManagerThreadPoolExecutor

public ThreadManagerThreadPoolExecutor(int corePoolSize,
                                       int maximumPoolSize,
                                       long keepAliveTime,
                                       java.util.concurrent.TimeUnit unit,
                                       java.util.concurrent.BlockingQueue<java.lang.Runnable> workQueue)

ThreadManagerThreadPoolExecutor

public ThreadManagerThreadPoolExecutor(int corePoolSize,
                                       int maximumPoolSize,
                                       long keepAliveTime,
                                       java.util.concurrent.TimeUnit unit,
                                       java.util.concurrent.BlockingQueue<java.lang.Runnable> workQueue,
                                       java.util.concurrent.ThreadFactory threadFactory)

ThreadManagerThreadPoolExecutor

public ThreadManagerThreadPoolExecutor(int corePoolSize,
                                       int maximumPoolSize,
                                       long keepAliveTime,
                                       java.util.concurrent.TimeUnit unit,
                                       java.util.concurrent.BlockingQueue<java.lang.Runnable> workQueue,
                                       java.util.concurrent.RejectedExecutionHandler handler)

ThreadManagerThreadPoolExecutor

public ThreadManagerThreadPoolExecutor(int corePoolSize,
                                       int maximumPoolSize,
                                       long keepAliveTime,
                                       java.util.concurrent.TimeUnit unit,
                                       java.util.concurrent.BlockingQueue<java.lang.Runnable> workQueue,
                                       java.util.concurrent.ThreadFactory threadFactory,
                                       java.util.concurrent.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(java.lang.Runnable r,
                            java.lang.Throwable t)

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

Overrides:

afterExecute in class java.util.concurrent.ThreadPoolExecutor