BlockingQueue的应用

package blockqueuetestinfo;import java.util.concurrent.ArrayBlockingQueue;import java.util.concurrent.BlockingQueue;import java.util.concurrent.ExecutorService;import java.util.concurrent.Executors;/** * @author 向旗 */public class QueueMain {/** * 定义装苹果的篮子 */public static class Basket {// 篮子，能够容纳3个苹果BlockingQueue<String> basket = new ArrayBlockingQueue<String>(3);// 生产苹果，放入篮子public void produce() throws InterruptedException {// put方法放入一个苹果，若basket满了，等到basket有位置basket.put("An apple");}// 消费苹果，从篮子中取走public String consume() throws InterruptedException {// get方法取出一个苹果，若basket为空，等到basket有苹果为止return basket.take();}}// 　测试方法public static void testBasket() {// 建立一个装苹果的篮子final Basket basket = new Basket();// 定义苹果生产者class Producer implements Runnable {public void run() {try {while (true) {// 生产苹果System.out.println("生产者准备生产苹果：" + System.currentTimeMillis());basket.produce();System.out.println("生产者生产苹果完毕：" + System.currentTimeMillis());// 休眠300msThread.sleep(300);}} catch (InterruptedException ex) {}}}// 定义苹果消费者class Consumer implements Runnable {public void run() {try {while (true) {// 消费苹果System.out.println("消费者准备消费苹果：" + System.currentTimeMillis());basket.consume();System.out.println("消费者消费苹果完毕：" + System.currentTimeMillis());// 休眠1000msThread.sleep(1000);}} catch (InterruptedException ex) {}}}ExecutorService service = Executors.newCachedThreadPool();Producer producer = new Producer();Consumer consumer = new Consumer();// 提交两个线程到线程池里service.submit(producer);service.submit(consumer);// 程序运行5s后，所有任务停止try {Thread.sleep(5000);} catch (InterruptedException e) {}service.shutdownNow();}public static void main(String[] args) {QueueMain.testBasket();}}