From e87212b095c646a2ee567ab0d419797177a2627a Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E5=BC=A0=E6=9D=BE?= <8605635+zhang3064194730@user.noreply.gitee.com> Date: Wed, 3 Dec 2025 10:52:07 +0800 Subject: [PATCH] =?UTF-8?q?=E9=92=89=E9=92=89=E8=80=83=E5=8B=A4?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../czg/service/market/service/impl/AttendanceServiceImpl.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/cash-service/market-service/src/main/java/com/czg/service/market/service/impl/AttendanceServiceImpl.java b/cash-service/market-service/src/main/java/com/czg/service/market/service/impl/AttendanceServiceImpl.java index b6f037bf4..827f00cd7 100644 --- a/cash-service/market-service/src/main/java/com/czg/service/market/service/impl/AttendanceServiceImpl.java +++ b/cash-service/market-service/src/main/java/com/czg/service/market/service/impl/AttendanceServiceImpl.java @@ -124,7 +124,7 @@ public class AttendanceServiceImpl implements AttendanceService { ConcurrentLinkedDeque statusList = new ConcurrentLinkedDeque<>(); RateLimiter rateLimiter = RateLimiter.create(15.0); // 每秒15次 - weekList.parallelStream().forEach(week -> { + weekList.parallelStream().forEachOrdered(week -> { rateLimiter.acquire(); // 阻塞直到获取令牌(保证限流) statusList.add( dingService.getAttendanceStatus(