diff --git a/cloud-task-server/src/main/java/com/muyu/service/impl/TaskServiceImpl.java b/cloud-task-server/src/main/java/com/muyu/service/impl/TaskServiceImpl.java index c2d84f7..808809e 100644 --- a/cloud-task-server/src/main/java/com/muyu/service/impl/TaskServiceImpl.java +++ b/cloud-task-server/src/main/java/com/muyu/service/impl/TaskServiceImpl.java @@ -203,7 +203,7 @@ public class TaskServiceImpl extends ServiceImpl implement log.info("当前页为{}", i); int pageNum = i * pageSize; long finalFirstArray = Math.min(pageSize, count - pageNum); - String limit = " limit " + pageSize + " OFFSET " + pageNum; + String limit = " limit " + pageNum + "," + pageSize; String limitSelect = sql + limit; Long finalDatabaseId = databaseId; log.info("执行查询语句为{}", limitSelect); diff --git a/cloud-task-server/src/main/java/com/muyu/task/PriorityThreadPool.java b/cloud-task-server/src/main/java/com/muyu/task/PriorityThreadPool.java index da2a752..746dbc3 100644 --- a/cloud-task-server/src/main/java/com/muyu/task/PriorityThreadPool.java +++ b/cloud-task-server/src/main/java/com/muyu/task/PriorityThreadPool.java @@ -221,7 +221,7 @@ public class PriorityThreadPool { // 创建固定大小的线程池 executor = new ThreadPoolExecutor( totalThreads, totalThreads, - 30L, TimeUnit.SECONDS, + 40L, TimeUnit.SECONDS, new LinkedBlockingQueue() ); highPrioritySemaphore = new Semaphore(defaultHighThreads);