wangli/workflow-engine
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Merge branch 'refs/heads/feature/REQ-2596' into feature/merge-all

Browse Source
This commit is contained in:
yangqicheng 2024-07-30 10:08:19 +08:00
commit 129465f705
1 changed files with 4 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
workflow-engine-core/src/main/java/cn/axzo/workflow/core/engine/job/AbstractExecuteWithLockJobHandler.java
View File

@ -1,5 +1,6 @@
package cn.axzo.workflow.core.engine.job;
import cn.axzo.framework.domain.ServiceException;
import cn.axzo.workflow.core.common.utils.SpringContextUtils;
import cn.axzo.workflow.core.repository.entity.ExtAxProperty;
import cn.axzo.workflow.core.service.ExtAxPropertyService;
@ -31,6 +32,9 @@ public abstract class AbstractExecuteWithLockJobHandler extends AbstractJobHandl
if (acquireLock(processInstanceId, jobId)) {
log.info("job acquire lock success,processInstanceId:{},jobId:{}", processInstanceId, jobId);
executeInternal(job, configuration, variableScope, commandContext);
} else {
log.error("get lock failed,processInstanceId:{},jobId:{}", processInstanceId, jobId);
throw new ServiceException("acquire lock failed");
}
} finally {
releaseLock(processInstanceId, jobId);