File	Doc	Category	Size	Date	Package
ThreadPoolExecutorPipeline.java	API Doc	Glassfish v2 API	11000	Fri May 04 22:37:06 BST 2007	com.sun.enterprise.web.connector.grizzly

ThreadPoolExecutorPipeline

• java.lang.Object

Fields Summary
private int	waitingThreads The number of thread waiting for a Task
private int	maxThreads The maximum number of Thread
private int	minThreads The minimum numbers of WorkerThread
private int	port The port used.
private int	threadCount The number of WorkerThread
private String	name The name of this Pipeline
private int	priority The Thread Priority
private boolean	isStarted Has the pipeline already started
private ThreadPoolExecutor	workerThreads ExecutorService wrapped by this pipeline.
private ArrayBlockingQueue	arrayBlockingQueue Connection queue
private int	maxQueueSizeInBytes Maximum pending connection before refusing requests.
private int	queueSizeInBytes maximum size of the connection queue, in bytes.
protected PipelineStatistic	pipelineStat The PipelineStatistic objects used when gathering statistics.

Constructors Summary

Methods Summary
public void	addTask(Task task) Add an object to this pipeline if (workerThreads.getQueue().size() > maxQueueSizeInBytes ){ task.cancelTask("Maximum Connections Reached: " + pipelineStat.getQueueSizeInBytes() + " -- Retry later", HtmlHelper.OK); task.getSelectorThread().returnTask(task); return; } workerThreads.execute((Runnable)task); if ( pipelineStat != null) { pipelineStat.gather(size()); }
public boolean	expireKey(java.nio.channels.SelectionKey key) Invoked when the SelectorThread is about to expire a SelectionKey. return true if the SelectorThread should expire the SelectionKey, false if not. return true;
public int	getCurrentThreadCount() Return the current number of threads used. return workerThreads.getPoolSize() ;
public int	getCurrentThreadsBusy() Return the curent number of threads that are currently processing a task. return workerThreads.getActiveCount();
public int	getMaxSpareThreads() Return the maximum spare thread. return getWaitingThread();
public int	getMaxThreads() Return the number of threads used by this pipeline. return maxThreads;
public int	getMinSpareThreads() Return the minimum spare thread. return 0;
public java.lang.String	getName() Return the name of this Pipeline return the name of this Pipeline return name+port;
public PipelineStatistic	getPipelineStatistic() Return the PipelineStatistic object used to gather statistic; return pipelineStat;
public int	getQueueSizeInBytes() Get the maximum pending connection this Pipeline can handle. return maxQueueSizeInBytes;
public Task	getTask() Return a Task object available in the pipeline. return null;
public int	getWaitingThread() Return the number of waiting threads. return workerThreads.getPoolSize() - workerThreads.getActiveCount();
public void	initPipeline() Init the Pipeline by initializing the required ThreadPoolExecutor. // ------------------------------------------------ Lifecycle ------------/ if (isStarted){ return; } isStarted = true; arrayBlockingQueue = new ArrayBlockingQueue<Runnable>(maxQueueSizeInBytes, true); workerThreads = new ThreadPoolExecutor( maxThreads, maxThreads, 0L, TimeUnit.MILLISECONDS, arrayBlockingQueue, new GrizzlyThreadFactory(name,port,priority), this);
public boolean	interruptThread(long threadID) Interrupt the Thread using it thread id return ((GrizzlyThreadFactory)workerThreads.getThreadFactory()) .interruptThread(threadID);
public void	rejectedExecution(java.lang.Runnable r, java.util.concurrent.ThreadPoolExecutor executor) When the maxQueueSizeInBytesConnection is reached, terminate Task Task task = (Task)r; task.cancelTask("Maximum Connections Reached -- Retry later", HtmlHelper.OK); task.getSelectorThread().returnTask(task);
public void	setMaxThreads(int maxThreads) Set the number of threads used by this pipeline. this.maxThreads = maxThreads;
public void	setMinSpareThreads(int minSpareThreads) Set the minimum space thread this Pipeline can handle.
public void	setMinThreads(int minThreads) Set the minimum thread this Pipeline will creates when initializing. param minThreads the minimum number of threads. this.minThreads = minThreads;
public void	setName(java.lang.String name) Set the name of this Pipeline this.name = name;
public void	setPipelineStatistic(PipelineStatistic pipelineStatistic) Set the PipelineStatistic object used to gather statistic; this.pipelineStat = pipelineStatistic;
public void	setPort(int port) Set the port used by this Pipeline param port the port used by this Pipeline this.port = port;
public void	setPriority(int priority) Set the thread priority of the Pipeline this.priority = priority;
public void	setQueueSizeInBytes(int maxQueueSizeInBytes) Set the maximum pending connection this Pipeline can handle. this.maxQueueSizeInBytes = maxQueueSizeInBytes; if ( pipelineStat != null ) pipelineStat.setQueueSizeInBytes(maxQueueSizeInBytes);
public void	setThreadsIncrement(int threadsIncrement) ; // Not Supported
public void	setThreadsTimeout(int threadsTimeout) ; // Not Supported
public int	size() Returns the number of tasks in this Pipeline. return Number of tasks in this Pipeline. return workerThreads.getQueue().size();
public void	startPipeline() Start the Pipeline if (isStarted){ return; } ; // Do nothing
public void	stopPipeline() Stop the Pipeline if (!isStarted){ return; } isStarted = false; workerThreads.shutdown();
public java.lang.String	toString() return "name: " + name + " maxThreads: " + maxThreads + " minThreads:" + minThreads;