listenWx fix

long-article-recommend-service/src/main/java/com/tzld/longarticle/recommend/server/common/ThreadPoolFactory.java

@@ -15,7 +15,7 @@ public final class ThreadPoolFactory {
             32,
             256,
             0L, TimeUnit.SECONDS,
-            new LinkedBlockingQueue<>(20000),
+            new LinkedBlockingQueue<>(200000),
             new ThreadFactoryBuilder().setNameFormat("DEFAULT-%d").build(),
             new ThreadPoolExecutor.AbortPolicy());
     public final static ExecutorService RECALL = new CommonThreadPoolExecutor(

long-article-recommend-service/src/main/java/com/tzld/longarticle/recommend/server/service/WXListenService.java

@@ -22,13 +22,19 @@ public class WXListenService {
         ThreadPoolFactory.defaultPool().submit(() -> {
             Long start = System.currentTimeMillis();
             userManagementService.listenWx(xmlData);
-            log.info("listenWx userManagementService cost: {} ms", System.currentTimeMillis() - start);
+            Long end = System.currentTimeMillis();
+            if (end - start > 100) {
+                log.warn("listenWx userManagementService cost: {} ms", end - start);
+            }
         });
 
         ThreadPoolFactory.defaultPool().submit(() -> {
             Long start = System.currentTimeMillis();
             messageSendCallbackService.listenWx(xmlData);
-            log.info("listenWx messageSendCallbackService cost: {} ms", System.currentTimeMillis() - start);
+            Long end = System.currentTimeMillis();
+            if (end - start > 100) {
+                log.warn("listenWx messageSendCallbackService cost: {} ms", end - start);
+            }
         });
 
     }