Java ArrayBlockingQueue add()方法

ArrayBlockingQueue 是有边界的、阻塞的队列，它在内部存储了由数组支持的元素。

ArrayBlockingQueue 类是Java集合框架的一个成员。
有界意味着它将有一个固定的大小，你不能存储超过队列容量的元素数量。
该队列也遵循FIFO（先进先出）规则来存储和移除队列中的元素。
如果你试图把一个元素放进一个满的队列或从一个空的队列中取出一个元素，那么队列将阻止你。

add (E e) 方法在这个队列的尾部插入作为参数传递给该方法的元素。如果添加的元素超过了队列的容量，那么这个方法将抛出一个IllegalStateException。如果添加元素成功，该方法返回true，否则将抛出一个IllegalStateException。

语法

public boolean add(E e)

参数:

e – 要添加到队列中的元素。

返回值:

如果添加成功则为true。

抛出:

IllegalStateException – 如果此队列已满

NullPointerException – 如果指定的元素为空。

例1

下面的程序说明了向ArrayBlockingQueue添加元素。

// Java Program to Demonstrate add(E e) method
// of ArrayBlockingQueue.
import java.util.ArrayList;
import java.util.concurrent.ArrayBlockingQueue;
  
public class GFG {
  
    public static void main(String[] args)
    {
        // define capacity of ArrayBlockingQueue
        int capacity = 10;
  
        // create object of ArrayBlockingQueue
        ArrayBlockingQueue<Integer> queue = new ArrayBlockingQueue<Integer>(capacity);
  
        // Add element to ArrayBlockingQueue
        queue.add(23);
  
        // print queue after add operation
        System.out.println("After adding 23");
        System.out.println(queue);
  
        // add more numbers
        queue.add(32);
        queue.add(45);
        queue.add(12);
  
        // print queue after add operation
        System.out.println("After adding 32, 45, 12");
        System.out.println(queue);
  
        // add more numbers
        queue.add(27);
        queue.add(67);
  
        // print queue after add operation
        System.out.println("After adding 27, 67");
        System.out.println(queue);
    }
}

**Output :**
After adding 23
[23]
After adding 32, 45, 12
[23, 32, 45, 12]
After adding 27, 67
[23, 32, 45, 12, 27, 67]

例2
下面的程序说明了向ArrayBlockingQueue中添加元素，如果队列满了，则抛出异常。

// Java Program to Demonstrate add(E e) method
// of ArrayBlockingQueue.
import java.util.ArrayList;
import java.util.concurrent.ArrayBlockingQueue;
  
public class GFG {
  
    public static void main(String[] args)
    {
  
        // define capacity of ArrayBlockingQueue to 5 elements
        int capacity = 5;
  
        // create object of ArrayBlockingQueue
        ArrayBlockingQueue<Integer> queue = new ArrayBlockingQueue<Integer>(capacity);
  
        // Add 5 element to ArrayBlockingQueue
        queue.add(23);
        queue.add(32);
        queue.add(45);
        queue.add(12);
        queue.add(27);
  
        // print queue after add operation
        System.out.println("After adding all 5 elements to queue");
        System.out.println(queue);
  
        // check whether queue is full or not.
        if (queue.remainingCapacity() == 0) {
            System.out.println("Queue is full");
        }
        else {
            System.out.println("Queue is not full");
        }
  
        // try to add more elements
        // If exception thrown print the exception.
        try {
            Boolean response = queue.add(27);
        }
        catch (Exception e) {
            e.printStackTrace();
        }
    }
}

输出 :

After adding all 5 elements to queue
[23, 32, 45, 12, 27]
Queue is full
java.lang.IllegalStateException: Queue full
    at java.util.AbstractQueue.add(Unknown Source)
    at java.util.concurrent.ArrayBlockingQueue.add(Unknown Source)
    at defaultpackage.GFG.main(GFG.java:38)

参考资料:
https://docs.oracle.com/javase/7/docs/api/java/util/concurrent/ArrayBlockingQueue.html#add(E)