常读

job-bytedance/src/main/java/cn/com/ctop/job/bytedance/changdu/service/impl/ChangduSeriesFeishuServiceImpl.java

@@ -13,11 +13,14 @@ import org.slf4j.LoggerFactory;
 import org.springframework.stereotype.Service;
 
 import java.util.List;
+import java.util.concurrent.ExecutorService;
+import java.util.concurrent.Executors;
 
 @Service
 public class ChangduSeriesFeishuServiceImpl implements IChangduSeriesFeishuService {
 
     private static final Logger log = LoggerFactory.getLogger(ChangduSeriesFeishuServiceImpl.class);
+    private static final ExecutorService PUSH_EXECUTOR = Executors.newFixedThreadPool(3);
 
     private final ChangduSeriesFeishuMapper changduSeriesFeishuMapper;
     private final ChangduSeriesFeishuClient changduSeriesFeishuClient;
@@ -53,8 +56,9 @@ public class ChangduSeriesFeishuServiceImpl implements IChangduSeriesFeishuServi
             log.info("changdu series feishu no pending data");
             return;
         }
+        log.info("changdu series feishu submitting {} cards to thread pool", candidates.size());
         for (ChangduSeriesCardCandidate candidate : candidates) {
-            sendSingleCard(candidate);
+            PUSH_EXECUTOR.submit(() -> sendSingleCard(candidate));
         }
     }