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

update - 测试分布式锁

Browse Source
This commit is contained in:
wangli 2024-07-01 20:55:30 +08:00
parent 278d4d989d
commit 439a2ceac5
1 changed files with 5 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
workflow-engine-core/src/main/java/cn/axzo/workflow/core/engine/interceptor/CustomLockProcessInstanceInterceptor.java
View File

@ -45,7 +45,7 @@ public class CustomLockProcessInstanceInterceptor extends AbstractCommandInterce
}
@Override
public <T> T execute(CommandConfig config, Command<T> command, CommandExecutor commandExecutor) {
public final <T> T execute(CommandConfig config, Command<T> command, CommandExecutor commandExecutor) {
if (AbstractCommand.class.isAssignableFrom(command.getClass())) {
AbstractCommand abstractCommand = (AbstractCommand) command;
String token = null;
@ -143,6 +143,10 @@ public class CustomLockProcessInstanceInterceptor extends AbstractCommandInterce
ReturnType.INTEGER, 1, keysAndArgs);
if (result != null && result > 0)
return true;
} catch (Exception e) {
log.warn("unlock error: {}", e.getMessage(), e);
// unlock(name, token);
return false;
} finally {
RedisConnectionUtils.releaseConnection(conn, factory);
}