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(