moliparty/peko-java
4
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

线程池-云信发批量房间消息-缩短单线程循环数

Browse Source
This commit is contained in:
khalil
2025-05-15 01:04:52 +08:00
parent df2975f3b1
commit e1a2d07a29
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
accompany-business/accompany-business-service/src/main/java/com/accompany/business/service/SendSysMsgService.java
View File

@@ -568,7 +568,7 @@ public class SendSysMsgService extends BaseService {
}
validRooms.add(0, curRoom);
List<List<Room>> validRoomPartitionList = Lists.partition(validRooms, 20);
List<List<Room>> validRoomPartitionList = Lists.partition(validRooms, 10);
for (List<Room> vaildRoomList: validRoomPartitionList) {
asyncExecutor.execute(() -> {
for (Room room : vaildRoomList) {
@@ -591,7 +591,7 @@ public class SendSysMsgService extends BaseService {
return;
}
List<List<Room>> validRoomPartitionList = Lists.partition(validRooms, 20);
List<List<Room>> validRoomPartitionList = Lists.partition(validRooms, 10);
for (List<Room> vaildRoomList: validRoomPartitionList) {
asyncExecutor.execute(() -> {
for (Room room : vaildRoomList) {
@@ -614,7 +614,7 @@ public class SendSysMsgService extends BaseService {
return;
}
List<List<Room>> validRoomPartitionList = Lists.partition(validRooms, 20);
List<List<Room>> validRoomPartitionList = Lists.partition(validRooms, 10);
for (List<Room> vaildRoomList: validRoomPartitionList) {
asyncExecutor.execute(() -> {
for (Room room : vaildRoomList) {