异步线程池调试

miniapp/src/main/java/com/kym/miniapp/MiniAppApplication.java

@@ -6,6 +6,7 @@ import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
 import org.springframework.boot.autoconfigure.jdbc.DataSourceAutoConfiguration;
 import org.springframework.cache.annotation.EnableCaching;
+import org.springframework.scheduling.annotation.EnableAsync;
 
 
 /**
@@ -13,6 +14,7 @@ import org.springframework.cache.annotation.EnableCaching;
  *
  * @author skyline
  */
+@EnableAsync
 @SpringBootApplication(scanBasePackages = {"com.kym"}, exclude = DataSourceAutoConfiguration.class)
 //@ComponentScan(basePackages = {"com.kym"},excludeFilters = @ComponentScan.Filter(type = FilterType.REGEX, pattern = "com.kym.admin.*"))
 @MapperScan(basePackages = {"com.kym.mapper"})

service/src/main/java/com/kym/service/admin/impl/ActivityServiceImpl.java

@@ -158,10 +158,10 @@ public class ActivityServiceImpl extends ServiceImpl<ActivityMapper, Activity> i
      * @param rechargeAmount
      */
     @Override
-    @Async("AsyncExecutor")
+    @Async
     public void handleRechargeActivity(long userId, int rechargeAmount) {
-//        asyncHandleRechargeActivity(userId,rechargeAmount);
-        executor.execute(new RechargeActivityTask(userId, rechargeAmount));
+        asyncHandleRechargeActivity(userId,rechargeAmount);
+//        executor.execute(new RechargeActivityTask(userId, rechargeAmount));
     }
 
     @Transactional(rollbackFor = Exception.class)