java如何使用ConcurrentHashMap和計數器實現鎖？下面是由本站小編爲大家整理的java使用ConcurrentHashMap和計數器實現鎖的方法，喜歡的可以收藏一下！瞭解更多詳情資訊，請關注應屆畢業生考試網！
java 使用ConcurrentHashMap和計數器實現鎖
在某些場景下,我們想讓線程根據某些業務數據進行排隊,簡單代碼如下：
import yList;
import Map;
import ;
import ;
import urrentHashMap;import icInteger;public class TestServiceImpl {private static ConcurrentHashMap<Long, LockObj> lockMap = new ConcurrentHashMap<Long, LockObj>(40);public void test(Long userId){LockObj lock = tryLock(userId);
synchronized (lock) {
try{
//處理業務
}
finally{
unLock(lock);
}
}
}
private LockObj tryLock(Long key) {
LockObj curVal = new LockObj(key);
LockObj preVal = fAbsent(key, curVal);if (null == preVal) {();
return curVal;
}
else{
();
}
return preVal;
}
private void unLock(LockObj lock){
if (() <= 0){
ve(ey());
}
}
public class LockObj {
private long key = 0;
private AtomicInteger count = new AtomicInteger(0);public LockObj(long key){ = key;
}
public int inc(){
return ementAndGet();
}
public int dec(){
return ementAndGet();
}
public long getKey(){
return key;
}
@Override
public String toString() {
return "LockObj [key=" + key + ", count=" + count + "]";}
}
}
按照userId來排隊,如果每個線程處理數據後不釋放鎖的`話，那麼可以不利用計數器。但是加了釋放鎖的操作，則必須加上計算器。因爲當線程把鎖釋放掉後，還沒來得及退出synchronized 代碼塊時，另外一個線程調用了tryLock方法，那該線程將拿到另外一個對象的鎖，導致利用synchronized 關鍵字進行userId排隊失敗。
也可以利用guava的API來實現。
import rner;import rners;public class TestServiceImpl {Interner<String> pool = eakInterner();public void test(Long userId) throws OspException {synchronized ( rn(eOf(userId))){//處理業務操作}
}
}
