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()); 
 | 
            } 
 | 
        } 
 | 
    } 
 | 
  
 | 
} 
 |