ArrayBlockingQueue生产者消费者

package com.thread.arrayblockingqueue;

import java.util.Random;
import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.BlockingQueue;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
class Apple{
    private String name;
    public Apple(String name){
        this.name = name;
    }
    public String toString(){
        return this.name;
    }
}
class Basket{
    BlockingQueue<Apple> basket = new ArrayBlockingQueue<Apple>(3);
    public String add(Apple apple) throws InterruptedException{
        
        if(basket.size() >=3){
            return ",篮子已满。。等待取走";
        }else{
            basket.put(apple);
            return "成功生产" + apple.toString();
        }
        
        
    }
    public String sub() throws InterruptedException{
        if(basket.size()<=0){
            return (",已取完。。等待生产");
        }else{
            return ",成功取走" + basket.take().toString();
        }
        
    }
}
class Producer implements Runnable{
    private Random r = new Random();
    private String name;
    private Basket basket;
    public Producer(String name, Basket basket){
        this.name = name;
        this.basket = basket;
    }
    @Override
    public void run() {
        int i = 0;
        while(true){
            try {
                System.out.println("生产者：" + name +",尝试生产。。" + basket.add(new Apple("苹果"+i++)));
            } catch (InterruptedException e1) {
                // TODO Auto-generated catch block
                e1.printStackTrace();
            }
            try {
                Thread.sleep(r.nextInt(5)*1000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
        
    }
    
}
class Consumer implements Runnable{
    private Random r = new Random();
    private String name;
    private Basket basket;
    public Consumer(String name, Basket basket){
        this.name = name;
        this.basket = basket;
    }
    @Override
    public void run() {
        // TODO Auto-generated method stub
        while(true){
            try {
                System.out.println("消费者：" +name+"尝试取走"+basket.sub());
                Thread.sleep(r.nextInt(10)*1000);
            } catch (InterruptedException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
        }
    }
    
}
public class Test01 {
    public static void main(String[] args) {
        Basket b = new Basket();
        Producer p1 = new Producer("p1", b);
        Consumer c1 = new Consumer("c1", b);
        Consumer c2 = new Consumer("c2", b);
        ExecutorService es = Executors.newCachedThreadPool();
        es.execute(p1);
        es.execute(c1);
        es.execute(c2);
    }
}