IScheduleProcessor.java 583 Bytes
package com.taobao.pamirs.schedule.taskmanager;

interface IScheduleProcessor {
	 /**
	  * 是否已经处理完内存中所有的数据,在进行队列切换的时候,
	  * 必须保证所有内存的数据处理完毕
	  * @return
	  */
	 public boolean isDealFinishAllData();
	 /**
	  * 判断进程是否处于休眠状态
	  * @return
	  */
	 public boolean isSleeping();
	 /**
	  * 停止任务处理器
	  * @throws Exception
	  */
	 public void stopSchedule() throws Exception;
	 
	 /**
	  * 清除所有已经取到内存中的数据,在心跳线程失败的时候调用,避免数据重复
	  */
	 public void clearAllHasFetchData();
}