阻塞队列(新版)消费者生产者

package jucTest;
import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.BlockingQueue;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.atomic.AtomicInteger;

class MyResource{
    public  volatile  boolean flag=true;//定义一个开关,开启生产和消费
    private AtomicInteger atomicInteger=new AtomicInteger();

    BlockingQueue<String> blockingQueue=null;

    public MyResource(BlockingQueue<String> blockingQueue) {
        this.blockingQueue = blockingQueue;
        System.out.println(blockingQueue.getClass().getName());
    }

    //定义生产者
     public void MyProduct() throws InterruptedException {
        String date=null;
        boolean result;
        while (flag)
        {
            date = atomicInteger.incrementAndGet()+"";
            result = blockingQueue.offer(date, 2L, TimeUnit.SECONDS);
            if (result==true){
                System.out.println(Thread.currentThread().getName()+" 生产"+String.valueOf(date)+" 成功");
            }else{
                System.out.println(Thread.currentThread().getName()+" 生产"+String.valueOf(date)+" 失败");
            }
            TimeUnit.SECONDS.sleep(1);
        }
        System.out.println("老板不让干了,生产结束");
     }
     //定义消费者
    public void  MyCustomer() throws Exception{
        String poll=null;
        while (flag){
            poll= blockingQueue.poll(2L, TimeUnit.SECONDS);
            if (poll==null||poll.equalsIgnoreCase("")){
                System.out.println(" 消费时间超过2S,退出");
                System.out.println();
                System.out.println();
                return;
            }else {
                System.out.println("消费"+String.valueOf(poll)+"成功");
            }
            TimeUnit.SECONDS.sleep(1);
        }
         System.out.println("消费结束");
    }




}
public class test2 {
    public static void main(String[] args){
        MyResource myResource = new MyResource(new ArrayBlockingQueue<>(10));

        new Thread(()->{
        System.out.println("生产线程启动");
            try {
                myResource.MyProduct();
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        },"producer").start();

        new Thread(()->{
        System.out.println("消费者线程启动");
            try {
                myResource.MyCustomer();
            } catch (InterruptedException e) {
                e.printStackTrace();
            } catch (Exception e) {
                e.printStackTrace();
            }
        },"customer").start();

        //暂停线程
        try{ TimeUnit.SECONDS.sleep(10);} catch(InterruptedException e){ e.printStackTrace();}
        System.out.println("10秒时间到,老板不让干了,下班了");
        myResource.flag=false;

    }
}