PriorityBlockingQueue add()方法在Java中

在Java中，PriorityBlockingQueue是一个线程安全的队列，它继承自AbstractQueue类并实现了BlockingQueue接口。

PriorityBlockingQueue的优先级是由其元素自身的比较器来决定的。在元素被插入到队列中时，元素将会根据其自身的比较器进行排序，优先级高的元素先被取出。如果两个元素的优先级相同，则它们将遵守FIFO原则（先进先出）。

当我们需要将元素插入到PriorityBlockingQueue中时，我们可以使用add()方法。add()方法的作用是将指定元素插入到队列中，如果成功，则返回true。如果队列已满，则抛出IllegalStateException异常。

下面是PriorityBlockingQueue中add()方法的示例代码：

import java.util.concurrent.PriorityBlockingQueue;

public class PriorityBlockingQueueAddDemo {
    public static void main(String[] args) {
        PriorityBlockingQueue<String> queue = new PriorityBlockingQueue<>(3);
        // 添加元素
        boolean result1 = queue.add("Java");
        boolean result2 = queue.add("Python");
        boolean result3 = queue.add("C++");
        boolean result4 = queue.add("Go");
        System.out.println("result1: " + result1);
        System.out.println("result2: " + result2);
        System.out.println("result3: " + result3);
        System.out.println("result4: " + result4);
    }
}

上面的示例代码创建了一个容量为3的PriorityBlockingQueue，然后向队列中插入了4个元素。由于队列已满，因此会抛出IllegalStateException异常。输出结果如下：

result1: true
result2: true
result3: true
Exception in thread "main" java.lang.IllegalStateException: Queue full
    at java.util.AbstractQueue.add(AbstractQueue.java:98)
    at java.util.concurrent.PriorityBlockingQueue.add(PriorityBlockingQueue.java:401)
    at PriorityBlockingQueueAddDemo.main(PriorityBlockingQueueAddDemo.java:11)

我们可以看到，”Java”、”Python”和”C++”成功地被插入到了队列中，而”Go”则无法插入到队列中并抛出了异常。

除了add()方法之外，PriorityBlockingQueue还提供了offer()方法，它的作用与add()方法基本一致，不过当队列已满时，offer()方法会返回false而不是抛出异常。

下面是PriorityBlockingQueue中offer()方法的示例代码：

import java.util.concurrent.PriorityBlockingQueue;

public class PriorityBlockingQueueOfferDemo {
    public static void main(String[] args) {
        PriorityBlockingQueue<String> queue = new PriorityBlockingQueue<>(3);
        // 添加元素
        boolean result1 = queue.offer("Java");
        boolean result2 = queue.offer("Python");
        boolean result3 = queue.offer("C++");
        boolean result4 = queue.offer("Go");
        System.out.println("result1: " + result1);
        System.out.println("result2: " + result2);
        System.out.println("result3: " + result3);
        System.out.println("result4: " + result4);
    }
}

上面的示例代码向队列中插入了4个元素，但是队列的容量只有3。由于队列已满，offer()方法会返回false而不是抛出异常。输出结果如下：

result1: true
result2: true
result3: true
result4: false

结论

通过本文我们了解了PriorityBlockingQueue中add()方法的使用。当队列已满时，add()方法会抛出IllegalStateException异常，而offer()方法则会返回false。使用时根据实际需求进行选择。