Java中的PriorityBlockingQueue size()方法

在Java中，PriorityBlockingQueue是一个实现了BlockingQueue接口的特殊队列，其内部的元素按照比较器的顺序进行排序。PriorityBlockingQueue在许多并发场景下是非常有用的，因为它支持多线程环境下的安全操作。其中的size()方法用于返回PriorityBlockingQueue中的元素数量，本篇文章将通过示例代码对其进行解释。

PriorityBlockingQueue的特性

在使用PriorityBlockingQueue时，需要注意其具有以下特性：

支持多线程并发操作，保证线程安全；
内部元素按照比较器的顺序进行排序；
是一个无界队列（即没有容量限制），但可以在构造PriorityBlockingQueue实例时指定初始容量。

size()方法的功能

size()方法用于返回PriorityBlockingQueue中的元素数量。

public int size() {
    final ReentrantLock lock = this.lock;
    lock.lock();
    try {
        return count;
    } finally {
        lock.unlock();
    }
}

可以看出，size()是一个同步方法，它使用了ReentrantLock来保证线程安全。当多个线程同时访问PriorityBlockingQueue时，如果有线程正在修改PriorityBlockingQueue的元素，其他线程则需要等到修改完成后才能调用size()方法。

示例代码

下面的示例展示了如何创建一个PriorityBlockingQueue并使用size()方法来获取其大小。

import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.PriorityBlockingQueue;

public class Example {

    public static void main(String[] args) {
        PriorityBlockingQueue<Integer> queue = new PriorityBlockingQueue<>();

        // 添加元素
        queue.add(3);
        queue.add(1);
        queue.add(5);

        // 获取元素数量
        int size = queue.size();
        System.out.println("Size of queue: " + size); // Output: 3
    }
}

在上面的示例中，我们创建了一个PriorityBlockingQueue实例，并向其添加了三个整数元素。随后，我们通过调用size()方法来获取PriorityBlockingQueue的大小（元素数量），并将结果输出到控制台中。