package com.dy.common.mw.core;

import java.util.List;

import org.apache.logging.log4j.*;

public class CoreConstantThread extends Thread{
	
	private final static Logger log = LogManager.getLogger(CoreConstantThread.class.getName()) ;
	
	private final static CoreConstantThread instance = new CoreConstantThread() ;

	@SuppressWarnings("unused")
	private static Long sleepBigBusy = 100L ;//大忙时（除了恒久任务，还是其他任务），核心线程暂停间隔
	private static Long sleepSmallBusy = 500L ;//小忙时（只有恒久任务，无其他任务），核心线程暂停间隔
	
	private CoreConstantThread(){
	}
	
	public static CoreConstantThread getInstance(){
		return instance ;
	}
	
	/**
	 * 设置暂停时长
	 * @param sleepBigBusy 大忙时（除了恒久任务，还是其他任务），核心线程暂停间隔
	 * @param sleepSmallBusy 小忙时（只有恒久任务，无其他任务），核心线程暂停间隔
	 */
	public void setSleep(Long sleepBigBusy, Long sleepSmallBusy){
		CoreConstantThread.sleepBigBusy = sleepBigBusy ;
		CoreConstantThread.sleepSmallBusy = sleepSmallBusy ;
	}

	/**
	 * 核心单线程，执行所有的单线程任务
	 */
	@Override
	@SuppressWarnings("InfiniteLoopStatement")
	public void run(){
		int count ;
		Integer temp ;
		while (true) {
			count = 0;
			try {
				//恒久任务
				List<CoreTask> constantTasks = CoreUnit.getAllConstantTasks();
				if (constantTasks != null && constantTasks.size() > 0) {
					for (CoreTask task : constantTasks) {
						temp = task.execute();
						if (temp != null) {
							count += temp;
						}
					}
				}
				if (count == 0) {
					//小暂停一下
					Thread.sleep(sleepSmallBusy);
				}
			} catch (Exception e) {
				log.error("核心线程发生异常" + (e.getMessage() == null ? "" : (":" + e.getMessage())), e);
			}
		}
	}
}