黑灰名单2020.04.22_05

src/main/java/cn/quantgroup/qgblservice/service/impl/BlackGreyListServiceImpl.java

@@ -51,7 +51,8 @@ public class BlackGreyListServiceImpl implements IBlackGreyListService {
     @Autowired
     private UpdateBlackListOverdueDayParallel updateBlackListOverdueDayParallel;
 
-    private static int pageSize = 10000;
+    //private static int pageSize = 10000;
+    private static int pageSize = 5000;
 
     //private static Map<String, Integer> channelBlackListExpireConfigMap = new ConcurrentHashMap<>();
     /*@PostConstruct

src/main/java/cn/quantgroup/qgblservice/service/impl/BlackToGreyListParallel.java

@@ -43,7 +43,7 @@ public class BlackToGreyListParallel implements ParallelComputingProcess<BlackGr
     //并行处理框架
     private ParallelComputing<BlackGreyListResult, Set<String>> p = new ParallelComputing<BlackGreyListResult, Set<String>>("BlackToGreyListParallel");
 
-    private static int THREAD_COUNT = ConstantBlackGrey.PARAM.SYS_CPU_COUNT * 4;
+    private static int THREAD_COUNT = ConstantBlackGrey.PARAM.SYS_CPU_COUNT * 2;
 
     @Autowired
     private BlackGreyListMapper blackGreyListMapper;

src/main/java/cn/quantgroup/qgblservice/service/impl/UpdateBlackListOverdueDayParallel.java

@@ -44,7 +44,7 @@ public class UpdateBlackListOverdueDayParallel implements ParallelComputingProce
     //并行处理框架
     private ParallelComputing<BlackGreyListResult, Set<String>> p = new ParallelComputing<BlackGreyListResult, Set<String>>("UpdateBlackListOverdueDay");
 
-    private static int THREAD_COUNT = ConstantBlackGrey.PARAM.SYS_CPU_COUNT * 4;
+    private static int THREAD_COUNT = ConstantBlackGrey.PARAM.SYS_CPU_COUNT * 2;
 
     @Autowired
     private BlackGreyListMapper blackGreyListMapper;