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