From efb836ba619ec097c8e2ed07ad26a6512053f5c5 Mon Sep 17 00:00:00 2001 From: Cui YongXing <2835316714@qq.com> Date: Fri, 6 Sep 2024 00:12:41 +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 --- .../com/muyu/task/server/service/impl/TaskInfoServiceImpl.java | 2 +- .../muyu/task/server/thread/OptimizedPrioritizedThreadPool.java | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) 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 bd0d040..6055980 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 @@ -329,7 +329,7 @@ public class TaskInfoServiceImpl extends ServiceImpl i log.info("{}查询结束",sqlSelect); log.info("执行{}添加的方法",sqlSelect); Result result = datasourceFeign.addProduct(newBasicId, tableId, data); - log.info("{}添加结束",sqlSelect); + log.info("{}添加结束",result); // for (List dataValues : tableValue) { // for (DataValue dataValue : dataValues) { // String key = dataValue.getKey(); 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 19c1f8e..1cc018c 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 @@ -37,7 +37,7 @@ public class OptimizedPrioritizedThreadPool { // 创建固定大小的线程池 executor = new ThreadPoolExecutor( totalThreads, totalThreads, - 60L, TimeUnit.SECONDS, + 80L, TimeUnit.SECONDS, new LinkedBlockingQueue() ); highPrioritySemaphore = new Semaphore(defaultHighThreads);