com.sun.grizzly.http
Class LinkedListPipeline
java.lang.Object
java.util.AbstractCollection<E>
java.util.AbstractList<E>
java.util.AbstractSequentialList<E>
java.util.LinkedList<Callable>
com.sun.grizzly.DefaultPipeline
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
Fields inherited from class com.sun.grizzly.DefaultPipeline |
initialByteBufferSize, isStarted, maxQueueSizeInBytes, maxThreads, minSpareThreads, minThreads, name, port, priority, threadCount, threadsIncrement, waitingThreads, workerThreads |
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 interface com.sun.grizzly.Pipeline |
size |
pipelineStat
protected transient PipelineStatistic pipelineStat
- The
PipelineStatistic
objects used when gathering statistics.
LinkedListPipeline
public LinkedListPipeline()
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 addstartThread
- - 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.