今天我们就介绍一种非常普遍的并发场景:读多写少场景。实际工作中,为了优化性能,我们经常会使用缓存,例如缓存元数据、缓存基础数据等,这就是一种典型的读多写少应用场景。缓存之所以能提升性能,一个重要的条件就是缓存的数据一定是读多写少的,例如元数据和基础数据基本上不会发生变化(写少),但是使用它们的地方却很多(读多)。

针对读多写少这种并发场景,Java SDK 并发包提供了读写锁——ReadWriteLock,非常容易使用,并且性能很好。

读写锁,并不是 Java 语言特有的,而是一个广为使用的通用技术,所有的读写锁都遵守以下三条基本原则:

  1. 允许多个线程同时读共享变量;
  2. 只允许一个线程写共享变量;
  3. 如果一个写线程正在执行写操作,此时禁止读线程读共享变量

读写锁与互斥锁的一个重要区别就是读写锁允许多个线程同时读共享变量,而互斥锁是不允许的,这是读写锁在读多写少场景下性能优于互斥锁的关键。但读写锁的写操作是互斥的,当一个线程在写共享变量的时候,是不允许其他线程执行写操作和读操作。

快速实现一个缓存


下面我们就实践起来,用 ReadWriteLock 快速实现一个通用的缓存工具类。

在下面的代码中,我们声明了一个 Cache 类,其中类型参数 K 代表缓存里 key 的类型,V 代表缓存里 value 的类型。缓存的数据保存在 Cache 类内部的 HashMap 里面,HashMap 不是线程安全的,这里我们使用读写锁 ReadWriteLock 来保证其线程安全。ReadWriteLock 是一个接口,它的实现类是 ReentrantReadWriteLock,通过名字你应该就能判断出来,它是支持可重入的。下面我们通过 rwl 创建了一把读锁和一把写锁。

Cache 这个工具类,我们提供了两个方法,一个是读缓存方法 get(),另一个是写缓存方法 put()。读缓存需要用到读锁,读锁的使用和前面我们介绍的 Lock 的使用是相同的,都是 try{}finally{}这个编程范式。写缓存则需要用到写锁,写锁的使用和读锁是类似的。这样看来,读写锁的使用还是非常简单的。

  1. class Cache<K,V> {
  2. final Map<K, V> m = new HashMap<>();
  3. final ReadWriteLock rwl = new ReentrantReadWriteLock();
  4. // 读锁
  5. final Lock r = rwl.readLock();
  6. // 写锁
  7. final Lock w = rwl.writeLock();
  8. // 读缓存
  9. V get(K key) {
  10. r.lock();
  11. try { return m.get(key); }
  12. finally { r.unlock(); }
  13. }
  14. // 写缓存
  15. V put(K key, V value) {
  16. w.lock();
  17. try { return m.put(key, v); }
  18. finally { w.unlock(); }
  19. }
  20. }


如果你曾经使用过缓存的话,你应该知道使用缓存首先要解决缓存数据的初始化问题。缓存数据的初始化,可以采用一次性加载的方式,也可以使用按需加载的方式。

如果源头数据的数据量不大,就可以采用一次性加载的方式,这种方式最简单(可参考下图),只需在应用启动的时候把源头数据查询出来,依次调用类似上面示例代码中的 put() 方法就可以了。

image.png

如果源头数据量非常大,那么就需要按需加载了,按需加载也叫懒加载,指的是只有当应用查询缓存,并且数据不在缓存里的时候,才触发加载源头相关数据进缓存的操作。下面你可以结合文中示意图看看如何利用 ReadWriteLock 来实现缓存的按需加载。

image.png

实现缓存的按需加载

  1. class Cache<K,V> {
  2. final Map<K, V> m = new HashMap<>();
  3. final ReadWriteLock rwl = new ReentrantReadWriteLock();
  4. final Lock r = rwl.readLock();
  5. final Lock w = rwl.writeLock();
  6. V get(K key) {
  7. V v = null;
  8. // 读缓存
  9. r.lock();
  10. try {
  11. v = m.get(key);
  12. } finally{
  13. r.unlock();
  14. }
  15. // 缓存中存在,返回
  16. if(v != null) {
  17. return v;
  18. }
  19. // 缓存中不存在,查询数据库
  20. w.lock();
  21. try {
  22. // 再次验证
  23. // 其他线程可能已经查询过数据库
  24. v = m.get(key);
  25. if(v == null){
  26. // 查询数据库
  27. v= 省略代码无数
  28. m.put(key, v);
  29. }
  30. } finally{
  31. w.unlock();
  32. }
  33. return v;
  34. }
  35. }