工作遇到了金钱计算,需要用到读写锁保证数据安全。记录一下。
单纯读没有限制,读写、写写的时候会有安全问题。
_hashMap_存在并发线程安全问题,而 _hashtable_线程安全但每次修改的时候使用 _synchronized_锁住整个表效率很低。推荐使用 _ConcurrentHashMap 。_但 _ ConcurrentHashMap_只是保证了put()、get()操作是线程安全。连续的俩个或多个原子操作逻辑后并不一定线程安全,并发问题依然存在。使用putIfAbsent()方法可以同时达到put,get效果,保证了一次读写的数据同步。putIfAbsent(key,value)存数据的时候会根据key去容器中查询,查询到就返回原容器中key对应的value值,并没有更新value值。查询不到的时候就将key,value存入然后返回null。 _ConcurrentHashMap_使用分段锁提高性能。
static ConcurrentHashMap <string, reentrantreadwritelock> paycertifyMap=new ConcurrentHashMap<>();</string,>
使用map存储流水号和读写锁对象,需要使用的时候 根据从map查询出锁对象然后 tryLock() 只会尝试一次获取锁对象,成功获取返回true。而 lock()获取不到锁时休眠等待获取为止。然后常规使用 即可。
ReentrantReadWriteLock lock = new ReentrantReadWriteLock();
//先去map查询是否存在该流水号的写锁对象
if (paycertifyMap.putIfAbsent(bizMnPaycertifyVO.getHkls(), lock) != null) {
//map已存在数据,赋值
lock = paycertifyMap.putIfAbsent(bizMnPaycertifyVO.getHkls(), lock);
}
//等于null 添加成功 锁对象为新增的lock
if (!lock.writeLock().tryLock()) {
//获取锁失败
return -1;
}
//获取锁成功
try {
//测试并发
Thread.sleep(5000);
//逻辑方法
paycertifyAddUpdate(bizMnPaycertifyVO);
} catch (Exception e) {
logger.error("新增/修改支付凭证异常" + e);
} finally {
//释放锁
//一般释放锁需要判断是否由该线程获取的锁,避免释放其他线程锁,但是这里使用了ConcurrentHashMap保证了同一时间只存在一个线程持有该锁
lock.writeLock().unlock();
}
return 0;
Original: https://www.cnblogs.com/cking98/p/16277645.html
Author: 林间小路
Title: java读写锁
原创文章受到原创版权保护。转载请注明出处:https://www.johngo689.com/620422/
转载文章受原作者版权保护。转载请注明原作者出处!