From 6d11b7d4625b939e2b4d4a3e7053e2cb69f1b446 Mon Sep 17 00:00:00 2001 From: xuxueli <931591021@qq.com> Date: Sat, 6 Dec 2025 14:15:12 +0800 Subject: [PATCH] =?UTF-8?q?=E8=B0=83=E5=BA=A6=E7=BB=84=E4=BB=B6=E4=BA=8B?= =?UTF-8?q?=E5=8A=A1=E4=BB=A3=E7=A0=81=E4=BC=98=E5=8C=96=EF=BC=8C=E4=BF=AE?= =?UTF-8?q?=E5=A4=8DDB=E8=B6=85=E6=97=B6=E7=AD=89=E5=B0=8F=E6=A6=82?= =?UTF-8?q?=E7=8E=87=E6=83=85=E5=86=B5=E4=B8=8B=E8=B0=83=E5=BA=A6=E7=BB=88?= =?UTF-8?q?=E6=AD=A2=E9=97=AE=E9=A2=98=EF=BC=9B?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- doc/XXL-JOB官方文档.md | 3 ++- .../com/xxl/job/admin/scheduler/thread/JobScheduleHelper.java | 3 ++- 2 files changed, 4 insertions(+), 2 deletions(-) diff --git a/doc/XXL-JOB官方文档.md b/doc/XXL-JOB官方文档.md index 23fd6f47..42c15677 100644 --- a/doc/XXL-JOB官方文档.md +++ b/doc/XXL-JOB官方文档.md @@ -2698,7 +2698,8 @@ public void execute() { - b、本次升级针对客户端rollinglog依赖字段做规范约束,如不关注该功能 v2.4.* 及后续版本客户端不需要升级/可兼容,否则需要升级客户端版本; ### 7.42 版本 v3.3.1 Release Notes[ING] -- 1、【TODO】任务调度触发后分批批量更新,提升调度性能; +- 1、【修复】调度组件事务代码优化,修复DB超时等小概率情况下调度终止问题; +- 2、【TODO】任务调度触发后分批批量更新,提升调度性能; ### TODO LIST diff --git a/xxl-job-admin/src/main/java/com/xxl/job/admin/scheduler/thread/JobScheduleHelper.java b/xxl-job-admin/src/main/java/com/xxl/job/admin/scheduler/thread/JobScheduleHelper.java index de7df79c..e2c93eb6 100644 --- a/xxl-job-admin/src/main/java/com/xxl/job/admin/scheduler/thread/JobScheduleHelper.java +++ b/xxl-job-admin/src/main/java/com/xxl/job/admin/scheduler/thread/JobScheduleHelper.java @@ -63,8 +63,9 @@ public class JobScheduleHelper { boolean preReadSuc = true; // transaction start - TransactionStatus transactionStatus = XxlJobAdminBootstrap.getInstance().getTransactionManager().getTransaction(new DefaultTransactionDefinition()); + TransactionStatus transactionStatus = null; try { + transactionStatus = XxlJobAdminBootstrap.getInstance().getTransactionManager().getTransaction(new DefaultTransactionDefinition()); // 1、job lock String lockedRecord = XxlJobAdminBootstrap.getInstance().getXxlJobLockMapper().scheduleLock(); long nowTime = System.currentTimeMillis();