From 8a1a4c1c6d84beb02b9e01eaba407d5d9a529847 Mon Sep 17 00:00:00 2001 From: wangli <274027703@qq.com> Date: Fri, 24 May 2024 16:07:36 +0800 Subject: [PATCH] =?UTF-8?q?update(REQ-2324)=20-=20=E5=BC=80=E5=90=AF=20Flo?= =?UTF-8?q?wable=20=E5=BC=82=E6=AD=A5=E4=BB=BB=E5=8A=A1=E7=9A=84=E5=85=A8?= =?UTF-8?q?=E5=B1=80=E9=94=81=EF=BC=8C=E9=81=BF=E5=85=8D=E5=9B=A0=E4=B8=BA?= =?UTF-8?q?=E7=AB=9E=E4=BA=89=E5=AF=BC=E8=87=B4=E4=BB=BB=E5=8A=A1=E8=A2=AB?= =?UTF-8?q?=E5=BC=82=E5=B8=B8=E9=94=81=E6=AD=BB=EF=BC=8C=E5=90=8E=E7=BB=AD?= =?UTF-8?q?=E5=86=8D=E6=8E=92=E6=9F=A5=E9=94=81=E6=AD=BB=E7=9A=84=E8=A7=A6?= =?UTF-8?q?=E5=8F=91=E6=9D=A1=E4=BB=B6?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../java/cn/axzo/workflow/core/conf/FlowableConfiguration.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/workflow-engine-core/src/main/java/cn/axzo/workflow/core/conf/FlowableConfiguration.java b/workflow-engine-core/src/main/java/cn/axzo/workflow/core/conf/FlowableConfiguration.java index a1d6c1d84..d0bf6139e 100644 --- a/workflow-engine-core/src/main/java/cn/axzo/workflow/core/conf/FlowableConfiguration.java +++ b/workflow-engine-core/src/main/java/cn/axzo/workflow/core/conf/FlowableConfiguration.java @@ -23,7 +23,6 @@ import org.springframework.context.annotation.Configuration; import org.springframework.data.redis.core.StringRedisTemplate; import java.time.Duration; - import java.util.List; import static org.flowable.common.engine.impl.AbstractEngineConfiguration.DB_SCHEMA_UPDATE_TRUE; @@ -68,6 +67,7 @@ public class FlowableConfiguration { configuration.setDefaultFailedJobWaitTime(30); configuration.setAsyncFailedJobWaitTime(30); configuration.getAsyncExecutorConfiguration().setAsyncJobLockTime(Duration.ofMinutes(5)); + configuration.getAsyncExecutorConfiguration().setGlobalAcquireLockEnabled(true); configuration.setAddDefaultExceptionHandler(false); configuration.setEnableVerboseExecutionTreeLogging(enableVerboseExecutionTreeLogging); configuration.setCustomAsyncRunnableExecutionExceptionHandlers(Lists.newArrayList(