钉钉考勤
This commit is contained in:
@@ -124,7 +124,7 @@ public class AttendanceServiceImpl implements AttendanceService {
|
|||||||
ConcurrentLinkedDeque<String> statusList = new ConcurrentLinkedDeque<>();
|
ConcurrentLinkedDeque<String> statusList = new ConcurrentLinkedDeque<>();
|
||||||
RateLimiter rateLimiter = RateLimiter.create(15.0); // 每秒15次
|
RateLimiter rateLimiter = RateLimiter.create(15.0); // 每秒15次
|
||||||
|
|
||||||
weekList.parallelStream().forEach(week -> {
|
weekList.parallelStream().forEachOrdered(week -> {
|
||||||
rateLimiter.acquire(); // 阻塞直到获取令牌(保证限流)
|
rateLimiter.acquire(); // 阻塞直到获取令牌(保证限流)
|
||||||
statusList.add(
|
statusList.add(
|
||||||
dingService.getAttendanceStatus(
|
dingService.getAttendanceStatus(
|
||||||
|
|||||||
Reference in New Issue
Block a user