修改为并行打分

ad-engine-service/src/main/java/com/tzld/piaoquan/ad/engine/service/score/VlogAdCtrCalibrationScorer.java

@@ -23,7 +23,7 @@ public class VlogAdCtrCalibrationScorer extends BaseCalibrationScorer {
 
     private static final int LOCAL_TIME_OUT = 150;
     private final static Logger LOGGER = LoggerFactory.getLogger(VlogAdCtrCalibrationScorer.class);
-    private static final ExecutorService executorService = Executors.newFixedThreadPool(512);
+    private static final ExecutorService executorService = Executors.newFixedThreadPool(8);
 
     public VlogAdCtrCalibrationScorer(ScorerConfigInfo configInfo) {
         super(configInfo);

ad-engine-service/src/main/java/com/tzld/piaoquan/ad/engine/service/score/VlogAdCtrLRScorer.java

@@ -29,7 +29,7 @@ public class VlogAdCtrLRScorer extends BaseLRModelScorer {
 
     private static final int LOCAL_TIME_OUT = 150000;
     private final static Logger LOGGER = LoggerFactory.getLogger(VlogAdCtrLRScorer.class);
-    private static final ExecutorService executorService = Executors.newFixedThreadPool(512);
+    private static final ExecutorService executorService = Executors.newFixedThreadPool(8);
     private static final double defaultUserCtrGroupNumber = 10.0;
     private static final int enterFeedsScoreRatio = 10;
     private static final int enterFeedsScoreNum = 20;

ad-engine-service/src/main/java/com/tzld/piaoquan/ad/engine/service/score/VlogAdCvrCalibrationScorer.java

@@ -23,7 +23,7 @@ public class VlogAdCvrCalibrationScorer extends BaseCalibrationScorer {
 
     private static final int LOCAL_TIME_OUT = 150;
     private final static Logger LOGGER = LoggerFactory.getLogger(VlogAdCvrCalibrationScorer.class);
-    private static final ExecutorService executorService = Executors.newFixedThreadPool(512);
+    private static final ExecutorService executorService = Executors.newFixedThreadPool(8);
 
     public VlogAdCvrCalibrationScorer(ScorerConfigInfo configInfo) {
         super(configInfo);

ad-engine-service/src/main/java/com/tzld/piaoquan/ad/engine/service/score/VlogAdCvrLRScorer.java

@@ -26,7 +26,7 @@ public class VlogAdCvrLRScorer extends BaseLRModelScorer {
 
     private static final int LOCAL_TIME_OUT = 150;
     private final static Logger LOGGER = LoggerFactory.getLogger(VlogAdCvrLRScorer.class);
-    private static final ExecutorService executorService = Executors.newFixedThreadPool(512);
+    private static final ExecutorService executorService = Executors.newFixedThreadPool(8);
     private static final double defaultUserCtrGroupNumber = 10.0;
     private static final int enterFeedsScoreRatio = 10;
     private static final int enterFeedsScoreNum = 20;

ad-engine-service/src/main/java/com/tzld/piaoquan/ad/engine/service/score/VlogAdThompsonScorer.java

@@ -25,7 +25,7 @@ public class VlogAdThompsonScorer extends BaseThompsonSamplingScorer {
 
     private static final int LOCAL_TIME_OUT = 150;
     private final static Logger LOGGER = LoggerFactory.getLogger(VlogAdThompsonScorer.class);
-    private static final ExecutorService executorService = Executors.newFixedThreadPool(512);
+    private static final ExecutorService executorService = Executors.newFixedThreadPool(8);
 
     public VlogAdThompsonScorer(ScorerConfigInfo configInfo) {
         super(configInfo);

ad-engine-service/src/main/java/com/tzld/piaoquan/ad/engine/service/score/VlogMergeEcpmScorer.java

@@ -23,7 +23,7 @@ import java.util.concurrent.*;
 public class VlogMergeEcpmScorer extends BaseLRModelScorer {
 
     private final static Logger LOGGER = LoggerFactory.getLogger(VlogMergeEcpmScorer.class);
-    private static final ExecutorService executorService = Executors.newFixedThreadPool(512);
+    private static final ExecutorService executorService = Executors.newFixedThreadPool(8);
     private static final int LOCAL_TIME_OUT = 150;
     public VlogMergeEcpmScorer(ScorerConfigInfo configInfo) {
         super(configInfo);