线程的通信

wait()与notify()和notifyAll()

• wait()：令当前线程挂起并放弃CPU、同步资源并等待，使别的线程可访问并修改共享资源，而当前线程排队等候其他线程调用notify()或notifyAll()方法唤醒，唤醒后等待重新获得对监视器的所有权后才能继续执行。

• notify()：唤醒正在排队等待同步资源的线程中优先级最高者结束等待

• notifyAll()：唤醒正在排队等待资源的所有线程结束等待.

注意：

• 这三个方法只有在synchronized方法或synchronized代码块中才能使用，否则会报java.lang.IllegalMonitorStateException异常。

• 因为这三个方法必须有锁对象调用，而任意对象都可以作为synchronized的同步锁，因此这三个方法只能在Object类中声明。

wait() 方法

• 在当前线程中调用方法：对象名.wait()
• 使当前线程进入等待（某对象）状态，直到另一线程对该对象发出notify(或notifyAll)为止。
• 调用方法的必要条件：当前线程必须具有对该对象的监控权（加锁）
• 调用此方法后，当前线程将释放对象监控权，然后进入等待
• 在当前线程被notify后，要重新获得监控权，然后从断点处继续代码的执行。

notify()/notifyAll()方法

• 在当前线程中调用方法：对象名.notify()

• 功能：唤醒等待该对象监控权的一个/所有线程。

• 调用方法的必要条件：当前线程必须具有对该对象的监控权（加锁）

示例代码：

public class ThreadCommunication {

    public static void main(String[] args) {
        Number10 n = new Number10();
        Thread t1 = new Thread(n);
        Thread t2 = new Thread(n);
        t1.start();
        t2.start();
    }

}

class Number10 implements Runnable {
    private int num = 0;

    @Override
    public void run() {
        // TODO Auto-generated method stub

        while (true) {
            synchronized (this) {
                notify();
                try {
                    Thread.sleep(100);
                } catch (InterruptedException e) {
                    // TODO Auto-generated catch block
                    e.printStackTrace();
                }
                if (num < 10) {
                    System.out.printf("%s : num: %d%n", Thread.currentThread().getName(), num++);
                } else {
                    break;
                }

                try {
                    wait();
                } catch (InterruptedException e) {
                    // TODO Auto-generated catch block
                    e.printStackTrace();
                }
            }

        }

    }

}

输出：

Thread-0 : num: 0
Thread-1 : num: 1
Thread-0 : num: 2
Thread-1 : num: 3
Thread-0 : num: 4
Thread-1 : num: 5
Thread-0 : num: 6
Thread-1 : num: 7
Thread-0 : num: 8
Thread-1 : num: 9