黑灰名单2020.04.22_04

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

@@ -799,9 +799,9 @@ public class BlackGreyListServiceImpl implements IBlackGreyListService {
             }catch (Exception e){
                 e.printStackTrace();
                 log.error("查询结果表-黑名单列表异常, totalPage: {} , page: {} , startId: {} , endId: {} , 耗时: {} ", totalPage, page, startId, endId, (System.currentTimeMillis()-thisPageStart), e);
-            }finally {
+            }/*finally {
                 log.error("查询结果表-黑名单列表结束, totalPage: {} , page: {} , startId: {} , endId: {} , 大小: {} , 耗时: {} ", totalPage, page, startId, endId, tmpQueryList!=null?tmpQueryList.size():"null", (System.currentTimeMillis()-thisPageStart));
-            }
+            }*/
         }
 
         log.info("黑转灰-查询黑灰名单结果表结束, 查询大小: {} , type11大小: {} , list大小: {} , 总查询耗时: {} ", count_black, count_type_11, blackListResults!=null?blackListResults.size():"null", (System.currentTimeMillis()-startTime));
@@ -913,9 +913,9 @@ public class BlackGreyListServiceImpl implements IBlackGreyListService {
             }catch (Exception e){
                 e.printStackTrace();
                 log.error("查询结果表-黑名单列表异常, totalPage: {} , page: {} , startId: {} , endId: {} , 耗时: {} ", totalPage, page, startId, endId, (System.currentTimeMillis()-thisPageStart), e);
-            }finally {
+            }/*finally {
                 log.error("查询结果表-黑名单列表结束, totalPage: {} , page: {} , startId: {} , endId: {} , 大小: {} , 耗时: {} ", totalPage, page, startId, endId, tmpQueryList!=null?tmpQueryList.size():"null", (System.currentTimeMillis()-thisPageStart));
-            }
+            }*/
         }
 
         log.info("更新黑名单逾期天数-查询黑灰名单结果表结束, list大小: {} , 总查询耗时: {} ", blackListResults!=null?blackListResults.size():"null", (System.currentTimeMillis()-startTime));

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 * 2;
+    private static int THREAD_COUNT = ConstantBlackGrey.PARAM.SYS_CPU_COUNT * 4;
 
     @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 * 2;
+    private static int THREAD_COUNT = ConstantBlackGrey.PARAM.SYS_CPU_COUNT * 4;
 
     @Autowired
     private BlackGreyListMapper blackGreyListMapper;