package com.dy.common.mw.core;

import java.util.ArrayList;
import java.util.List;

import org.apache.logging.log4j.*;

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

	private List<CoreConstantTimer> coreConstantTimers ;

	private Long coreInterval = 100L ;//核心线程暂停间隔

	private CoreConstantManage(){
		coreConstantTimers = new ArrayList<>() ;
	}
	
	public static CoreConstantManage getInstance(){
		return instance ;
	}
	
	/**
	 * 设置暂停时长
	 * @param coreInterval 核心线程暂停间隔
	 */
	public void setSleep(Long coreInterval){
		this.coreInterval = coreInterval ;
	}

	public void start(){
		//恒久任务
		List<CoreTask> constantTasks = CoreUnit.getAllConstantTasks();
		if (constantTasks != null && constantTasks.size() > 0) {
			for (CoreTask task : constantTasks) {
				//new CoreConstantThread(sleepBigBusy, sleepSmallBusy, task).start();
				coreConstantTimers.add(new CoreConstantTimer(coreInterval, task).start());
			}
		}
	}

}