From 87f00d0a2de9c22a56de6abd28806261adf38c10 Mon Sep 17 00:00:00 2001 From: Junjie <fallin.jie@qq.com> Date: 星期一, 27 三月 2023 08:01:59 +0800 Subject: [PATCH] 算法优化等 --- src/main/java/com/zy/core/ServerBootstrap.java | 23 +++++++++++++++++++---- 1 files changed, 19 insertions(+), 4 deletions(-) diff --git a/src/main/java/com/zy/core/ServerBootstrap.java b/src/main/java/com/zy/core/ServerBootstrap.java index 151df14..024304c 100644 --- a/src/main/java/com/zy/core/ServerBootstrap.java +++ b/src/main/java/com/zy/core/ServerBootstrap.java @@ -3,10 +3,7 @@ import com.zy.core.cache.MessageQueue; import com.zy.core.cache.SlaveConnection; import com.zy.core.enums.SlaveType; -import com.zy.core.model.CrnSlave; -import com.zy.core.model.DevpSlave; -import com.zy.core.model.LedSlave; -import com.zy.core.model.SteSlave; +import com.zy.core.model.*; import com.zy.core.properties.SlaveProperties; import com.zy.core.thread.*; import lombok.extern.slf4j.Slf4j; @@ -73,6 +70,10 @@ for (Slave ste : slaveProperties.getSte()) { MessageQueue.init(SlaveType.Ste, ste); } + // 鍒濆鍖栧洓鍚戠┛姊溅mq + for (Slave shuttle : slaveProperties.getShuttle()) { + MessageQueue.init(SlaveType.Shuttle, shuttle); + } } private void initThread(){ @@ -97,6 +98,20 @@ new Thread((Runnable) devpThread).start(); SlaveConnection.put(SlaveType.Devp, devp.getId(), devpThread); } + // 鍒濆鍖栨彁鍗囨満 + News.info("鍒濆鍖栨彁鍗囨満........................................................"); + for (LiftSlave liftSlave : slaveProperties.getLift()) { + LiftThread liftThread = new LiftThread(liftSlave); + new Thread(liftThread).start(); + SlaveConnection.put(SlaveType.Lift, liftSlave.getId(), liftThread); + } + // 鍒濆鍖栧洓鍚戠┛姊溅 + News.info("鍒濆鍖栧洓鍚戠┛姊溅......................................................"); + for (ShuttleSlave shuttleSlave : slaveProperties.getShuttle()) { + ShuttleThread shuttleThread = new ShuttleThread(shuttleSlave); + new Thread(shuttleThread).start(); + SlaveConnection.put(SlaveType.Shuttle, shuttleSlave.getId(), shuttleThread); + } // 鍒濆鍖栨潯鐮佹壂鎻忎华绾跨▼ News.info("鍒濆鍖栨潯鐮佹壂鎻忎华绾跨▼..................................................."); for (Slave barcode : slaveProperties.getBarcode()) { -- Gitblit v1.9.1