线程通讯的例子

两个线程交替打印1~100

涉及到的三个方法：

wait():一旦执行此方法，当前线程就会进入阻塞状态，并且释放同步监视器。

notify():一旦执行此方法，就会唤醒一个被wait的线程。如果有多个线程被wait，优先唤醒优先级高的线程

notifyAll():一旦执行此方法，就会唤醒所有被wait的线程。

说明：

1、wait（），notify（），notifyAll（）必须使用在同步代码块或者同步方法中。

2、wait（），notify（），notifyAll（）的调用者必须是同步代码块或者同步方法中的同步监视器。否则会出现IllegalMonitorStateException异常。

3、每个类都拥有wait（），notify（），notifyAll（）方法，因为这三个方法在上帝类Object中。

package com.gtguigu.java.Thread;

public class Number implements Runnable{
    public static void main(String[] args) {
        Number number = new Number();
        Thread thread1 = new Thread(number,"线程一");
        Thread thread2 = new Thread(number,"线程二");

        thread1.start();
        thread2.start();
    }
    private int num = 1;
    private Object obj = new Object();
    @Override
    public void run() {
        while (true){
            //同步代码块保证线程安全
            synchronized (this){
            //唤醒一个处于wait阻塞状态的线程;
                notify();
                if (num<=100){
                    System.out.println(Thread.currentThread().getName()+num);
                    num++;
                }else {
                    break;
                }
                try {
                    //使线程进入阻塞状态
                    wait();
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
        }
    }
}

 运行结果：

 如果将同步监视器改为obj对象并且没有更改notif方法和wait方法：

synchronized (obj){
            //唤醒一个处于wait阻塞状态的线程;
                notify();
                if (num<=100){
                    System.out.println(Thread.currentThread().getName()+num);
                    num++;
                }else {
                    break;
                }
                try {
                    //使线程进入阻塞状态
                    wait();
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }

运行结果：

 正确应用方法：

synchronized (obj){
            //唤醒一个处于wait阻塞状态的线程;
                obj.notify();
                if (num<=100){
                    System.out.println(Thread.currentThread().getName()+num);
                    num++;
                }else {
                    break;
                }
                try {
                    //使线程进入阻塞状态
                    obj.wait();
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }

notify（），wait（），notifyAll（）的调用者应该与同步监视器相同。