JUC并发编程——读写锁（基于狂神说的学习笔记）

读写锁

以下来自官方文档

ReadWriteLock维护一对关联的locks ，一个用于只读操作，另一个用于写入。 只要没有写入器， read lock可以由多个读取器线程同时保持。 write lock是独家的。

所有ReadWriteLock实现必须保证writeLock操作的内存同步效果（如Lock接口中所指定）也相对于关联的readLock 。 也就是说，成功获取读锁定的线程将看到在先前释放写锁定时所做的所有更新。

读写锁允许访问共享数据的并发性高于互斥锁允许的并发性。 它利用了这样一个事实：虽然一次只有一个线程（一个编写器线程）可以修改共享数据，但在许多情况下，任何数量的线程都可以同时读取数据（因此读取器线程）。 理论上，使用读写锁所允许的并发性的增加将导致相互使用互斥锁的性能提高。 实际上，这种并发性的增加只能在多处理器上完全实现，并且只有在共享数据的访问模式合适时才能实现。

读写锁是否会提高使用互斥锁的性能取决于与被修改相比读取数据的频率，读写操作的持续时间以及数据的争用 - 是，将尝试同时读取或写入数据的线程数。 例如，最初填充数据并且之后不经常修改但经常搜索的集合（例如某种目录）是使用读写锁的理想候选者。 但是，如果更新变得频繁，那么数据的大部分时间都会被完全锁定，并且并发性几乎没有增加。 此外，如果读取操作太短，则读写锁定实现的开销（其本质上比互斥锁定更复杂）可以支配执行成本，特别是因为许多读写锁定实现仍然通过序列化所有线程。小部分代码。 最终，只有分析和测量才能确定使用读写锁是否适合您的应用。

package RWLock;

import java.util.HashMap;
import java.util.Map;
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;
import java.util.concurrent.locks.ReentrantReadWriteLock;

/**
 * 独占锁（写锁）
 * 共享锁（读锁）
 * ReadWriteLock
 *
 */
public class ReadWriteLockDemo {
    public static void main(String[] args) {


        MyCache myCache = new MyCache();
        // 写入
        for (int i = 1; i <= 5; i++) {
            final int temp = i;
            new Thread(()->{
                myCache.put(temp+"",temp+"");
            },String.valueOf(i)).start();
        }

        // 读取
        for (int i = 1; i <= 5; i++) {
            final int temp = i;
            new Thread(()->{
                myCache.get(temp+"");
            },String.valueOf(i)).start();
        }
    }

}

/**
 * 自定义缓存
 */
class MyCache{
    private volatile Map<String,Object> map = new HashMap<>();
    // 读写锁：更加细粒度的控制
    private ReentrantReadWriteLock ReadWriteLock = new ReentrantReadWriteLock();

    // 存，写过程，写入的时候只希望同时只有一个线程在写
    public void put(String key, Object value){
        ReadWriteLock.writeLock().lock(); // 加锁
        try {
            System.out.println(Thread.currentThread().getName()+"写入"+key);
            map.put(key, value);
            System.out.println(Thread.currentThread().getName()+"写入完毕");
        } catch (Exception e) {
            throw new RuntimeException(e);
        } finally {
            ReadWriteLock.writeLock().unlock(); // 解锁
        }

    }

    // 取，读过程， 读取的时候希望所有人都可以取读
    public void get(String key){
        ReadWriteLock.readLock().lock();

        try {
            System.out.println(Thread.currentThread().getName()+"读取"+key);
            Object o = map.get(key);
            System.out.println(Thread.currentThread().getName()+"读取完毕");
        } catch (Exception e) {
            throw new RuntimeException(e);
        } finally {
            ReadWriteLock.readLock().unlock();
        }

    }
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77