package com.zy.asrs.task.core; 
 | 
  
 | 
import com.zy.asrs.task.handler.WorkLogHandler; 
 | 
import com.zy.asrs.task.handler.WorkMastHandler; 
 | 
import com.zy.system.service.ConfigService; 
 | 
import org.slf4j.Logger; 
 | 
import org.slf4j.LoggerFactory; 
 | 
import org.springframework.beans.factory.annotation.Autowired; 
 | 
  
 | 
import javax.annotation.PostConstruct; 
 | 
import javax.annotation.PreDestroy; 
 | 
  
 | 
/** 
 | 
 * 单线程模式  ( 已弃用 ) 
 | 
 * 任务中心调度器 
 | 
 * Created by vincent on 2020/7/4 
 | 
 */ 
 | 
//@Component 
 | 
@Deprecated 
 | 
public class WcsDispatcher { 
 | 
  
 | 
    private static final Logger log = LoggerFactory.getLogger(WcsDispatcher.class); 
 | 
    private Thread thread; 
 | 
  
 | 
    @Autowired 
 | 
    private WorkMastHandler workMastHandler; 
 | 
    @Autowired 
 | 
    private WorkLogHandler workLogHandler; 
 | 
    @Autowired 
 | 
    private ConfigService configService; 
 | 
  
 | 
    @PostConstruct 
 | 
    private void start(){ 
 | 
        thread = new Thread(() -> { 
 | 
            while (!Thread.currentThread().isInterrupted()) { 
 | 
                try { 
 | 
                    Thread.sleep(3000); 
 | 
  
 | 
//                    workMastHandler.start(); 
 | 
// 
 | 
//                    workLogHandler.start(); 
 | 
  
 | 
                } catch (Exception e) { 
 | 
                    log.error("Exception", e); 
 | 
                } 
 | 
            } 
 | 
        }); 
 | 
        thread.start(); 
 | 
        log.info("任务中心调度器已启动......"); 
 | 
    } 
 | 
  
 | 
    @PreDestroy 
 | 
    public void shutDown(){ 
 | 
        if (thread != null) 
 | 
            thread.interrupt(); 
 | 
        log.info("任务中心调度器已停止......"); 
 | 
    } 
 | 
  
 | 
} 
 |