用实例揭示notify()和notifyAll()的本质区别

notify()和notifyAll()都是Object对象用于通知等待该对象的线程的方法。

notifyAll使所有原来在该对象上等待的线程统统退出wait的状态，变成等待该对象上的锁，一旦该对象被解锁，它们就会去竞争。
notify则只是选择一个wait状态线程进行通知，并使它获得该对象上的锁，但不惊动其他同样在等待被该对象notify的线程们，当第一个线程运行完毕以后释放对象上的锁此时如果该对象没有再次使用notify语句，则即便该对象已经空闲，其他wait状态等待的线程由于没有得到该对象的通知，继续处在wait状态，直到这个对象发出一个notify或notifyAll，它们等待的是被notify或notifyAll，而不是锁。


import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
class Cafe {
}
class CafeFactory {
    List<Cafe> finishedCafe = new ArrayList<Cafe>();
    public void addCafe() {
        try {
            while (true) {
                Thread.sleep(5000);// act busy
                Cafe w = new Cafe();
                // 也就是说需要5秒钟才能新产生一个Widget，这决定了一定要用notify而不是notifyAll
                // 因为上面两行代码不是同步的，如果用notifyAll则所有线程都企图冲出wait状态
                // 第一个线程得到了锁，并取走了Widget（这个过程的时间小于5秒，新的Widget还没有生成）
                // 并且解开了锁，然后第二个线程获得锁(因为用了notifyAll其他线程不再等待notify语句
                // ，而是等待finishedWidgets上的锁，一旦锁放开了，他们就会竞争运行)，运行
                // finishedWidgets.remove(0)，但是由于finishedWidgets现在还是空的，
                // 于是产生异常
                // ***********这就是为什么下面的那一句不能用notifyAll而是要用notify
                synchronized (finishedCafe) {
                    System.out.println(Thread.currentThread() + " Adding cafe:" + w);
                    finishedCafe.add(w);
                    finishedCafe.notify(); // 这里只能是notify而不能是notifyAll
                }
            }
        } catch (InterruptedException e) {
        }
    }
    public Cafe getCafe() {
        synchronized (finishedCafe) {
            if (finishedCafe.size() == 0) {
                try {
                    finishedCafe.wait();
                } catch (InterruptedException e) {
                }
            }
            Cafe c = finishedCafe.remove(0);
            System.out.println(Thread.currentThread() + "Getting cafe:" + c);
            return c;
        }
    }
}
class AddingCafeTask implements Runnable {
    private CafeFactory cafeFactory;
    public AddingCafeTask(CafeFactory cafeFactory) {
        this.cafeFactory = cafeFactory;
    }
    @Override
    public void run() {
        cafeFactory.addCafe();
    }
}
class GetingCafeTask implements Runnable {
    private CafeFactory cafeFactory;
    public GetingCafeTask(CafeFactory cafeFactory) {
        this.cafeFactory = cafeFactory;
    }
    @Override
    public void run() {
        cafeFactory.getCafe();
    }
}
public class CafeTest extends Thread {
    public static void main(String[] args) {
        CafeFactory cafeFactory = new CafeFactory();
        ExecutorService executorService = Executors.newCachedThreadPool();
        executorService.execute(new GetingCafeTask(cafeFactory));
        executorService.execute(new GetingCafeTask(cafeFactory));
        executorService.execute(new GetingCafeTask(cafeFactory));
        executorService.execute(new AddingCafeTask(cafeFactory));
    }
}