【Java基础-并发编程】-wait/notify

谁践踏了优雅 2023-10-12 16:04 43阅读 0赞

## 一、wait/notify的原理 ##

![92bd5c4e7d9a4124b1acb47206bb9dde.png][]

*  Owner线程发现条件不满足，调用wait方法，即可进入WaitSet变为WAITING状态
 *  BLOCKED和WAITING的线程都处于阻塞状态，不占用CPU时间片
 *  BLOCKED线程会在Owner线程释放锁时唤醒
 *  WAITING线程会在Owner线程调用notify或notifyAll时唤醒，但唤醒后并不意味着立刻获得锁，仍需进入EntryList重新竞争。

## 二、wait/notify 的API介绍 ##

*  obj.wait() 让进入object监视器的线程到waitSet等待
 *  obj.notify()在object上正在waitSet等待的线程中挑一个唤醒
 *  obj.notifyAll()让object上正在waitSet等待的线程全部唤醒

它们都是线程之间进行协作的手段，都属于Object对象的方法，必须获得此对象的锁，才能调用这几个方法。

final static Object obj = new Object();
    
        public static void main(String[] args){
            new Thread(()->{
                synchronized (obj){
                    log.info("执行......");
                    try{
                        obj.wait();//让线程在obj上一直等待下去
                    }catch (InterruptedException e){
                        e.printStackTrace();
                    }
                    log.info("其他代码......");
                }
            },"t1").start();
    
            new Thread(()->{
                synchronized (obj){
                    log.info("执行......");
                    try{
                        obj.wait();//让线程在obj上一直等待下去
                    }catch (InterruptedException e){
                        e.printStackTrace();
                    }
                    log.info("其他代码......");
                }
            },"t2").start();
    
            //主线程两秒后执行
            try{
                Thread.sleep(2000);
            }catch (Exception e){
                e.printStackTrace();
            }
            log.info("唤醒obj上其它线程");
            synchronized (obj){
                obj.notifyAll(); //唤醒obj上一个线程
            }
    
        }

## 三、Sleep与wait的区别 ##

1.  sleep是Thread方法，而wait是object的方法
2.  sleep不需要强制和synchronized配合使用，但wait需要和synchronized一起使用
3.  sleep在睡眠的同时，不会释放对象锁的，但wait在等待的时候会释放对象锁。
4.  sleep和wait的状态都是TIMED\_WAITING

## 四、wait与notifyAll的正确用法格式 ##

4.1 标准格式

synchronized (lock){
        //使用while而不是if的目的是为了，在notifyAll唤醒时，防止虚假唤醒
        while (条件不成立){
            lock.wait();
        }
        //干活
    }
    //另一个线程
    synchronized (lock){
        //设置条件成立
        //2.唤醒所有wait阻塞
        lock.notifyAll()
    }

4.2 用例

final static Object room = new Object();
    static boolean hasCigarette = false;
    static boolean hasTakeout = false;
    
    public static void main(String[] args) throws InterruptedException {
       new Thread(()->{
       synchronized (room) {
            log.info("有烟没？【{}】", hasCigarette);
            while (!hasCigarette) {
               log.info("没烟，先歇会！");
               try {
                    room.wait();
                } catch (InterruptedException e) {
                            e.printStackTrace();
                        }
                    }
                    log.info("有烟没？【{}】", hasCigarette);
                    if (hasCigarette) {
                        log.info("可以开始干活了！");
                    } else {
                        log.info("没干成活......");
                    }
                }
            },"小南").start();
    
    
       new Thread(()->{
          synchronized (room) {
              log.info("有外卖没？【{}】", hasTakeout);
              while (!hasTakeout) {
                        log.info("没外卖，先歇会！");
                        try {
                            room.wait();
                        } catch (InterruptedException e) {
                            e.printStackTrace();
                        }
                    }
                    log.info("有外卖没？【{}】", hasTakeout);
                    if (hasTakeout) {
                        log.info("可以开始干活了！");
                    } else {
                        log.info("没干成活......");
                    }
                }
            },"小女").start();
    
    
       Thread.sleep(2000);
            synchronized (room){
                hasTakeout = true;
                log.info("外卖来了.....");
                room.notifyAll();
            }
        }

[92bd5c4e7d9a4124b1acb47206bb9dde.png]: https://img-blog.csdnimg.cn/92bd5c4e7d9a4124b1acb47206bb9dde.png