java使用ConcurrentHashMap和計數器實現鎖的方法

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))){//處理業務操作}

}

}