| java.lang.Object java.lang.Thread org.apache.jetspeed.aggregator.impl.WorkerImpl
WorkerImpl | public class WorkerImpl extends Thread implements Worker(Code) | | Worker thread processes jobs and notify its WorkerMonitor when completed.
When no work is available, the worker simply sets itself in a waiting mode
pending reactivation by the WorkerMonitor
author: Raphael Luta author: Woonsan Ko version: $Id: WorkerImpl.java 587064 2007-10-22 11:54:11Z woonsan $ |
Field Summary | |
final protected static Log | log |
log | final protected static Log log(Code) | | Commons logging
|
getJobCount | public int getJobCount()(Code) | | Return the number of jobs processed by this worker since the last time it
has been on the idle queue
|
resetJobCount | public void resetJobCount()(Code) | | Reset the processed job counter
|
run | public void run()(Code) | | Process the job assigned, then notify Monitor. If no job available,
go into sleep mode
|
setRunning | public void setRunning(boolean status)(Code) | | Sets the running status of this Worker. If set to false, the Worker will
stop after processing its current job.
|
|
|