简介
wait,notify,notifyAll，都是属于object对象提供的方法，但在实际工作中怎么使用这几个方法，确是很多程序员清楚，不够明白，在群里问，有人说，哪个线程想wait,就用
需等待线程.wait（），就跟Thread.sleep()一样，唤醒也一样，这样显然是不对的。
在 Java 中可以用 wait、notify 和 notifyAll 来实现线程间的通信。。举个例子，如果你的Java程序中有两个线程——即生产者和消费者，那么生产者可以通知消费者，让消费者开始消耗数据，因为队列缓 冲区中有内容待消费（不为空）。相应的，消费者可以通知生产者可以开始生成更多的数据，因为当它消耗掉某些数据后缓冲区不再为满。
1、废话不多说，直接看demo吧
package hello.wait_notify; import java.util.LinkedList;
import java.util.List;
import java.util.Random;
import java.util.concurrent.ConcurrentLinkedQueue; /**
* Created by jacky on 2017/3/25 0025.
*/
public class Waint_Notify { public static void main(String args[])
{
ConcurrentLinkedQueue queue = new ConcurrentLinkedQueue();
int maxSize = 10;
Thread producer = new Producer(queue, maxSize, "PRODUCER");
Thread consumer = new Consumer(queue, maxSize, "CONSUMER");
producer.start();
consumer.start(); } static class Producer extends Thread {
private ConcurrentLinkedQueue queue;
private int maxSize; public Producer(ConcurrentLinkedQueue queue, int maxSize, String name) {
super(name);
this.queue = queue;
this.maxSize = maxSize;
} @Override
public void run() {
while (true) {
synchronized (queue) {
while (queue.size() == maxSize) {
try {
System.out.println("队列中已经满了，等待消费者消费!");
queue.wait();
} catch (Exception ex) {
ex.printStackTrace();
}
}
Random random = new Random();
int i = random.nextInt();
System.out.println("Producing value : " + i);
queue.add(i);
queue.notifyAll();
}
}
}
} static class Consumer extends Thread {
private ConcurrentLinkedQueue queue;
private int maxSize; public Consumer(ConcurrentLinkedQueue queue, int maxSize, String name) {
super(name);
this.queue = queue;
this.maxSize = maxSize;
} @Override
public void run() {
while (true) {
synchronized (queue) {
while (queue.isEmpty()) {
System.out.println("队列已经空了,等待生产者放数据" );
try {
queue.wait();
} catch (Exception ex) {
ex.printStackTrace();
}
}
System.out.println("Consuming value : " + queue.remove());
queue.notifyAll();
}
}
}
}
}
2、结果
3、总结
1. 你可以使用wait和notify函数来实现线程间通信。你可以用它们来实现多线程（>3）之间的通信。
2. 永远在synchronized的函数里使用wait、notify和notifyAll，不然Java虚拟机会生成 IllegalMonitorStateException。
3. 永远在while循环里而不是if语句下使用wait。这样，循环会在线程睡眠前后都检查wait的条件，并在条件实际上并未改变的情况下处理唤醒通知。
4. 永远在多线程间共享的对象（在生产者消费者模型里即缓冲区队列）上使用wait。
5. 基于前文提及的理由，更倾向用 notifyAll()，而不是 notify()。