From a77a5ebbe056a238fca5b803e17648b60c46d1e8 Mon Sep 17 00:00:00 2001 From: luxiaotao1123 <t1341870251@163.com> Date: 星期四, 10 九月 2020 09:48:21 +0800 Subject: [PATCH] # --- src/main/java/com/zy/core/cache/MessageQueue.java | 27 +++++++++++++++++++++++++-- 1 files changed, 25 insertions(+), 2 deletions(-) diff --git a/src/main/java/com/zy/core/cache/MessageQueue.java b/src/main/java/com/zy/core/cache/MessageQueue.java index f2c92ad..5f27eba 100644 --- a/src/main/java/com/zy/core/cache/MessageQueue.java +++ b/src/main/java/com/zy/core/cache/MessageQueue.java @@ -7,6 +7,7 @@ import java.util.Map; import java.util.concurrent.ConcurrentHashMap; import java.util.concurrent.ConcurrentLinkedQueue; +import java.util.concurrent.LinkedBlockingQueue; /** * 娑堟伅闃熷垪 @@ -21,7 +22,7 @@ // 鏉$爜鎵弿浠猰q浜ゆ崲鏈� private static final Map<Integer, ConcurrentLinkedQueue<Task>> BARCODE_EXCHANGE = new ConcurrentHashMap<>(); // Led鐏� mq浜ゆ崲鏈� - private static final Map<Integer, ConcurrentLinkedQueue<Task>> LED_EXCHANGE = new ConcurrentHashMap<>(); + private static final Map<Integer, LinkedBlockingQueue<Task>> LED_EXCHANGE = new ConcurrentHashMap<>(); // 纾呯Оmq浜ゆ崲鏈� private static final Map<Integer, ConcurrentLinkedQueue<Task>> SCALE_EXCHANGE = new ConcurrentHashMap<>(); @@ -40,7 +41,7 @@ BARCODE_EXCHANGE.put(slave.getId(), new ConcurrentLinkedQueue<>()); break; case Led: - LED_EXCHANGE.put(slave.getId(), new ConcurrentLinkedQueue<>()); + LED_EXCHANGE.put(slave.getId(), new LinkedBlockingQueue<>(1)); break; case Scale: SCALE_EXCHANGE.put(slave.getId(), new ConcurrentLinkedQueue<>()); @@ -112,4 +113,26 @@ } } + public static void clear(SlaveType type, Integer id){ + switch (type) { + case Crn: + CRN_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; + default: + break; + } + } + } -- Gitblit v1.9.1