Lock&Condition实现线程同步通信

我会带着你远行 2022-07-19 06:10 262阅读 0赞

*  Lock比传统线程模型中的synchronized方式更加面向对象，与生活中的锁类似，锁本身也应该是一个对象。两个线程执行的代码片段要实现同步互斥的效果，它们必须用同一个Lock对象。锁是写在代表要操作的资源的类的内部方法中，而不是线程代码中！  
    \- 读写锁：分为读锁和写锁，多个读锁不互斥，读锁与写锁互斥，写锁与写锁互斥，这是由jvm自己控制的，你只要写好相应的锁即可。如果你的代码只读数据，可以很多人同时读，但不能同时写，那就上读锁，只能有一个人在写，且不能同时读取，那就上写锁。总之，读的时候上读锁，写的时候上写锁！有一个面试题：写一个缓存类！代码如下：

package cn.itcast.heima;
    
    import java.util.HashMap;
    import java.util.Map;
    import java.util.concurrent.locks.ReadWriteLock;
    import java.util.concurrent.locks.ReentrantReadWriteLock;
    
    /** * 缓存demo * * @ClassName: CacheDemo * @Description: TODO * @author liuyuan * @date 2016年8月10日 下午6:53:07 */
    public class CacheDemo { 
        private Map<String, Object> cache = new HashMap<String, Object>();// 缓存存放的位置
        private ReadWriteLock readWriteLock = new ReentrantReadWriteLock();// 读写锁
    
        public Object getData(String key) {
            readWriteLock.readLock().lock();// 加读锁
            Object value = null;
            try {
                value = cache.get(key);// 读
                if (value == null) {
                    readWriteLock.readLock().unlock();// 开读锁
                    readWriteLock.writeLock().lock();// 加写锁
                    try {
                        if (value == null) {
                            value = "abc";// 写：实际代码为从数据库中查询;
                        }
                    } catch (Exception e) {
                        e.printStackTrace();
                    } finally {
                        readWriteLock.writeLock().unlock();// 开写锁
                    }
                    readWriteLock.readLock().lock();// 加读锁
                }
            } catch (Exception e) {
                e.printStackTrace();
            } finally {
                readWriteLock.readLock().unlock();// 开读锁
            }
            return value;
        }
    }