ソースを参照

异步线程池

zuy 2 年 前
コミット
29127e23a5

+ 2 - 2
service/src/main/java/com/kym/service/admin/impl/ActivityServiceImpl.java

@@ -159,8 +159,8 @@ public class ActivityServiceImpl extends ServiceImpl<ActivityMapper, Activity> i
     @Override
     @Async("AsyncExecutor")
     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)