测试线程池

cloud-task-server/src/main/java/com/muyu/service/impl/TaskServiceImpl.java

@@ -203,7 +203,7 @@ public class TaskServiceImpl extends ServiceImpl<TaskMapper, TaskInfo> 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);

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<Runnable>()
         );
         highPrioritySemaphore = new Semaphore(defaultHighThreads);