From 3d263960e8a9d2901ff23a5c1ddf430f850daf56 Mon Sep 17 00:00:00 2001 From: wangw <1594593906@qq.com> Date: Fri, 27 Dec 2024 16:52:46 +0800 Subject: [PATCH] =?UTF-8?q?=E8=A1=A5=E5=81=BF=E6=9C=BA=E5=88=B63?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../controller/DiscSpinningController.java | 11 +++++------ 1 file changed, 5 insertions(+), 6 deletions(-) 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); }