Methods Summary |
---|
public void | addTask(Task task)Add an Task to be processed by this Pipeline
|
public boolean | expireKey(java.nio.channels.SelectionKey key)Invoked when the SelectorThread is about to expire a SelectionKey.
|
public int | getCurrentThreadCount()Return the number of active threads.
|
public int | getCurrentThreadsBusy()Return the curent number of threads that are currently processing
a task.
|
public int | getMaxSpareThreads()Return the number of maximum spare thread.
|
public int | getMaxThreads()Return the number of threads used by this pipeline.
|
public int | getMinSpareThreads()Return the number of minimum spare thread.
|
public java.lang.String | getName()Return the name of this Pipeline
|
public PipelineStatistic | getPipelineStatistic()Return the PipelineStatistic object used
to gather statistic;
|
public Task | getTask()Return a Task object available in the pipeline.
|
public int | getWaitingThread()Return the number of waiting threads.
|
public void | initPipeline()Init the Pipeline by initializing the required
WorkerThread . Default value is 10
|
public boolean | interruptThread(long threadId)Interrup the Thread using it thread id
|
public void | setMaxThreads(int maxThread)Set the maximum thread this pipeline can handle.
|
public void | setMinSpareThreads(int minSpareThreads)Set the number of minimum spare thread.
|
public void | setMinThreads(int minThread)Set the minimum thread this pipeline can handle.
|
public void | setName(java.lang.String name)Set the name of this Pipeline
|
public void | setPipelineStatistic(PipelineStatistic pipelineStatistic)Set the PipelineStatistic object used
to gather statistic;
|
public void | setPort(int port)Set the port this Pipeline is associated with.
|
public void | setPriority(int priority)Set the Thread priority used when creating new threads.
|
public void | setQueueSizeInBytes(int maxQueueSizeInBytesCount)Set the maximum pending connection this Pipeline
can handle.
|
public void | setThreadsIncrement(int processorThreadsIncrement)Set the number the Pipeline will use when increasing the
thread pool
|
public void | setThreadsTimeout(int processorThreadsTimeout)Set the timeout value a thread will use to times out the request.
|
public int | size()Returns the number of tasks in this Pipeline .
|
public void | startPipeline()Start the Pipeline
|
public void | stopPipeline()Stop the Pipeline
|