Commit 6a794915 by huangfusuper

调整redis锁代码结构

parent baaf705a
...@@ -47,14 +47,13 @@ public class DaemonScanThreadRunHelperRedisLock extends BaseDaemonScanThreadRunH ...@@ -47,14 +47,13 @@ public class DaemonScanThreadRunHelperRedisLock extends BaseDaemonScanThreadRunH
dateAligned(CYCLE_INTERVAL,threadName); dateAligned(CYCLE_INTERVAL,threadName);
//调用业务操作 //调用业务操作
sleepTime = examplesValue.start(); sleepTime = examplesValue.start();
RedissLockUtil.unlock(lockName);
} }
}catch (Exception e) { }catch (Exception e) {
RedissLockUtil.unlock(lockName);
if(!THREAD_GROUP_STOP){ if(!THREAD_GROUP_STOP){
log.error("---------{}---------",e.getMessage()); log.error("---------{}---------",e.getMessage());
} }
}finally {
RedissLockUtil.unlock(lockName);
log.debug("------------{},解锁成功,锁名称为{}----------",threadName,lockName);
} }
sleepTime = sleepTime==null?examplesValue.UNIVERSAL_WAIT_TIME:sleepTime; sleepTime = sleepTime==null?examplesValue.UNIVERSAL_WAIT_TIME:sleepTime;
dateAligned(sleepTime,threadName); dateAligned(sleepTime,threadName);
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment