#

luxiaotao1123

2020-11-13 00e3e465859114706fa2f802a9b4d3dbbee17a36

 src/main/java/com/zy/core/ServerBootstrap.java

@@ -6,10 +6,7 @@
import com.zy.core.model.CrnSlave;
import com.zy.core.model.DevpSlave;
import com.zy.core.properties.SlaveProperties;
import com.zy.core.thread.BarcodeThread;
import com.zy.core.thread.CarThread;
import com.zy.core.thread.CrnThread;
import com.zy.core.thread.DevpThread;
import com.zy.core.thread.*;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.Async;
@@ -33,8 +30,9 @@

    @PostConstruct
    @Async
    public void init(){
    public void init() throws InterruptedException {
        log.info("核心控制层开始初始化...............................................");
        Thread.sleep(2000);
        // 初始化消息队列
        initMq();
        // 初始化下位机线程
@@ -75,8 +73,18 @@
        // 初始化堆垛机线程
        log.info("初始化堆垛机线程...................................................");
        for (CrnSlave crn : slaveProperties.getCrn()) {
            CrnThread crnThread = new CrnThread(crn);
            new Thread(crnThread).start();
            CrnThread crnThread = null;
            switch (crn.getId()) {
                case 1:
                    crnThread = new SiemensCrnThread(crn);
                    break;
                case 2:
                    crnThread = new MelsecCrnThread(crn);
                    break;
                default:
                    break;
            }
            new Thread((Runnable) crnThread).start();
            SlaveConnection.put(SlaveType.Crn, crn.getId(), crnThread);
        }