
Public Member Functions | |
| synchronized void | cancelScheduledWorkUnits () |
| int | currentQueueSize () |
| synchronized ERWorkUnit | dispatchWorkUnit () |
| ERLocalWorkerChannel (int numberOfThreads, int queueSize) | |
| void | resumeWorkers () |
| synchronized ERResultUnit | scheduleWorkUnit (ERWorkUnit workUnit) |
| synchronized void | shutdownWorkers () |
| void | startWorkers () |
| void | suspendWorkers () |
Static Public Attributes | |
| static final ERXLogger | log = ERXLogger.getERXLogger(ERLocalWorkerChannel.class) |
Private Member Functions | |
| void | _initalizeWorkUnitQueue () |
Private Attributes | |
| int | _count |
| int | _head |
| boolean | _isSuspended |
| final int | _queueSize |
| int | _tail |
| final ERWorkerThread[] | _threadPool |
| ERWorkUnit[] | _workUnitQueue |
| ERLocalWorkerChannel | ( | int | numberOfThreads, | |
| int | queueSize | |||
| ) |
| void _initalizeWorkUnitQueue | ( | ) | [private] |
| synchronized void cancelScheduledWorkUnits | ( | ) |
Implements ERWorkerChannel.
| int currentQueueSize | ( | ) |
Implements ERWorkerChannel.
| synchronized ERWorkUnit dispatchWorkUnit | ( | ) |
Implements ERWorkerChannel.
| void resumeWorkers | ( | ) |
Implements ERWorkerChannel.
| synchronized ERResultUnit scheduleWorkUnit | ( | ERWorkUnit | workUnit | ) |
Implements ERWorkerChannel.
| synchronized void shutdownWorkers | ( | ) |
Implements ERWorkerChannel.
| void startWorkers | ( | ) |
Implements ERWorkerChannel.
| void suspendWorkers | ( | ) |
Implements ERWorkerChannel.
int _count [private] |
int _head [private] |
boolean _isSuspended [private] |
final int _queueSize [private] |
int _tail [private] |
final ERWorkerThread [] _threadPool [private] |
ERWorkUnit [] _workUnitQueue [private] |
1.5.8