优化代码

java110-core/src/main/java/com/java110/core/factory/Java110ThreadPoolFactory.java

@@ -33,7 +33,7 @@ import java.util.concurrent.Future;
  **/
 public class Java110ThreadPoolFactory<T> {
 
-    public static final int JAVA110_DEFAULT_THREAD_NUM = 200;
+    public static final int JAVA110_DEFAULT_THREAD_NUM = 5;
     private Vector<Future<T>> futureList = null;
     ExecutorService executor = null;
 

service-api/src/main/java/com/java110/api/listener/fee/SaveRoomCreateFeeListener.java

@@ -7,6 +7,7 @@ import com.java110.api.listener.AbstractServiceApiListener;
 import com.java110.core.annotation.Java110Listener;
 import com.java110.core.context.DataFlowContext;
 import com.java110.core.event.service.api.ServiceDataFlowEvent;
+import com.java110.core.factory.Java110ThreadPoolFactory;
 import com.java110.dto.RoomDto;
 import com.java110.dto.fee.FeeAttrDto;
 import com.java110.dto.fee.FeeConfigDto;

service-fee/src/main/java/com/java110/fee/bmo/impl/QueryOweFeeImpl.java

@@ -184,7 +184,7 @@ public class QueryOweFeeImpl implements IQueryOweFee {
         //查询费用信息arrearsEndTime
         List<RoomDto> tmpRoomDtos = new ArrayList<>();
         List<RoomDto> tempRooms = new ArrayList<>();
-        int threadNum = 20;
+        int threadNum = Java110ThreadPoolFactory.JAVA110_DEFAULT_THREAD_NUM;
         for (int roomIndex = 0; roomIndex < roomDtos.size(); roomIndex++) {
             tempRooms.add(roomDtos.get(roomIndex));
             if (roomIndex % threadNum == 0 && roomIndex != 0) {