您好,登錄后才能下訂單哦!
ConcurrentHashMap如何在java項(xiàng)目中使用?相信很多沒有經(jīng)驗(yàn)的人對此束手無策,為此本文總結(jié)了問題出現(xiàn)的原因和解決方法,通過這篇文章希望你能解決這個(gè)問題。
java 使用ConcurrentHashMap
在某些場景下,我們想讓線程根據(jù)某些業(yè)務(wù)數(shù)據(jù)進(jìn)行排隊(duì),簡單代碼如下:
import java.util.ArrayList; import java.util.HashMap; import java.util.List; import java.util.Map; import java.util.concurrent.ConcurrentHashMap; import java.util.concurrent.atomic.AtomicInteger; 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{ //處理業(yè)務(wù) } finally{ unLock(lock); } } } private LockObj tryLock(Long key) { LockObj curVal = new LockObj(key); LockObj preVal = lockMap.putIfAbsent(key, curVal); if (null == preVal) { curVal.inc(); return curVal; } else{ preVal.inc(); } return preVal; } private void unLock(LockObj lock){ if (lock.dec() <= 0){ lockMap.remove(lock.getKey()); } } public class LockObj { private long key = 0; private AtomicInteger count = new AtomicInteger(0); public LockObj(long key){ this.key = key; } public int inc(){ return count.incrementAndGet(); } public int dec(){ return count.decrementAndGet(); } public long getKey(){ return key; } @Override public String toString() { return "LockObj [key=" + key + ", count=" + count + "]"; } } }
按照userId來排隊(duì),如果每個(gè)線程處理數(shù)據(jù)后不釋放鎖的話,那么可以不利用計(jì)數(shù)器。但是加了釋放鎖的操作,則必須加上計(jì)算器。因?yàn)楫?dāng)線程把鎖釋放掉后,還沒來得及退出synchronized 代碼塊時(shí),另外一個(gè)線程調(diào)用了tryLock方法,那該線程將拿到另外一個(gè)對象的鎖,導(dǎo)致利用synchronized 關(guān)鍵字進(jìn)行userId排隊(duì)失敗。
也可以利用guava的API來實(shí)現(xiàn)。
import com.google.common.collect.Interner; import com.google.common.collect.Interners; public class TestServiceImpl { Interner<String> pool = Interners.newWeakInterner(); public void test(Long userId) throws OspException { synchronized ( pool.intern(String.valueOf(userId))){ //處理業(yè)務(wù)操作 } } }
看完上述內(nèi)容,你們掌握ConcurrentHashMap如何在java項(xiàng)目中使用的方法了嗎?如果還想學(xué)到更多技能或想了解更多相關(guān)內(nèi)容,歡迎關(guān)注億速云行業(yè)資訊頻道,感謝各位的閱讀!
免責(zé)聲明:本站發(fā)布的內(nèi)容(圖片、視頻和文字)以原創(chuàng)、轉(zhuǎn)載和分享為主,文章觀點(diǎn)不代表本網(wǎng)站立場,如果涉及侵權(quán)請聯(lián)系站長郵箱:is@yisu.com進(jìn)行舉報(bào),并提供相關(guān)證據(jù),一經(jīng)查實(shí),將立刻刪除涉嫌侵權(quán)內(nèi)容。