com.sun.grizzly.http
Class LinkedListPipeline

java.lang.Object
  extended by java.util.AbstractCollection<E>
      extended by java.util.AbstractList<E>
          extended by java.util.AbstractSequentialList<E>
              extended by java.util.LinkedList<Callable>
                  extended by com.sun.grizzly.DefaultPipeline
                      extended by com.sun.grizzly.http.LinkedListPipeline
All Implemented Interfaces:
Pipeline<Callable>, Serializable, Cloneable, Iterable<Callable>, Collection<Callable>, List<Callable>, Queue<Callable>

public class LinkedListPipeline
extends DefaultPipeline

Internal FIFO used by the Worker Threads to pass information between Task objects.

Author:
Jean-Francois Arcand
See Also:
Serialized Form

Field Summary
protected  PipelineStatistic pipelineStat
          The PipelineStatistic objects used when gathering statistics.
 
Fields inherited from class com.sun.grizzly.DefaultPipeline
initialByteBufferSize, isStarted, maxQueueSizeInBytes, maxThreads, minSpareThreads, minThreads, name, port, priority, threadCount, threadsIncrement, waitingThreads, workerThreads
 
Fields inherited from class java.util.AbstractList
modCount
 
Constructor Summary
LinkedListPipeline()
           
 
Method Summary
 PipelineStatistic getPipelineStatistic()
          Return the PipelineStatistic object used to gather statistic;
protected  void increaseWorkerThread(int increment, boolean startThread)
          Create new HttpWorkerThread.
 void setPipelineStatistic(PipelineStatistic pipelineStatistic)
          Set the PipelineStatistic object used to gather statistic;
 
Methods inherited from class com.sun.grizzly.DefaultPipeline
execute, expireKey, getByteBufferType, getCurrentThreadCount, getCurrentThreadsBusy, getInitialByteBufferSize, getMaxSpareThreads, getMaxThreads, getMinSpareThreads, getName, getQueueSizeInBytes, getTaskQueuedCount, getWaitingThread, initPipeline, interruptThread, isEmpty, setByteBufferType, setInitialByteBufferSize, setMaxThreads, setMinSpareThreads, setMinThreads, setName, setPort, setPriority, setQueueSizeInBytes, setThreadsIncrement, startPipeline, stopPipeline, toString, waitForIoTask
 
Methods inherited from class java.util.LinkedList
add, add, addAll, addAll, addFirst, addLast, clear, clone, contains, element, get, getFirst, getLast, indexOf, lastIndexOf, listIterator, offer, peek, poll, remove, remove, remove, removeFirst, removeLast, set, size, toArray, toArray
 
Methods inherited from class java.util.AbstractSequentialList
iterator
 
Methods inherited from class java.util.AbstractList
equals, hashCode, listIterator, removeRange, subList
 
Methods inherited from class java.util.AbstractCollection
containsAll, removeAll, retainAll
 
Methods inherited from class java.lang.Object
finalize, getClass, notify, notifyAll, wait, wait, wait
 
Methods inherited from interface com.sun.grizzly.Pipeline
size
 
Methods inherited from interface java.util.List
containsAll, equals, hashCode, iterator, listIterator, removeAll, retainAll, subList
 

Field Detail

pipelineStat

protected transient PipelineStatistic pipelineStat
The PipelineStatistic objects used when gathering statistics.

Constructor Detail

LinkedListPipeline

public LinkedListPipeline()
Method Detail

increaseWorkerThread

protected void increaseWorkerThread(int increment,
                                    boolean startThread)
Create new HttpWorkerThread. This method must be invoked from a synchronized block.

Overrides:
increaseWorkerThread in class DefaultPipeline
Parameters:
increment - - how many additional HttpWorkerThread objects to add
startThread - - should newly added HttpWorkerThread objects be started after creation?

setPipelineStatistic

public void setPipelineStatistic(PipelineStatistic pipelineStatistic)
Set the PipelineStatistic object used to gather statistic;


getPipelineStatistic

public PipelineStatistic getPipelineStatistic()
Return the PipelineStatistic object used to gather statistic;



Copyright © 2009 SUN Microsystems. All Rights Reserved.