From 62107c34d3bb40649c6af1385a5f61d81104cf47 Mon Sep 17 00:00:00 2001
From: zhang <zc857179121@qq.com>
Date: 星期五, 10 四月 2026 12:56:51 +0800
Subject: [PATCH] 1

---
 zy-acs-cv/src/main/java/com/zy/core/cache/MessageQueue.java |   58 ++++++++++------------------------------------------------
 1 files changed, 10 insertions(+), 48 deletions(-)

diff --git a/zy-acs-cv/src/main/java/com/zy/core/cache/MessageQueue.java b/zy-acs-cv/src/main/java/com/zy/core/cache/MessageQueue.java
index 3f34d61..5692a21 100644
--- a/zy-acs-cv/src/main/java/com/zy/core/cache/MessageQueue.java
+++ b/zy-acs-cv/src/main/java/com/zy/core/cache/MessageQueue.java
@@ -35,27 +35,18 @@
      */
     public static void init(SlaveType type, Slave slave) {
         switch (type) {
-            case Crn:
-                CRN_EXCHANGE.put(slave.getId(), new LinkedBlockingQueue<>(1));
-                break;
-            case Rgv:
-                RGV_EXCHANGE.put(slave.getId(), new LinkedBlockingQueue<>(1));
-                break;
+
             case Devp:
                 DEVP_EXCHANGE.put(slave.getId(), new ConcurrentLinkedQueue<>());
                 break;
             case Barcode:
                 BARCODE_EXCHANGE.put(slave.getId(), new ConcurrentLinkedQueue<>());
                 break;
-            case Led:
-                LED_EXCHANGE.put(slave.getId(), new LinkedBlockingQueue<>(1));
-                break;
+
             case Scale:
                 SCALE_EXCHANGE.put(slave.getId(), new ConcurrentLinkedQueue<>());
                 break;
-            case Car:
-                CAR_EXCHANGE.put(slave.getId(), new ConcurrentLinkedQueue<>());
-                break;
+
             default:
                 break;
         }
@@ -67,20 +58,15 @@
      */
     public static boolean offer(SlaveType type, Integer id, Task task) {
         switch (type) {
-            case Crn:
-                return CRN_EXCHANGE.get(id).offer(task);
-            case Rgv:
-                return RGV_EXCHANGE.get(id).offer(task);
+
             case Devp:
                 return DEVP_EXCHANGE.get(id).offer(task);
             case Barcode:
                 return BARCODE_EXCHANGE.get(id).offer(task);
-            case Led:
-                return LED_EXCHANGE.get(id).offer(task);
+
             case Scale:
                 return SCALE_EXCHANGE.get(id).offer(task);
-            case Car:
-                return CAR_EXCHANGE.get(id).offer(task);
+
             default:
                 return false;
         }
@@ -92,20 +78,15 @@
      */
     public static Task poll(SlaveType type, Integer id) {
         switch (type) {
-            case Crn:
-                return CRN_EXCHANGE.get(id).poll();
-            case Rgv:
-                return RGV_EXCHANGE.get(id).poll();
+
             case Devp:
                 return DEVP_EXCHANGE.get(id).poll();
             case Barcode:
                 return BARCODE_EXCHANGE.get(id).poll();
-            case Led:
-                return LED_EXCHANGE.get(id).poll();
+
             case Scale:
                 return SCALE_EXCHANGE.get(id).poll();
-            case Car:
-                return CAR_EXCHANGE.get(id).poll();
+
             default:
                 return null;
         }
@@ -116,20 +97,12 @@
      */
     public static Task peek(SlaveType type, Integer id) {
         switch (type) {
-            case Crn:
-                return CRN_EXCHANGE.get(id).peek();
-            case Rgv:
-                return RGV_EXCHANGE.get(id).peek();
             case Devp:
                 return DEVP_EXCHANGE.get(id).peek();
             case Barcode:
                 return BARCODE_EXCHANGE.get(id).peek();
-            case Led:
-                return LED_EXCHANGE.get(id).peek();
             case Scale:
                 return SCALE_EXCHANGE.get(id).peek();
-            case Car:
-                return CAR_EXCHANGE.get(id).peek();
             default:
                 return null;
         }
@@ -137,27 +110,16 @@
 
     public static void clear(SlaveType type, Integer id) {
         switch (type) {
-            case Crn:
-                CRN_EXCHANGE.get(id).clear();
-                break;
-            case Rgv:
-                RGV_EXCHANGE.get(id).clear();
-                break;
             case Devp:
                 DEVP_EXCHANGE.get(id).clear();
                 break;
             case Barcode:
                 BARCODE_EXCHANGE.get(id).clear();
                 break;
-            case Led:
-                LED_EXCHANGE.get(id).clear();
-                break;
             case Scale:
                 SCALE_EXCHANGE.get(id).clear();
                 break;
-            case Car:
-                CAR_EXCHANGE.get(id).clear();
-                break;
+
             default:
                 break;
         }

--
Gitblit v1.9.1