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