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