diff --git a/src/main/java/com/sqx/modules/discSpinning/controller/DiscSpinningController.java b/src/main/java/com/sqx/modules/discSpinning/controller/DiscSpinningController.java index d0f2892b..4813618c 100644 --- a/src/main/java/com/sqx/modules/discSpinning/controller/DiscSpinningController.java +++ b/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); - }finally { - executor.shutdown(); - } + + executor.schedule(() -> receive1(draws), 4, TimeUnit.SECONDS); + return new Result().put("data", draws); }