From bfb05c977dbf2edcb0ecdb6c34b6800b4c7d9386 Mon Sep 17 00:00:00 2001 From: cxh Date: Tue, 28 May 2024 13:55:02 +0800 Subject: [PATCH] =?UTF-8?q?update=20=E7=AE=80=E5=8C=96=E4=BB=A3=E7=A0=81?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../java/org/dromara/demo/controller/RedisLockController.java | 4 ++-- .../dromara/demo/controller/queue/BoundedQueueController.java | 2 +- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/ruoyi-modules/ruoyi-demo/src/main/java/org/dromara/demo/controller/RedisLockController.java b/ruoyi-modules/ruoyi-demo/src/main/java/org/dromara/demo/controller/RedisLockController.java index b7e096266..64fc21981 100644 --- a/ruoyi-modules/ruoyi-demo/src/main/java/org/dromara/demo/controller/RedisLockController.java +++ b/ruoyi-modules/ruoyi-demo/src/main/java/org/dromara/demo/controller/RedisLockController.java @@ -33,13 +33,13 @@ public class RedisLockController { @Lock4j(keys = {"#key"}) @GetMapping("/testLock4j") public R testLock4j(String key, String value) { - System.out.println("start:" + key + ",time:" + LocalTime.now().toString()); + System.out.println("start:" + key + ",time:" + LocalTime.now()); try { Thread.sleep(10000); } catch (InterruptedException e) { e.printStackTrace(); } - System.out.println("end :" + key + ",time:" + LocalTime.now().toString()); + System.out.println("end :" + key + ",time:" + LocalTime.now()); return R.ok("操作成功", value); } diff --git a/ruoyi-modules/ruoyi-demo/src/main/java/org/dromara/demo/controller/queue/BoundedQueueController.java b/ruoyi-modules/ruoyi-demo/src/main/java/org/dromara/demo/controller/queue/BoundedQueueController.java index 30ec27f7f..e08586fd7 100644 --- a/ruoyi-modules/ruoyi-demo/src/main/java/org/dromara/demo/controller/queue/BoundedQueueController.java +++ b/ruoyi-modules/ruoyi-demo/src/main/java/org/dromara/demo/controller/queue/BoundedQueueController.java @@ -49,7 +49,7 @@ public class BoundedQueueController { for (int i = 0; i < 11; i++) { String data = "data-" + i; boolean flag = QueueUtils.addBoundedQueueObject(queueName, data); - if (flag == false) { + if (!flag) { log.info("通道: {} , 发送数据: {} 失败, 通道已满", queueName, data); } else { log.info("通道: {} , 发送数据: {}", queueName, data);