Java 实现基于 ArrayList 的生产者 / 消费者

//缓冲区大小private static final int MAX_SIZE = 10;//定义缓冲区private static List<Integer> buffer = new ArrayList<Integer>(MAX_SIZE);private static Random random = new Random();
//生产者线程public class Producer extends Thread {  public void run() {    while(true) {      synchronized(buffer) {        if(buffer.size() == MAX_SIZE) {          try {            buffer.wait();            } catch(Exception e) {          }        }                buffer.add(random.nextInt());                buffer.notify();                System.out.println(buffer.get(buffer.size() - 1));      }    }  }}
//消费者线程public class Consumer extends Thread {  public void run() {    while(true) {      synchronized(buffer) {        if(buffer.isEmpty()) {          try {            buffer.wait();            } catch(Exception e) {          }                  }        System.out.println(buffer.get(0));        buffer.remove(0);        buffer.notify();      }    }  }}
//主程序public static void main(String[] args) throws Exception {  ProducerConsumerArrayList pcm = new ProducerConsumerArrayList();  Consumer consumer0 = pcm.new Consumer();  Consumer consumer1 = pcm.new Consumer();  Producer producer0 = pcm.new Producer();  Producer producer1 = pcm.new Producer();  consumer0.start();  consumer1.start();  producer0.start();  producer1.start();}