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 15cdb00fa..c3309ab37 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 { * 滑动窗口关闭 */ public void end() { - ConcurrentLinkedQueue list = saveData.get(LocalDateTime.now()); - if (CollectionUtils.isEmpty(list)) { - return; - } - for (Listener listener : listeners) { - listener.handler(new ArrayList<>(list)); + for (final LocalDateTime windowPeriod : saveData.keySet()) { + doHandlerListener(windowPeriod); } }