针对单一key加读写锁

一、什么是读写锁
读写锁是JDK1.5提供的一个工具锁，适用于读多写少的场景，将读写分离，从而提高并发性。
二、读写锁的特点
读锁是共享锁，写锁是排他锁，读锁和写锁不能同时存在；
读锁不能升级为写锁；
写锁可以降级为读锁；
三、锁的本质
锁的本质就是锁住一块资源而不是一块代码. 在常见的一些代码实现都是加一把大锁,将这一块代码资源统一加锁,无法针对资源进行精确进行锁控制.
四、代码实现
`
import lombok.extern.slf4j.Slf4j;
import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.locks.ReadWriteLock;
import java.util.concurrent.locks.ReentrantReadWriteLock;
@Slf4j
public class UserDefinedLock {

1. final ConcurrentHashMap<String, ReadWriteLock> map = new ConcurrentHashMap<>();
3. public UserDefinedLock() {
5. }
7. /**
8. * 从map里获取锁 如果存在则返回 不存在则创建
9. *
10. * @param key key
11. * @return lock
12. */
13. public void createOrGetLock(String key) {
14.     synchronized (key.intern()) {
15.         map.compute(key, (k, lock) -> {
16.             if (lock == null) {
17.                 lock = new ReentrantReadWriteLock();
18.             }
19.             return lock;
20.         });
21.     }
22. }
24. /**
25. * 获取锁 会阻塞
26. *
27. * @param key key
28. */
29. public void writeLock(String key) {
30.     map.get(key).writeLock().lock();
31. }
33. public void readLock(String key) {
34.     map.get(key).readLock().lock();
35. }
37. /**
38. * 释放锁 必须由申请锁的线程进行调用
39. *
40. * @param key key
41. */
42. public void unWriteLock(String key) {
43.     ReadWriteLock lock = map.get(key);
44.     if (null != lock) {
45.         try {
46.             lock.writeLock().unlock();
47.         } catch (Exception e) {
48.             log.error("释放写锁失败，key：{}, msg：{}", key, e.getMessage());
49.         }
50.     }
51. }
53. public void unReadLock(String key) {
54.     ReadWriteLock lock = map.get(key);
55.     if (null != lock) {
56.         try {
57.             lock.readLock().unlock();
58.         } catch (Exception e) {
59.             log.error("释放读锁失败，key：{}, msg：{}", key, e.getMessage());
60.         }
61.     }
62. }
63.   public static void main(String[] args) {
64.         UserDefinedLock userDefinedLock = new UserDefinedLock();
65.         ArrayList list = new ArrayList<String>();
66.     for (int i = 0; i < 5; i++) {
67.         String key = String.valueOf("测试" + i);
68.         new Thread(() -> {
69.             try {
70.                 userDefinedLock.createOrGetLock(key);
71.                 userDefinedLock.readLock(key);
72.                 System.out.println("-----" + key + "----");
73.                 list.add(key);
74.             } catch (Exception e) {
75.                 e.printStackTrace();
76.             } finally {
77.                 try {
78.                     Thread.sleep(1000);
79.                 } catch (InterruptedException e) {
80.                     e.printStackTrace();
81.                 }
82.                 userDefinedLock.unReadLock(key);
83.             }
84.         }, "read-" + key).start();
85.     }
86. }

复制代码

}
`

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！

继续阅读请点击广告