Java ArrayBlockingQueue put()方法

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

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

如果队列没有满， put (E e) 方法会将作为参数传递给方法的元素插入这个队列(ArrayBlockingQueue)的尾部。如果 队列是满的，那么它将等待空间变得可用。

语法

public void put(E e)  throws InterruptedException

参数：

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

抛出

InterruptedException – 如果在等待时被打断。

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

下面的程序说明了ArrayBlockingQueue的put(E e)方法。

例子1

// Java Program to demonstrate put(E e)
// method of ArrayBlockingQueue.
  
import java.util.concurrent.ArrayBlockingQueue;
  
public class GFG {
  
    public static void main(String[] args) throws InterruptedException
    {
        // define capacity of ArrayBlockingQueue
        int capacity = 5;
  
        // create object of ArrayBlockingQueue
        ArrayBlockingQueue<Integer> queue = new ArrayBlockingQueue<Integer>(capacity);
  
        // Add elements to ArrayBlockingQueue using put method
        queue.put(223);
        queue.put(546);
        queue.put(986);
        queue.put(357);
        queue.put(964);
  
        // print Queue
        System.out.println("queue contains " + queue);
    }
}

**Output :**
queue contains [223, 546, 986, 357, 964]

例2

// Java Program to demonstrate put(E e)
// method of ArrayBlockingQueue
  
import java.util.concurrent.ArrayBlockingQueue;
  
public class GFG {
  
    public static void main(String[] args) throws InterruptedException
    {
        // define capacity of ArrayBlockingQueue
        int capacity = 5;
  
        // create object of ArrayBlockingQueue
        ArrayBlockingQueue<String> queue = new ArrayBlockingQueue<String>(capacity);
  
        // Add elements to ArrayBlockingQueue using put method
        queue.put("StarWars");
        queue.put("SuperMan");
        queue.put("Flash");
        queue.put("BatMan");
        queue.put("Avengers");
  
        // print Queue
        System.out.println("queue contains " + queue);
  
        // remove some elements
        queue.remove();
        queue.remove();
  
        // Add elements to ArrayBlockingQueue using put method
        queue.put("CaptainAmerica");
        queue.put("Thor");
  
        System.out.println("queue contains " + queue);
    }
}

输出 :

queue contains [StarWars, SuperMan, Flash, BatMan, Avengers]
queue contains [Flash, BatMan, Avengers, CaptainAmerica, Thor]

参考资料:

https://docs.oracle.com/javase/7/docs/api/java/util/concurrent/ArrayBlockingQueue.html#put(E)