Package tigase.util.processing
Class ProcessingThreads<E extends WorkerThread>
java.lang.Object
tigase.util.processing.ProcessingThreads<E>
Created: Apr 21, 2009 8:50:50 PM
- Author:
- Artur Hefczyc
-
Constructor Summary
ConstructorDescriptionProcessingThreads
(E worker, int numWorkerThreads, int maxQueueSize, String name) -
Method Summary
Modifier and TypeMethodDescriptionboolean
addItem
(XMPPProcessorIfc processor, Packet packet, XMPPResourceConnection conn) long
long
getName()
int
int
void
shutdown()
-
Constructor Details
-
ProcessingThreads
public ProcessingThreads(E worker, int numWorkerThreads, int maxQueueSize, String name) throws ClassNotFoundException, InstantiationException, IllegalAccessException
-
-
Method Details
-
addItem
-
getAverageProcessingTime
public long getAverageProcessingTime() -
getDroppedPackets
public long getDroppedPackets() -
getName
-
getTotalQueueSize
public int getTotalQueueSize() -
getTotalRuns
public int getTotalRuns() -
shutdown
public void shutdown()
-