class Product {

    private final int orderNum;

    public Product(int orderNum) {

        this.orderNum = orderNum;

    }

    public String toString() {

        return "Product" + orderNum;

    }

}

class Producter implements Runnable {

    private MainQueue main;

    public Producter(MainQueue main) {

        this.main = main;

    }

    public void run() {

        Product product = new Product(new Random().nextInt(100));

        //向队列插入一个元素 ，此时consumer任务是获取不了当前这个队列的所即他读取不了里面的数据

        main.queue.add(product);

        System.out.println("the Producter put the " + product

                + " in to the queue");

    }

}

class Consumer implements Runnable {

    private MainQueue main;

    public Consumer(MainQueue main) {

        this.main = main;

    }

    public void run() {

        while (main.queue.size() > 0) {

            Product product = null;

            try {

                //读队列中的一个元素，此时product任务写不进去元素

                product = main.queue.take();

                System.out.println("the Consumer get the" + product

                        + " from the quene");

            } catch (InterruptedException e) {

                System.out.println("Consumer interrupted!");

            }

        }

    }

}

public class MainQueue {

    //这是一个同步队列 它只允许一个任务插入或者删除元素 LinkedBlockingQeque是一个无界的队列

    BlockingQueue<Product> queue = new LinkedBlockingDeque<>();

    Producter producter = new Producter(this);

    Consumer consumer = new Consumer(this);

    public MainQueue() {

        for (int i = 0; i < 10; i++) {

            new Thread(producter).start();

        }

        for (int i = 0; i < 10; i++) {

            new Thread(consumer).start();

        }

    }

    public static void main(String[] args) {

        new MainQueue();

    }

}