1 package net.javacoding.jspider.core.task.impl; 2 3 import net.javacoding.jspider.api.event.monitor.MonitorEvent; 4 import net.javacoding.jspider.api.event.monitor.SchedulerMonitorEvent; 5 import net.javacoding.jspider.core.dispatch.EventDispatcher; 6 import net.javacoding.jspider.core.task.Scheduler; 7 import net.javacoding.jspider.core.threading.MonitorThread; 8 9 12 public class SchedulerMonitorThread extends MonitorThread { 13 14 protected Scheduler scheduler; 15 16 public SchedulerMonitorThread ( Scheduler scheduler, EventDispatcher dispatcher, int interval ) { 17 super ( dispatcher, interval, "Job Scheduler"); 18 this.scheduler = scheduler; 19 start(); 20 } 21 22 public MonitorEvent doMonitorTask() { 23 return new SchedulerMonitorEvent ( scheduler.getJobCount(), scheduler.getSpiderJobCount(), scheduler.getThinkerJobCount(), scheduler.getJobsDone(), scheduler.getSpiderJobsDone(), scheduler.getThinkerJobsDone(), scheduler.getBlockedCount(), scheduler.getAssignedCount() ); 25 } 26 27 } 28 | Popular Tags |