修改超时时间

ad-engine-commons/src/main/java/com/tzld/piaoquan/ad/engine/commons/score/ScorerPipeline.java

@@ -18,7 +18,7 @@ import java.util.concurrent.*;
 @Slf4j
 public class ScorerPipeline {
     public static final int corePoolSize = 128;
-    public static final int SCORE_TIME_OUT = 5000;
+    public static final int SCORE_TIME_OUT = 500;
     public static final Logger LOGGER = LoggerFactory.getLogger(ScorerPipeline.class);
     public static final ExecutorService executorService = Executors.newFixedThreadPool(corePoolSize);
 

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

@@ -112,7 +112,7 @@ public class PAIScorerV2 extends AbstractScorer {
         List<AdRankItem> merged = new ArrayList<>();
         for (Future<List<AdRankItem>> future : futures) {
             try {
-                merged.addAll(future.get(4000, TimeUnit.MILLISECONDS));
+                merged.addAll(future.get(400, TimeUnit.MILLISECONDS));
             } catch (Exception e) {
                 LOGGER.error("Execution error in batch", e);
             }