From 2f9849905dbb8d65faa28628a40084708a0386ef Mon Sep 17 00:00:00 2001
From: Junjie <DELL@qq.com>
Date: 星期四, 25 十二月 2025 10:58:34 +0800
Subject: [PATCH] #
---
src/main/java/com/zy/core/cache/MessageQueue.java | 14 ++++++++++++++
1 files changed, 14 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 fe3638b..48d96cd 100644
--- a/src/main/java/com/zy/core/cache/MessageQueue.java
+++ b/src/main/java/com/zy/core/cache/MessageQueue.java
@@ -16,6 +16,8 @@
// 鍫嗗灈鏈簃q浜ゆ崲鏈�
private static final Map<Integer, LinkedBlockingQueue<Task>> CRN_EXCHANGE = new ConcurrentHashMap<>();
+ // 鍙屽伐浣嶅爢鍨涙満mq浜ゆ崲鏈�
+ private static final Map<Integer, LinkedBlockingQueue<Task>> DUAL_CRN_EXCHANGE = new ConcurrentHashMap<>();
// 杈撻�佺嚎mq浜ゆ崲鏈�
private static final Map<Integer, ConcurrentLinkedQueue<Task>> DEVP_EXCHANGE = new ConcurrentHashMap<>();
// 鏉＄爜鎵弿浠猰q浜ゆ崲鏈�
@@ -34,6 +36,9 @@
switch (type) {
case Crn:
CRN_EXCHANGE.put(id, new LinkedBlockingQueue<>(1));
+ break;
+ case DualCrn:
+ DUAL_CRN_EXCHANGE.put(id, new LinkedBlockingQueue<>(1));
break;
case Rgv:
RGV_EXCHANGE.put(id, new LinkedBlockingQueue<>(1));
@@ -63,6 +68,8 @@
switch (type) {
case Crn:
return CRN_EXCHANGE.get(id).offer(task);
+ case DualCrn:
+ return DUAL_CRN_EXCHANGE.get(id).offer(task);
case Rgv:
return RGV_EXCHANGE.get(id).offer(task);
case Devp:
@@ -86,6 +93,8 @@
switch (type) {
case Crn:
return CRN_EXCHANGE.get(id).poll();
+ case DualCrn:
+ return DUAL_CRN_EXCHANGE.get(id).poll();
case Rgv:
return RGV_EXCHANGE.get(id).poll();
case Devp:
@@ -108,6 +117,8 @@
switch (type) {
case Crn:
return CRN_EXCHANGE.get(id).peek();
+ case DualCrn:
+ return DUAL_CRN_EXCHANGE.get(id).peek();
case Rgv:
return RGV_EXCHANGE.get(id).peek();
case Devp:
@@ -128,6 +139,9 @@
case Crn:
CRN_EXCHANGE.get(id).clear();
break;
+ case DualCrn:
+ DUAL_CRN_EXCHANGE.get(id).clear();
+ break;
case Rgv:
RGV_EXCHANGE.get(id).clear();
break;
--
Gitblit v1.9.1