LinkedBlockingQueue 和 addAll()

Question

如果尝试将一个集合添加到阻塞队列中，超过了阻塞队列的剩余容量，会发生什么？从我目前阅读的文档中并不清楚。

     LinkedBlockingQueue<Integer> foo = new LinkedBlockingQueue<Integer>(3);
        foo.add(1);
        foo.add(2);
        LinkedBlockingQueue<Integer> tenElements = new LinkedBlockingQueue<Integer(10); 
        for(int i = 0; i < 10; i++)
            tenElements.add(i);   

        foo.addAll(collectionWith10elements);

- paiego

---

我认为提供元素的线程将被阻塞，直到从foo消耗掉某个元素，以便插入空间。 - NickDelta

只需尝试并查看发生了什么？看一下源代码？去找Javadoc？ - Christine

Answer 1

Java中add()方法的文档说明，如果队列已满，则会抛出一个IllegalStateException异常：

如果立即插入指定元素而不违反容量限制，则将其插入此队列，并在成功时返回true，如果当前没有可用空间，则抛出IllegalStateException异常。

当您尝试以下代码时：

public static void main(String[] args) throws Exception {
    ArrayList<Integer> l = new ArrayList<Integer>();
    l.add(10);
    l.add(20);
    l.add(30);
    l.add(40);
    l.add(50);
    LinkedBlockingQueue<Integer> foo = new LinkedBlockingQueue<Integer>(3);
    foo.add(1);
    foo.add(2);
    foo.addAll(l);
}

您将会得到以下异常：

Exception in thread "main" java.lang.IllegalStateException: Queue full
    at java.util.AbstractQueue.add(AbstractQueue.java:98)
    at java.util.AbstractQueue.addAll(AbstractQueue.java:187)
    at Test.main(Test.java:16)

- Progman

---

这是正确的答案。我实际上混淆了add()和put()。没有“阻塞”的putAll()，所以这不是问题。 - paiego

Answer 2

一旦队列容量达到，持久化在队列中的元素应该被消费，否则我们将会得到以下异常：

Exception in thread "main" java.lang.IllegalStateException: Queue full
    at java.util.AbstractQueue.add(AbstractQueue.java:98)
    at java.util.AbstractQueue.addAll(AbstractQueue.java:187)

- Sarjit

Answer 3

我在我的IDE上测试了它，结果是：

Exception in thread "main" java.lang.IllegalStateException: Queue full
    at java.util.AbstractQueue.add(AbstractQueue.java:98)
    at java.util.AbstractQueue.addAll(AbstractQueue.java:187)

如果您想了解更多，请前往 这里。

- Laser Infinite