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 efe3f68..2584e8f 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 @@ -285,6 +285,7 @@ public class TaskInfoServiceImpl extends ServiceImpl i private void getString(Long pageNum,String fieName,String joint,Long basicId,Long newBasicId,Long tableId,HashMap map ) { String sql = " SELECT " + fieName + " FROM " + joint +" limit "+pageNum +",10000 "; + log.info(sql); Result>> tableValueResult = datasourceFeign.findTableValue(basicId, sql); List> tableValue = tableValueResult.getData(); for (List dataValues : tableValue) { 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 76436b2..5235a45 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 @@ -32,7 +32,7 @@ public class OptimizedPrioritizedThreadPool { // 创建固定大小的线程池 executor = new ThreadPoolExecutor( totalThreads, totalThreads, - 300, TimeUnit.SECONDS, + 300L, TimeUnit.SECONDS, new LinkedBlockingQueue() // 使用无界的阻塞队列 ); highPrioritySemaphore = new Semaphore(defaultHighThreads);