private static final BlockingQueue<String> blockingQueue = new ArrayBlockingQueue<>(3);
	//拋出異常
    @Test
    public void test(){
        System.out.println(blockingQueue.add("a"));
        System.out.println(blockingQueue.add("b"));
        System.out.println(blockingQueue.add("c"));
        System.out.println(blockingQueue.remove());
        System.out.println(blockingQueue.remove());
        System.out.println(blockingQueue.remove());
//        System.out.println(blockingQueue.remove()); //移除隊(duì)列當(dāng)中的元素，如果有則返回移除的元素，沒(méi)有則拋出異常：java.util.NoSuchElementException。
//        System.out.println(blockingQueue.element()); //獲取隊(duì)列當(dāng)中的元素，如果有則返回，沒(méi)有則拋出異常：java.util.NoSuchElementException。
//        System.out.println(blockingQueue.add("d")); //當(dāng)隊(duì)列已滿時(shí)，往隊(duì)列里添加元素，則會(huì)拋出異常：Queue full。
    }

private static final BlockingQueue<String> blockingQueue = new ArrayBlockingQueue<>(3);
	//特殊值
    @Test
    public void test2(){
        System.out.println(blockingQueue.offer("a"));
        System.out.println(blockingQueue.offer("b"));
        System.out.println(blockingQueue.offer("c"));
        System.out.println(blockingQueue.offer("d")); //往隊(duì)列里面添加元素，超出隊(duì)列長(zhǎng)度則返回false。
        System.out.println(blockingQueue.poll());
        System.out.println(blockingQueue.poll());
        System.out.println(blockingQueue.poll());
        System.out.println(blockingQueue.poll()); //移除隊(duì)列里面的元素，如果有元素，則返回元素，沒(méi)有則返回null。
    }

private static final BlockingQueue<String> blockingQueue = new ArrayBlockingQueue<>(3);
	//阻塞
    @Test
    public void test3() throws InterruptedException {
        blockingQueue.put("a");
        blockingQueue.put("b");
        blockingQueue.put("c");
//        blockingQueue.put("d"); //如果隊(duì)列已經(jīng)滿了，則一直阻塞，直到隊(duì)列有位置。
        System.out.println(blockingQueue.take());
        System.out.println(blockingQueue.take());
        System.out.println(blockingQueue.take());
//        System.out.println(blockingQueue.take()); //如果隊(duì)列沒(méi)有元素，則一直阻塞，直到隊(duì)列有元素。
    }

private static final BlockingQueue<String> blockingQueue = new ArrayBlockingQueue<>(3);
	//超時(shí)
    @Test
    public void test4() throws InterruptedException {
        System.out.println(blockingQueue.offer("a"));
        System.out.println(blockingQueue.offer("b"));
        System.out.println(blockingQueue.offer("c"));
        System.out.println(blockingQueue.offer("d",3, TimeUnit.SECONDS)); //往隊(duì)列里面添加元素，如果隊(duì)列已滿，則等待指定時(shí)間再次往隊(duì)列里面設(shè)置元素，設(shè)置成功返回true，失敗返回false。
        System.out.println(blockingQueue.poll(3,TimeUnit.SECONDS)); //移除隊(duì)列里面的元素，如果隊(duì)列里面有元素，則返回元素，沒(méi)有則等待指定時(shí)間再次移除隊(duì)列里面的元素，如果有元素則返回元素，沒(méi)有則返回null
    }