ctripcorp/zeus
1
1
Fork 0
mirror of https://github.com/ctripcorp/zeus.git synced 2024-11-11 18:08:25 +08:00
Code Issues Projects Releases Packages Wiki Activity

update lock

Browse source
This commit is contained in:
fanqq 2015-06-09 17:21:42 +08:00
parent b01c815f3b
commit e499c35af0
1 changed files with 5 additions and 7 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

12
src/main/java/com/ctrip/zeus/lock/impl/MysqlDistLock.java
View file

@ -9,6 +9,8 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.unidal.dal.jdbc.DalException;
import java.util.concurrent.atomic.AtomicBoolean;
/**
* Created by zhoumy on 2015/4/9.
*/
@ -17,14 +19,14 @@ public class MysqlDistLock implements DistLock {
private static final long SLEEP_INTERVAL = 500L;
private final String key;
private volatile boolean state;
private AtomicBoolean state;
private DistLockDao distLockDao;// = DbLockFactory.getDao();
private Logger logger = LoggerFactory.getLogger(this.getClass());
public MysqlDistLock(String key, DistLockDao distLockDao) {
this.key = key;
this.state = false;
this.state.set(false);
this.distLockDao = distLockDao;
}
@ -139,10 +141,6 @@ public class MysqlDistLock implements DistLock {
}
private final boolean compareAndSetState(boolean expected, boolean updated) {
if (state == expected) {
state = updated;
return true;
}
return false;
return state.compareAndSet(expected, updated);
}
}