java使用ConcurrentHashMap和计数器实现锁的方法

本文格式为Word版，下载可任意编辑——java使用ConcurrentHashMap和计数器实现锁的方法java使用ConcurrentHashMap和计数器实现锁的方法

java如何使用ConcurrentHashMap和计数器实现锁？下面是由我为大家整理的java使用ConcurrentHashMap和计数器实现锁的方法，热爱的可以珍藏一下！了解更多详情资讯，请关注我！

java使用ConcurrentHashMap和计数器实现锁

在某些场景下,我们想让线程根据某些业务数据举行排队,简朴代码如下：

importjava.util.ArrayList;

importjava.util.HashMap;

importjava.util.List;

importjava.util.Map;

importjava.util.concurrent.ConcurrentHashMap;importjava.util.concurrent.atomic.AtomicInteger;publicclassTestServiceImplprivatestaticConcurrentHashMapLong,LockObjlockMap=newConcurrentHashMapLong,LockObj40;publicvoidtestLonguserIdLockObjlock=tryLockuserId;

synchronizedlock

try

//处理业务

finally

unLocklock;

privateLockObjtryLockLongkey

LockObjcurVal=newLockObjkey;

LockObjpreVal=lockMap.putIfAbsentkey,curVal;ifnull==preValcurVal.inc;

returncurVal;

else

preVal.inc;

returnpreVal;

privatevoidunLockLockObjlock

iflock.dec=0

lockMap.removelock.getKey;

publicclassLockObj

privatelongkey=0;

privateAtomicIntegercount=newAtomicInteger0;publicLockObjlongkeythis.key=key;

publicintinc

returncount.incrementAndGet;

publicintdec

returncount.decrementAndGet;

publiclonggetKey

returnkey;

@Override

publicStringtoString

returnLockObj[key=+key+,count=+count+];

按照userId来排队,假设每个线程处理数据后不释放锁的`话，那么可以不利用计数器。但是加了释放锁的操作，那么务必加上计算器。由于当线程把锁释放掉后，还没来得及退出synchronized代码块时，另外一个线程调用了tryLock方法，那该线程将拿到另外一个对象的锁，导致利用synchronized关键字举行userId排队失败。

也可以利用guava的API来实现。

importmon.collect.Interner;importmon.collect.Interners;publicclassTestServiceImplInternerStringpool=Interners.newWeakInterner;p