Queue 阻塞队列 PriorityBlockingQueue

Posted 2022-05-30 han6

PriorityBlockingQueue 带优先级的无界的阻塞队列

 

package com.dh.learn.queue;

import java.util.concurrent.BlockingQueue;
import java.util.concurrent.PriorityBlockingQueue;

public class LearnPriorityBlockingQueue 
    //PriorityBlockingQueue 就是在PriorityQueue的基础上，添加了ReentrantLock与Condition实现了阻塞

    //PriorityBlockingQueue  有优先级，且无界

    // 由于队列是无界的，所以不存在添加元素时阻塞(自动扩容)。只有队列为空，从队列中取元素时，才会阻塞

    // 底层数据结构是：数组  数组的顺序是：小顶堆(根节点比两个子节点都小)

    public static void main(String[] args) 
        // 可以指定初始容量大小 以及 比较器
        BlockingQueue<String> priorityBlockingQueue = new PriorityBlockingQueue<>();