BlockingQueue阻塞隊列

BlockingQueue的四組API

/**BlockQueue的四組API
 * 1.拋出異常
 * 2.有返回值，不拋出異常
 * 3.阻塞等待
 * 4.超時等待
 */
public class BlockQueueTest {
    public static void main(String[] args) throws InterruptedException {
        test03();
    }
​
    /**拋出異常
     * */
    public static void test01(){
        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.element());
        //IllegalStateException: Queue full 拋出異常，列滿
                  //blockingQueue.add("d");
        System.out.println(blockingQueue.remove());
        System.out.println(blockingQueue.remove());
        System.out.println(blockingQueue.remove());
        //.NoSuchElementException 隊空
        //System.out.println(blockingQueue.remove());
​
    }
    /**不拋出異常，有返回值
     * */
    public static void test02(){
        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.peek());
        //有返回值，不拋出異常
       // System.out.println(blockingQueue.offer("d"));
        System.out.println(blockingQueue.poll());
        System.out.println(blockingQueue.poll());
        System.out.println(blockingQueue.poll());
        //有返回值，不拋出異常
        //System.out.println(blockingQueue.poll());
    }
    /**阻塞等待，一直阻塞
     * */
    public static void test03() throws InterruptedException {
        ArrayBlockingQueue arrayBlockingQueue = new ArrayBlockingQueue<>(3);
        arrayBlockingQueue.put("a");
        arrayBlockingQueue.put("b");
        arrayBlockingQueue.put("c");
        //隊滿，阻塞等待，一直等待
        //arrayBlockingQueue.put("d");
        System.out.println(arrayBlockingQueue.take());
        System.out.println(arrayBlockingQueue.take());
        System.out.println(arrayBlockingQueue.take());
        //隊空，阻塞等待，一直等待
        //System.out.println(arrayBlockingQueue.take());
    }
    /**
     *超時等待，但不會一直等待，阻塞時間內等待，之後退出
     */
    public static void test04() throws InterruptedException {
        ArrayBlockingQueue blockingQueue = new ArrayBlockingQueue<>(3);
        System.out.println(blockingQueue.offer("a", 2, TimeUnit.SECONDS));
        System.out.println(blockingQueue.offer("b", 2, TimeUnit.SECONDS));
        System.out.println(blockingQueue.offer("c", 2, TimeUnit.SECONDS));
        //阻塞兩秒，隊滿返回false退出
        // System.out.println(blockingQueue.offer("c", 2, TimeUnit.SECONDS));
​
        System.out.println(blockingQueue.poll(2, TimeUnit.SECONDS));
        System.out.println(blockingQueue.poll(2, TimeUnit.SECONDS));
        System.out.println(blockingQueue.poll(2, TimeUnit.SECONDS));
        //阻塞異常，阻塞兩秒，隊空返回null
        // System.out.println(blockingQueue.poll(2, TimeUnit.SECONDS));
    }
}

SynchronousQueue同步隊列

特點：

• 插入操作必須等待隊列中的上一個元素被取出後才能插入，反之亦然。

• 同步隊列沒有存儲空間

• 存儲元素操作put（） ，讀取操作take( )

   

   

//同步隊列
public class SynchronousQueueTest {
    public static void main(String[] args) {
        //SynchronousQueue是BlockingQueue的子類
        BlockingQueue<String> synchronousQueue = new SynchronousQueue<>();
        new Thread(()->{
            try {
                System.out.println(Thread.currentThread().getName()+" put1");
                synchronousQueue.put("a");
                System.out.println(Thread.currentThread().getName()+" put2");
                synchronousQueue.put("b");
                System.out.println(Thread.currentThread().getName()+" put3");
                synchronousQueue.put("c");
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        },"A").start();
        new Thread(()->{
            try {
                TimeUnit.SECONDS.sleep(3);
                System.out.println(Thread.currentThread().getName()+"----"+synchronousQueue.take());
                TimeUnit.SECONDS.sleep(3);
                System.out.println(Thread.currentThread().getName()+"----"+synchronousQueue.take());
                TimeUnit.SECONDS.sleep(3);
                System.out.println(Thread.currentThread().getName()+"----"+synchronousQueue.take());
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        },"B").start();
    }
}