LinkedBlockingQueue的“增加方法”包括add(失败抛IllegalStateException)、offer(失败返回false)、put(满则阻塞)和带超时的offer(超时返回false),均线程安全,默认无界。
LinkedBlockingQueue 是 Java 并发包(java.util.concurrent)中一个基于链表实现的、线程安全的阻塞队列。它的“增加方法”指的是向队列尾部插入元素的操作,主要有以下几种,按行为和异常处理方式区分:
尝试将元素插入队列尾部。如果队列已满(注意:LinkedBlockingQueue 默认是无界队列,但可指定容量),则抛出 IllegalStateException。
offer(e),若返回 false 就抛异常queue.add("item");
尝试插入元素,成功返回 true;若队列已满(比如构造时指定了固定容量),则直接返回 false,不阻塞也不抛异常。
true
if (!queue.offer("item")) { /* 处理失败 */ }
将元素插入队列尾部;如果队列已满,当前线程会**一直阻塞**,直到有空间可用(比如其他线程消费了元素)。
InterruptedException,需捕获处理queue.put("item"); // 可能阻塞
尝试插入元素,若队列满,则最多等待指定时间;超时前获得空间则成功返回 true,超时仍未成功则返回 false。
InterruptedException
boolean success = queue.offer("item", 3, TimeUnit.SECONDS);
注意:所有这些方法都是线程安全的,内部通过可重入锁(ReentrantLock)和条件变量(Condition)保证并发正确性。默认构造的 LinkedBlockingQueue 容量为 Integer.MAX_VALUE,即逻辑上“无界”,此时 add 和 offer 几乎不会失败,而 put 也不会阻塞。
基本上就这些。