feat: 2.2.0

1. 滑动窗口关闭时向服务端同步所有数据
This commit is contained in:
byteblogs168 2023-08-22 10:38:46 +08:00
parent 3954c08361
commit d4e98a38ac

View File

@ -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);
}
}