From 1c06b5c81f4187f1e9b7f4e5aa96a563637c6c12 Mon Sep 17 00:00:00 2001
From: zc <zc@123>
Date: 星期一, 05 五月 2025 20:30:59 +0800
Subject: [PATCH] #

---
 src/main/java/com/zy/core/cache/MessageQueue.java |    4 ++++
 1 files changed, 4 insertions(+), 0 deletions(-)

diff --git a/src/main/java/com/zy/core/cache/MessageQueue.java b/src/main/java/com/zy/core/cache/MessageQueue.java
index 2659aa4..0c6cf02 100644
--- a/src/main/java/com/zy/core/cache/MessageQueue.java
+++ b/src/main/java/com/zy/core/cache/MessageQueue.java
@@ -95,6 +95,10 @@
             case Devp:
                 return DEVP_EXCHANGE.get(id).poll();
             case Led:
+                ConcurrentLinkedQueue<Task> task2 = LED_EXCHANGE.get(id);
+                if (task2 == null) {
+                    return null;
+                }
                 return LED_EXCHANGE.get(id).poll();
             default:
                 return null;

--
Gitblit v1.9.1