Java线程之等待wait唤醒notify示例（一）

迈不过友情╰ 2022-08-21 09:48 104阅读 0赞

## 线程等待，线程唤醒 ##

*  “锁“中的主要方法

> 1.  wait(): 让线程处于冻结状态，被wait的线程会被存储到线程池中。
> 2.  notify():唤醒线程池中一个线程(任意),没有顺序。
> 3.  notifyAll():唤醒线程池中的所有线程。

因为synchronized模块的监视器是任意对象，所以这些方法定义在Object中

注意：  
\*\*这些方法都必须定义在同步中。因为这些方法是用于操作线程状态的方法。  
必须要明确到底操作的是哪个锁上的线程。也就是哪个锁调用了方法，那么这个锁里面的进城做出相应的动作\*\*

*  所谓的监听器即”锁”，这个锁不仅可以锁住进程，还可以监视进程，每个监听器都有进程缓冲池，  
    相应的监听器调用wait方法只能作用于自己缓冲池中的进程  
    所以一一定要保证是同一个锁

示例：

class Person { 
        private String name;
        private String country;
        private boolean flag = false;//默认数据为空
    
        //封装写数据方法
        synchronized void setData(String name,String country)
        {
            if(flag)//里面没有数据，将取数据进程等待
            try{
       this.wait();}catch (InterruptedException ex){}//因为wait方法有抛出异常（wait继承于Object）
            this.name = name;
            this.country = country;
            flag = true;//数据已经写入，转换标识
            this.notify();//唤醒取数据进程
        }
    
        //封装取数据方法
        synchronized void getData( )
        {
            if(!flag)//不为空，则写数据进程等待
            try{
       this.wait();}catch (InterruptedException ex){}
            System.out.println("name: "+name+"---country: "+country);
            flag = false;
            this.notify();
        }
    }
    
    //定义写数据线程任务
    class Input implements Runnable { 
        Person p;
        Input(Person p)
        {
            this.p = p;
        }
        public void run()
        {
            int i = 0;
            while(true)
            {
                if(i == 0)//为了模拟多个数据输出
                p.setData("女娲","中国");
                else
                p.setData("God","American");
                i=(i+1)%2;
            }
        }
    }
    
    //定义取数据进程
    class Output implements Runnable { 
        Person p;
        Output(Person p)
        {
            this.p = p;
        }
        public void run()
        {
            while(true)
            {
                p.getData();
            }
        }
    }
    class ThreadWait { 
        public static void main(String[] args) 
        {
            //创建数据对象
            Person p = new Person();
            //创建线程任务
            Input in = new Input(p);
            Output out = new Output(p);
            //创建线程
            Thread t1 = new Thread(in);
            Thread t2 = new Thread(out);
            //开始
            t1.start();
            t2.start();
        }
    }

![结果][20160426163536059]  
这个就是生产者和消费者模式的”前身“

[20160426163536059]: /images/20220724/f1dc56d7a4b040be9621f7fa05b79882.png