1
0
Pārlūkot izejas kodu

feat:邮件解析-异步化对外解析接口

mozuwen 7 mēneši atpakaļ
vecāks
revīzija
7a52e6780a

+ 1 - 1
service-base/src/main/java/com/simuwang/base/config/ThreadPoolConfig.java

@@ -36,7 +36,7 @@ public class ThreadPoolConfig {
     public ThreadPoolTaskExecutor asyncExecutor() {
         ThreadPoolTaskExecutor taskExecutor = new ThreadPoolTaskExecutor();
         taskExecutor.setCorePoolSize(2);
-        taskExecutor.setMaxPoolSize(50);
+        taskExecutor.setMaxPoolSize(5);
         taskExecutor.setQueueCapacity(50);
         taskExecutor.setKeepAliveSeconds(60);
         taskExecutor.setThreadNamePrefix("asyncExecutor--");

+ 1 - 1
service-daq/src/main/java/com/simuwang/daq/service/EmailParseApiServiceImpl.java

@@ -54,7 +54,7 @@ public class EmailParseApiServiceImpl implements EmailParseApiService {
 
     @Override
     public void parseEmail(MailboxInfoDTO mailboxInfoDTO, Date startDate, Date endDate) {
-        emailParseService.parseEmail(mailboxInfoDTO, startDate, endDate);
+        asyncExecutor.execute(() -> emailParseService.parseEmail(mailboxInfoDTO, startDate, endDate));
     }
 
     @Override