就是不需要某个方法锁住所有进来的线程,而是根据相同id来锁。除了String的intern()、或者concurrentMap这样的。
public class ResourceLock {
private static final Log log = LogFactory.get(ResourceLock.class);
// 初始化ConcurrentHashMap锁载体
private static final ConcurrentHashMap<String, AtomicInteger> lockMap = new ConcurrentHashMap<String, AtomicInteger>();
public static AtomicInteger getAtomicInteger(String key) {
if (lockMap.get(key) == null) {// 当实体ID锁资源为空,初始化锁
lockMap.putIfAbsent(key, new AtomicInteger(0));// 初始化一个竞争数为0的原子资源
}
int count = lockMap.get(key).incrementAndGet();// 线程得到该资源,原子性+1
log.debug("资源ID为:" + key + ",争抢线程数:".ne + count);
return lockMap.get(key);// 返回该ID资源锁
}
public static void giveUpAtomicInteger(String key) {
if (lockMap.get(key) != null) {// 当实体ID资源不为空,才可以操作锁,防止抛出空指针异常
int source = lockMap.get(key).decrementAndGet();// 线程释放该资源,原子性-1
if (source <= 0) {// 当资源没有线程竞争的时候,就删除掉该锁,防止内存溢出
lockMap.remove(key);
log.debug("资源ID为:" + key + "移除成功");
}
log.debug("资源ID为:" + key + ",争抢线程数:" + source);
}
}
}