补偿机制3

src/main/java/com/sqx/modules/discSpinning/controller/DiscSpinningController.java

@@ -47,7 +47,8 @@ public class DiscSpinningController {
     private final TaskCenterRecordService taskRecordService;
     private final UserService userService;
     private final RedisUtils redisUtils;
-    ScheduledExecutorService executor = Executors.newScheduledThreadPool(5);
+    ScheduledExecutorService executor = Executors.newScheduledThreadPool(10);
+
     @Autowired
     public DiscSpinningController(CommonInfoService commonRepository, DiscSpinningService discSpinningService,
                                   OrdersService ordersService, DiscSpinningRecordService recordService,
@@ -221,11 +222,9 @@ public class DiscSpinningController {
             redisUtils.set(redisKey, week, DateUtils.todayAfterSecond());
         }
         DiscSpinningRecord draws = discSpinningService.draws(i == null ? 1 : i + 1, amount, sourceId, userId, source);
-        try {
+
-            executor.schedule(() -> receive1(draws), 4, TimeUnit.SECONDS);
+        executor.schedule(() -> receive1(draws), 4, TimeUnit.SECONDS);
-        }finally {
+
-            executor.shutdown();
-        }
         return new Result().put("data", draws);
     }