（新思路）生产者消费者模型2（BlockingQueue的无锁解决方法）

public class testLinkedBlockingQueue{

    //初始化阻塞队列容器（放产品）

    static BlockingQueue<String> products = new LinkedBlockingQueue<>();

    static Random r = new Random();

    public static void main(String[] args){

        //1个生产者线程

        new Thread(()->{

            for(int i=0;i<100;i++){//生产100个产品

                try{

                    products.put("产品："+i);

                }catch (InterruptedException e){

                    e.printStackTrace();

                }

            }

        },"生产者").start();

        //5个消费者线程

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

            new Thread(()->{

                for(;;){//死循环，一直在消耗产品，如果产品为空则产品容器队列阻塞，等待产品生产

                    try{

                        //消费者线程消费产品

                     System.out.println(Thread.currentThread().getName() +

                                        "消费：" + products.take());

                    }catch(InterruptedException e){

                        e.printStackTrace();

                    }

                }

            }).start();

        }

    }

}