生产者消费者模式

?import java.util.concurrent.BlockingQueue;
?
?
?
import java.util.concurrent.ArrayBlockingQueue;import java.util.concurrent.BlockingQueue;import java.util.concurrent.ExecutorService;import java.util.concurrent.Executors;public class Setup {public static void main(String[] args) {BlockingQueue<String> queue = new ArrayBlockingQueue<String>(100);ExecutorService exec = Executors.newCachedThreadPool();exec.execute(new Producer(queue));exec.execute(new Consumer(queue));}}
?