From f6eb68199c06378001d29cced7fbb3aa5d9b32a4 Mon Sep 17 00:00:00 2001 From: lanyuanxiaoyao Date: Sun, 4 Feb 2024 16:31:54 +0800 Subject: [PATCH] =?UTF-8?q?feat(queue):=20=E4=BF=AE=E5=A4=8Dqueue=E5=A4=87?= =?UTF-8?q?=E4=BB=BD=E6=96=87=E4=BB=B6=E5=90=8D=E9=94=99=E8=AF=AF=E5=AF=BC?= =?UTF-8?q?=E8=87=B4deque=E4=B9=9F=E5=AD=98=E5=9C=A8=E6=95=B0=E6=8D=AE?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../lanyuanxiaoyao/service/queue/configuration/Constants.java | 2 +- .../lanyuanxiaoyao/service/queue/service/AutoSaveService.java | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/service-queue/src/main/java/com/lanyuanxiaoyao/service/queue/configuration/Constants.java b/service-queue/src/main/java/com/lanyuanxiaoyao/service/queue/configuration/Constants.java index e7a382b..7b95446 100644 --- a/service-queue/src/main/java/com/lanyuanxiaoyao/service/queue/configuration/Constants.java +++ b/service-queue/src/main/java/com/lanyuanxiaoyao/service/queue/configuration/Constants.java @@ -18,7 +18,7 @@ public interface Constants { ConcurrentHashMap>> QUEUE_MAP = new ConcurrentHashMap<>(10); String DEQUE_SAVE_FILENAME = "save_data_deque"; - String QUEUE_SAVE_FILENAME = "save_data_deque"; + String QUEUE_SAVE_FILENAME = "save_data_queue"; TimeUnit TIMEOUT_UNIT = TimeUnit.SECONDS; long POLL_TIMEOUT = 1; diff --git a/service-queue/src/main/java/com/lanyuanxiaoyao/service/queue/service/AutoSaveService.java b/service-queue/src/main/java/com/lanyuanxiaoyao/service/queue/service/AutoSaveService.java index 7fe26f2..cb5cce1 100644 --- a/service-queue/src/main/java/com/lanyuanxiaoyao/service/queue/service/AutoSaveService.java +++ b/service-queue/src/main/java/com/lanyuanxiaoyao/service/queue/service/AutoSaveService.java @@ -48,7 +48,7 @@ public class AutoSaveService { } private void save(Map> o, String name) throws IOException { - if (o == null) { + if (o == null || o.isEmpty()) { return; } Map> map = new HashMap<>(o.size());