四组API

方式	抛出异常	有返回值,不抛出异常	阻塞,等待	超时等待
添加	add	offet()	put()	offer(,,)
移除	remove	poll()	take()	poll(,)
检测对首元素	element	peek	..	..

第一

//抛出异常
    public static void Test1(){
        ArrayBlockingQueue blockingQueue = new ArrayBlockingQueue<>(3);

        System.out.println(blockingQueue.add("A"));
        System.out.println(blockingQueue.add("B"));
        System.out.println(blockingQueue.add("C"));
        //System.out.println(blockingQueue.add("A"));
        // java.lang.IllegalStateException: Queue full 队列已满
        System.out.println("===");

        System.out.println(blockingQueue.element());//查看队列个元素首是谁

        System.out.println(blockingQueue.remove());
        System.out.println(blockingQueue.remove());
        System.out.println(blockingQueue.remove());
        //java.util.NoSuchElementException  这里面没有元素
        //System.out.println(blockingQueue.remove());

    }

第二

 //有返回值,没有异常
    public static void Test2(){
        //队列大小
        ArrayBlockingQueue blockingQueue = new ArrayBlockingQueue<>(3);
        System.out.println(blockingQueue.offer("a"));
        System.out.println(blockingQueue.offer("b"));
        System.out.println(blockingQueue.offer("c"));
        //System.out.println(blockingQueue.offer("c"));//返回false  不会抛出异常

        System.out.println(blockingQueue.peek());

        System.out.println("======================");
        System.out.println(blockingQueue.poll());
        System.out.println(blockingQueue.poll());
        System.out.println(blockingQueue.poll());
        //System.out.println(blockingQueue.poll());//返回一个null  不会抛出异常
    }

第三

 //等待,阻塞(一直)
    public static void Test3() throws InterruptedException {
        //队列大小
        ArrayBlockingQueue blockingQueue = new ArrayBlockingQueue<>(3);
        blockingQueue.put("a");
        blockingQueue.put("b");
        blockingQueue.put("c");
        //blockingQueue.put("d");//队列 没有位置,程序就会一直等待  下面的程序不会执行
        //System.out.println(blockingQueue.offer("c"));//返回false  不会抛出异常

        System.out.println(blockingQueue.peek());

        System.out.println("======================");
        System.out.println(blockingQueue.take());
        System.out.println(blockingQueue.take());
        System.out.println(blockingQueue.take());
        System.out.println(blockingQueue.take());//找不到元素,会一直等待,一直阻塞状态
    }

第四

 //等待,阻塞(等待超时)
    public static void Test4() throws InterruptedException {
        //队列大小
        ArrayBlockingQueue blockingQueue = new ArrayBlockingQueue<>(3);
        blockingQueue.offer("a");
        blockingQueue.offer("b");
        blockingQueue.offer("c");
        blockingQueue.offer("b",2, TimeUnit.SECONDS);
        //       blockingQueue.offer("b",2, TimeUnit.SECONDS);//等待超過兩秒就退出

        System.out.println("===============");

        System.out.println(blockingQueue.poll());
        System.out.println(blockingQueue.poll());
        System.out.println(blockingQueue.poll());
        System.out.println(blockingQueue.poll(3, TimeUnit.SECONDS));
        //blockingQueue.poll(3, TimeUnit.SECONDS) 等待超過三秒就推出
    }