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();
    }
}

標籤：Java

上一篇：java學習之反射機制

下一篇：Mybatis-Plus 實作樂觀鎖