📜  Java中的 ArrayBlockingQueue add() 方法

📅  最后修改于: 2022-05-13 01:55:00.371000             🧑  作者: Mango

Java中的 ArrayBlockingQueue add() 方法

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

  • ArrayBlockingQueue类是Java集合框架的成员。
  • 有界意味着它将具有固定大小,您不能存储数量超过队列容量的元素。
  • 队列还遵循 FIFO(先进先出)规则来存储和删除队列中的元素。
  • 如果你试图将一个元素放入一个满队列或从一个空队列中取出一个元素,那么队列会阻止你。

add (E e)方法将作为参数传递给该方法的元素插入到此队列的尾部。如果添加元素超出队列的容量,则该方法将抛出 IllegalStateException。如果添加元素成功,则此方法返回 true,否则将抛出 IllegalStateException。
句法:

public boolean add(E e)

范围:
e - 要添加到队列的元素。
返回值:
如果添加成功,则为 true。
抛出:
IllegalStateException – 如果此队列已满
NullPointerException – 如果指定元素为 null

示例 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 queue = new ArrayBlockingQueue(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
下面的程序说明了将 Element 添加到 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 queue = new ArrayBlockingQueue(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();
        }
    }
}
Output :
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 Java)