From 040976de6f9934b99f30268a28e2ecf42260e217 Mon Sep 17 00:00:00 2001
From: yangys <y_ys79@sina.com>
Date: 星期六, 18 五月 2024 22:13:01 +0800
Subject: [PATCH] 注释整理

---
 smart-man-boot/src/main/java/com/qianwen/smartman/common/utils/DelayList.java |    9 ++++-----
 1 files changed, 4 insertions(+), 5 deletions(-)

diff --git a/smart-man-boot/src/main/java/com/qianwen/smartman/common/utils/DelayList.java b/smart-man-boot/src/main/java/com/qianwen/smartman/common/utils/DelayList.java
index 64793f6..a049876 100644
--- a/smart-man-boot/src/main/java/com/qianwen/smartman/common/utils/DelayList.java
+++ b/smart-man-boot/src/main/java/com/qianwen/smartman/common/utils/DelayList.java
@@ -11,7 +11,6 @@
 import java.util.function.Consumer;
 import com.qianwen.smartman.common.constant.DateConstant;
 
-/* loaded from: blade-api.jar:BOOT-INF/classes/org/springblade/common/utils/DelayList.class */
 public class DelayList<T> {
     private final int maxWait;
     private final int maxLen;
@@ -36,7 +35,7 @@
             return true;
         }
         if (o instanceof DelayList) {
-            DelayList<?> other = (DelayList) o;
+            DelayList<?> other = (DelayList<?>) o;
             if (other.canEqual(this) && getMaxWait() == other.getMaxWait() && getMaxLen() == other.getMaxLen()) {
                 Object this$queue = getQueue();
                 Object other$queue = other.getQueue();
@@ -105,13 +104,13 @@
     }
 
     public DelayList(int maxWait) {
-        this.queue = new ArrayBlockingQueue(100000, true);
+        this.queue = new ArrayBlockingQueue<>(100000, true);
         this.maxWait = maxWait;
         this.maxLen = 1000;
     }
 
     public DelayList(int maxWait, int maxLen) {
-        this.queue = new ArrayBlockingQueue(100000, true);
+        this.queue = new ArrayBlockingQueue<>(100000, true);
         this.maxWait = maxWait;
         this.maxLen = maxLen;
     }
@@ -125,7 +124,7 @@
         if (this.timer == null) {
             System.out.println("鍒涘缓娑堣垂绾跨▼");
             this.timer = new Thread(() -> {
-                ArrayList arrayList = new ArrayList();
+                ArrayList<T> arrayList = new ArrayList<>();
                 Queues.drainUninterruptibly(this.queue, arrayList, this.maxLen, this.maxWait, TimeUnit.SECONDS);
                 if (arrayList.size() != 0) {
                     consumer.accept(arrayList);

--
Gitblit v1.9.3