1. import java.util.HashMap;
   
2. 
   
3. import java.util.Map;
   
4. 
   
5. import java.util.concurrent.locks.ReadWriteLock;
   
6. 
   
7. import java.util.concurrent.locks.ReentrantReadWriteLock;
   
8. 
   
9. public classCacheDemo {
   
10. 
    
11. private Map<String,Object> cache= newHashMap<String, Object>(); //模拟缓存，每个key对应一个obj
    
12. 
    
13. public static void main(String[] args) {
    
14. 
    
15. }
    
16. 
    
17. private ReadWriteLock rwl = newReentrantReadWriteLock();//定义读写锁
    
18. 
    
19. //我们先跟去key去缓存中取数据，如果有的话，则返回对应的值，如果没有，去数据库中查找，返回查找到的值
    
20. 
    
21. public Object getData(String key){
    
22. 
    
23. rwl.readLock().lock();//上读锁
    
24. 
    
25. Objectvalue = null;
    
26. 
    
27. try {
    
28. 
    
29. value= cache.get(key);
    
30. 
    
31. if(value == null){//如果换从中没有的话 打开读锁
    
32. 
    
33. rwl.readLock().unlock();
    
34. 
    
35. rwl.writeLock();//读与写是互斥的，所以要先解开读锁，才能进行写操作（个人理解）
    
36. 
    
37. try {
    
38. 
    
39. value= “aaaa”;//实际是去数据库中queryDB();
    
40. 
    
41. cache.put(key, value);//将得到的数据，存入缓存中。以后的线程直接在缓存中取值（张老师视频上没有，个人加的）
    
42. 
    
43. }catch(Exception e) {
    
44. 
    
45. }finally{
    
46. 
    
47. rwl.writeLock().unlock();//释放读锁
    
48. 
    
49. }
    
50. 
    
51. rwl.readLock().lock();//还原读锁，防止下面的finally出现异常
    
52. 
    
53. }
    
54. 
    
55. }catch(Exception e) {
    
56. 
    
57. }
    
58. 
    
59. finally{
    
60. 
    
61. rwl.readLock().unlock();
    
62. 
    
63. }
    
64. 
    
65. return value;
    
66. 
    
67. }
    
68. 
    
69. }
    
70. 
    
71. 实现注意事项：此锁最多支持 65535 个递归写入锁和 65535 个读取锁。试图超出这些限制将导致锁方法抛出 .JDK_API_1_6_zh_CN.CHM::/java/lang/Error.html]Error。读写锁：多个读锁不互斥，读锁与写锁互斥，写锁与写锁互斥

复制代码

1. import java.util.HashMap;
   
2. 
   
3. import java.util.Map;
   
4. 
   
5. import java.util.concurrent.locks.ReadWriteLock;
   
6. 
   
7. import java.util.concurrent.locks.ReentrantReadWriteLock;
   
8. 
   
9. public classCacheDemo {
   
10. 
    
11. private Map<String,Object> cache= newHashMap<String, Object>(); //模拟缓存，每个key对应一个obj
    
12. 
    
13. public static void main(String[] args) {
    
14. 
    
15. }
    
16. 
    
17. private ReadWriteLock rwl = newReentrantReadWriteLock();//定义读写锁
    
18. 
    
19. //我们先跟去key去缓存中取数据，如果有的话，则返回对应的值，如果没有，去数据库中查找，返回查找到的值
    
20. 
    
21. public Object getData(String key){
    
22. 
    
23. rwl.readLock().lock();//上读锁
    
24. 
    
25. Objectvalue = null;
    
26. 
    
27. try {
    
28. 
    
29. value= cache.get(key);
    
30. 
    
31. if(value == null){//如果换从中没有的话 打开读锁
    
32. 
    
33. rwl.readLock().unlock();
    
34. 
    
35. rwl.writeLock();//读与写是互斥的，所以要先解开读锁，才能进行写操作（个人理解）
    
36. 
    
37. try {
    
38. 
    
39. value= “aaaa”;//实际是去数据库中queryDB();
    
40. 
    
41. cache.put(key, value);//将得到的数据，存入缓存中。以后的线程直接在缓存中取值（张老师视频上没有，个人加的）
    
42. 
    
43. }catch(Exception e) {
    
44. 
    
45. }finally{
    
46. 
    
47. rwl.writeLock().unlock();//释放读锁
    
48. 
    
49. }
    
50. 
    
51. rwl.readLock().lock();//还原读锁，防止下面的finally出现异常
    
52. 
    
53. }
    
54. 
    
55. }catch(Exception e) {
    
56. 
    
57. }
    
58. 
    
59. finally{
    
60. 
    
61. rwl.readLock().unlock();
    
62. 
    
63. }
    
64. 
    
65. return value;
    
66. 
    
67. }
    
68. 
    
69. }
    
70. 
    
71. 实现注意事项：此锁最多支持 65535 个递归写入锁和 65535 个读取锁。试图超出这些限制将导致锁方法抛出 .JDK_API_1_6_zh_CN.CHM::/java/lang/Error.html]Error。读写锁：多个读锁不互斥，读锁与写锁互斥，写锁与写锁互斥

复制代码