ad cost

ad-engine-commons/src/main/java/com/tzld/piaoquan/ad/engine/commons/thread/ThreadPoolFactory.java

@@ -18,6 +18,13 @@ public final class ThreadPoolFactory {
             new LinkedBlockingQueue<>(1000),
             new ThreadFactoryBuilder().setNameFormat("DEFAULT-%d").build(),
             new ThreadPoolExecutor.AbortPolicy());
+    private final static ExecutorService FEATURE = new CommonThreadPoolExecutor(
+            256,
+            256,
+            0L, TimeUnit.SECONDS,
+            new LinkedBlockingQueue<>(1000),
+            new ThreadFactoryBuilder().setNameFormat("Feature-%d").build(),
+            new ThreadPoolExecutor.AbortPolicy());
     public final static ExecutorService RECALL = new CommonThreadPoolExecutor(
             128,
             128,
@@ -30,6 +37,10 @@ public final class ThreadPoolFactory {
         return DEFAULT;
     }
 
+    public static ExecutorService feature() {
+        return FEATURE;
+    }
+
     public static ExecutorService recallPool() {
         return RECALL;
     }

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

@@ -147,9 +147,10 @@ public class RankStrategyXGBAutoUpdateModel688 extends RankStrategyXGBBasic {
             List<Future<AdRankItem>> futures = new ArrayList<>();
             CountDownLatch cdl1 = new CountDownLatch(request.getAdIdList().size());
             for (AdPlatformCreativeDTO dto : request.getAdIdList()) {
-                Future<AdRankItem> future = ThreadPoolFactory.defaultPool().submit(() -> {
+                Future<AdRankItem> future = ThreadPoolFactory.feature().submit(() -> {
                     AdRankItem adRankItem = new AdRankItem();
                     try {
+                        long time20 = System.currentTimeMillis();
                         adRankItem.setAdId(dto.getCreativeId());
                         adRankItem.setCreativeCode(dto.getCreativeCode());
                         adRankItem.setAdVerId(dto.getAdVerId());
@@ -183,10 +184,10 @@ public class RankStrategyXGBAutoUpdateModel688 extends RankStrategyXGBBasic {
                         this.handleD2Feature(vidRankMaps, cidFeatureMap, cidStr);
                         long time27 = System.currentTimeMillis();
 
-                        log.info("cost={}, handleB1Feature={}, handleB2ToB5AndB8ToB9Feature={}, " +
+                        log.info("cost={}, other={}, handleB1Feature={}, handleB2ToB5AndB8ToB9Feature={}, " +
                                         "handleB6ToB7Feature={}, " +
                                         "handleC1UIFeature={}, handleD1Feature={}, handleD2Feature={}",
-                                time27 - time21, time22 - time21,
+                                time27 - time20, time21 - time20,time22 - time21,
                                 time23 - time22, time24 - time23, time25 - time24, time26 - time25, time27 - time26);
                         return adRankItem;
                     } finally {