| package com.zy.asrs.task.core; | 
|   | 
| 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 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("任务中心调度器已停止......"); | 
|     } | 
|   | 
| } |