From 2b6fe59649f708d666bedb96605fa54f53fbf1c0 Mon Sep 17 00:00:00 2001 From: yangqicheng Date: Mon, 19 Aug 2024 13:47:46 +0800 Subject: [PATCH] =?UTF-8?q?hotfix-=E4=BF=AE=E5=A4=8D=E7=BA=BF=E7=A8=8B?= =?UTF-8?q?=E7=9D=A1=E7=9C=A0api=E5=BC=95=E7=94=A8=E9=94=99=E8=AF=AF?= =?UTF-8?q?=E9=97=AE=E9=A2=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../core/engine/job/AbstractExecuteWithLockJobHandler.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/workflow-engine-core/src/main/java/cn/axzo/workflow/core/engine/job/AbstractExecuteWithLockJobHandler.java b/workflow-engine-core/src/main/java/cn/axzo/workflow/core/engine/job/AbstractExecuteWithLockJobHandler.java index 95f5834a6..a714d31d2 100644 --- a/workflow-engine-core/src/main/java/cn/axzo/workflow/core/engine/job/AbstractExecuteWithLockJobHandler.java +++ b/workflow-engine-core/src/main/java/cn/axzo/workflow/core/engine/job/AbstractExecuteWithLockJobHandler.java @@ -57,7 +57,7 @@ public abstract class AbstractExecuteWithLockJobHandler extends AbstractJobHandl //删除15分钟前的数据,相当于超时时间是15分钟 extAxPropertyService.deleteByNameWithDuration(processInstanceId, 15L, TimeUnit.MINUTES); //睡眠2秒 - ThreadUtils.objectWait(2 * 1000); + ThreadUtils.sleep(2 * 1000); acquireCount++; log.warn("acquireLock error,processInstanceId:{},jobId:{},acquireCount:{}", processInstanceId, jobId, acquireCount); }