producerconsumertest3.java

java程序设计

import java.util.concurrent.*;
public class ProducerConsumerTest3 {
    public static void main(String[] args) {
				
        ArrayBlockingQueue<Integer> c = new ArrayBlockingQueue<Integer>(1);
        Producer3 p1 = new Producer3(c, 1);
        Consumer3 c1 = new Consumer3(c, 1);

        p1.start();
        c1.start();
    }
}