| | |
| | | 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; |
| | |
| | | |
| | | 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(){ |
| | | private void start() { |
| | | thread = new Thread(() -> { |
| | | while (!Thread.currentThread().isInterrupted()) { |
| | | try { |
| | |
| | | } |
| | | |
| | | @PreDestroy |
| | | public void shutDown(){ |
| | | public void shutDown() { |
| | | if (thread != null) |
| | | thread.interrupt(); |
| | | log.info("任务中心调度器已停止......"); |