🎨 指定 TaskExecutor Bean 名称

src/main/java/com/rymcu/forest/handler/AccountHandler.java

@@ -23,7 +23,7 @@ public class AccountHandler {
     @Resource
     private UserMapper userMapper;
 
-    @Async
+    @Async("accountThreadPool")
     @EventListener
     public void processAccountLastOnlineTimeEvent(AccountEvent accountEvent) {
         userMapper.updateLastOnlineTimeByAccount(accountEvent.getAccount());

src/main/java/com/rymcu/forest/handler/ArticleHandler.java

@@ -26,7 +26,7 @@ public class ArticleHandler {
     private LuceneService luceneService;
 
     @EventListener
-    @Async
+    @Async("articlePostThreadPool")
     public void processArticlePostEvent(ArticleEvent articleEvent) throws InterruptedException {
         Thread.sleep(1000);
         log.info(String.format("执行文章发布相关事件：[%s]", JSON.toJSONString(articleEvent)));
@@ -56,7 +56,7 @@ public class ArticleHandler {
     }
 
     @EventListener
-    @Async
+    @Async("articleDeleteThreadPool")
     public void processArticleDeleteEvent(ArticleDeleteEvent articleDeleteEvent) throws InterruptedException {
         Thread.sleep(1000);
         log.info(String.format("执行文章删除相关事件：[%s]", JSON.toJSONString(articleDeleteEvent)));

src/main/java/com/rymcu/forest/handler/CommentHandler.java

@@ -29,7 +29,7 @@ public class CommentHandler {
     @Resource
     private CommentMapper commentMapper;
 
-    @Async
+    @Async("commentThreadPool")
     @EventListener
     public void processCommentCreatedEvent(CommentEvent commentEvent) throws InterruptedException {
         log.info(String.format("开始执行评论发布事件：[%s]", JSON.toJSONString(commentEvent)));