From d4e98a38ac73e5c2b67bd553db957eea8b9caa2e Mon Sep 17 00:00:00 2001
From: byteblogs168 <598092184@qq.com>
Date: Tue, 22 Aug 2023 10:38:46 +0800
Subject: [PATCH] =?UTF-8?q?feat:=202.2.0=201.=20=E6=BB=91=E5=8A=A8?=
 =?UTF-8?q?=E7=AA=97=E5=8F=A3=E5=85=B3=E9=97=AD=E6=97=B6=E5=90=91=E6=9C=8D?=
 =?UTF-8?q?=E5=8A=A1=E7=AB=AF=E5=90=8C=E6=AD=A5=E6=89=80=E6=9C=89=E6=95=B0?=
 =?UTF-8?q?=E6=8D=AE?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../easy/retry/client/core/window/SlidingWindow.java      | 8 ++------
 1 file changed, 2 insertions(+), 6 deletions(-)

diff --git a/easy-retry-client-core/src/main/java/com/aizuda/easy/retry/client/core/window/SlidingWindow.java b/easy-retry-client-core/src/main/java/com/aizuda/easy/retry/client/core/window/SlidingWindow.java
index 15cdb00f..c3309ab3 100644
--- a/easy-retry-client-core/src/main/java/com/aizuda/easy/retry/client/core/window/SlidingWindow.java
+++ b/easy-retry-client-core/src/main/java/com/aizuda/easy/retry/client/core/window/SlidingWindow.java
@@ -301,12 +301,8 @@ public class SlidingWindow<T> {
      * 滑动窗口关闭
      */
     public void end() {
-        ConcurrentLinkedQueue<T> list = saveData.get(LocalDateTime.now());
-        if (CollectionUtils.isEmpty(list)) {
-            return;
-        }
-        for (Listener<T> listener : listeners) {
-            listener.handler(new ArrayList<>(list));
+        for (final LocalDateTime windowPeriod : saveData.keySet()) {
+            doHandlerListener(windowPeriod);
         }
     }