From 0def068b03df63a0908ef00f68aa8579e325803d Mon Sep 17 00:00:00 2001 From: Cui YongXing <2835316714@qq.com> Date: Fri, 6 Sep 2024 11:46:11 +0800 Subject: [PATCH] =?UTF-8?q?=E5=AF=BB=E6=89=BE=E6=8A=A5=E9=94=99?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../main/java/com/muyu/remote/feign/DatasourceFeign.java | 2 ++ .../task/server/service/impl/TaskInfoServiceImpl.java | 2 +- .../server/thread/OptimizedPrioritizedThreadPool.java | 8 ++++---- 3 files changed, 7 insertions(+), 5 deletions(-) diff --git a/cloud-task-remote/src/main/java/com/muyu/remote/feign/DatasourceFeign.java b/cloud-task-remote/src/main/java/com/muyu/remote/feign/DatasourceFeign.java index ae7c2e5..7b3ef8c 100644 --- a/cloud-task-remote/src/main/java/com/muyu/remote/feign/DatasourceFeign.java +++ b/cloud-task-remote/src/main/java/com/muyu/remote/feign/DatasourceFeign.java @@ -32,6 +32,8 @@ public interface DatasourceFeign { public Result addProduct(@RequestParam("basicId") Long basicId, @RequestParam("tableId") Long tableId, @RequestBody List> listList); + + @PostMapping("/product/addProduct") public Result addProduct(@RequestParam("basicId") Long basicId, @RequestParam("tableId") Long tableId, diff --git a/cloud-task-server/src/main/java/com/muyu/task/server/service/impl/TaskInfoServiceImpl.java b/cloud-task-server/src/main/java/com/muyu/task/server/service/impl/TaskInfoServiceImpl.java index 0a83b33..a86b16f 100644 --- a/cloud-task-server/src/main/java/com/muyu/task/server/service/impl/TaskInfoServiceImpl.java +++ b/cloud-task-server/src/main/java/com/muyu/task/server/service/impl/TaskInfoServiceImpl.java @@ -42,7 +42,7 @@ import static com.muyu.task.server.thread.OptimizedPrioritizedThreadPool.*; @Service public class TaskInfoServiceImpl extends ServiceImpl implements TaskInfoService { - private final Integer PAGE_SIZE = 5000; + private final Integer PAGE_SIZE = 10000; @Resource private TaskInfoMapper taskInfoMapper; diff --git a/cloud-task-server/src/main/java/com/muyu/task/server/thread/OptimizedPrioritizedThreadPool.java b/cloud-task-server/src/main/java/com/muyu/task/server/thread/OptimizedPrioritizedThreadPool.java index ae57536..b30a730 100644 --- a/cloud-task-server/src/main/java/com/muyu/task/server/thread/OptimizedPrioritizedThreadPool.java +++ b/cloud-task-server/src/main/java/com/muyu/task/server/thread/OptimizedPrioritizedThreadPool.java @@ -11,10 +11,10 @@ public class OptimizedPrioritizedThreadPool { private static final Semaphore lowPrioritySemaphore; private static final Semaphore emergencySemaphore; - private static final int totalThreads =40; // 固定线程池大小 - private static final int defaultHighThreads = 22; - private static final int defaultMediumThreads = 12; - private static final int defaultLowThreads = 6; + private static final int totalThreads =50; // 固定线程池大小 + private static final int defaultHighThreads = 26; + private static final int defaultMediumThreads = 15; + private static final int defaultLowThreads = 9; private static final int emergencyThreads = 21; private static final int emergencyHighThreads = 10;