gtsoft/gtsoft-snail-job-server
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects 1 Releases Wiki Activity

fix: 2.3.2

Browse Source 
1. 修复分布式锁释放锁问题
This commit is contained in:
byteblogs168 2023-11-16 14:34:28 +08:00
parent 41507d3e21
commit 6db370986a
2 changed files with 8 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
easy-retry-server/src/main/java/com/aizuda/easy/retry/server/support/lock/AbstractLockProvider.java
View File

@ -35,7 +35,7 @@ public abstract class AbstractLockProvider implements LockProvider {
try { try {
return doLockAfter(lockConfig); return doLockAfter(lockConfig);
} catch (Exception e) { } catch (Exception e) {
if (tryToCreateLockRecord) { if (!tryToCreateLockRecord) {
CacheLockRecord.remove(lockName); CacheLockRecord.remove(lockName);
} }

7
easy-retry-server/src/main/java/com/aizuda/easy/retry/server/support/schedule/AbstractSchedule.java
View File

@ -45,15 +45,20 @@ public abstract class AbstractSchedule implements Schedule {
LockConfig lockConfig = new LockConfig(LocalDateTime.now(), lockName, Duration.parse(lockAtMost), Duration.parse(lockAtLeast)); LockConfig lockConfig = new LockConfig(LocalDateTime.now(), lockName, Duration.parse(lockAtMost), Duration.parse(lockAtLeast));
LockProvider lockProvider = getLockAccess(); LockProvider lockProvider = getLockAccess();
boolean lock = false;
try { try {
if (lockProvider.lock(lockConfig)) { lock = lockProvider.lock(lockConfig);
if (lock) {
doExecute(); doExecute();
} }
} catch (Exception e) { } catch (Exception e) {
LogUtils.error(log, this.getClass().getName() + " execute error. lockName:[{}]", lockName, e); LogUtils.error(log, this.getClass().getName() + " execute error. lockName:[{}]", lockName, e);
} finally { } finally {
if (lock) {
lockProvider.unlock(lockConfig); lockProvider.unlock(lockConfig);
} }
}
} }