Java中的ArrayBlockingQueue take()方法

ArrayBlockingQueue 是一种有界、阻塞队列，内部存储元素由数组支持。

ArrayBlockingQueue 类是Java Collections Framework的一个成员。
有界表示它将具有固定大小，您不能存储超过队列容量的元素数量。
该队列还遵循先进先出（FIFO）规则，用于存储和从队列中删除元素。
如果您尝试将元素放入满队列或从空队列中取出元素，则队列会阻止您。

take()方法用于检索并删除此队列的头部。如果队列为空，则它将等待直到有元素可用。

语法：

public E take()throws InterruptedException

参数： 该方法不接受任何参数。

返回值： 该方法返回此队列的头部值。

异常： 该方法在等待时中断时会抛出 InterruptedException 。

下面的程序说明了ArrayBlockingQueue的take（）方法：

程序 1 :

// 程序演示ArrayBlockingQueue的take()方法
 
import java.util.concurrent.ArrayBlockingQueue;
 
public class GFG {
 
public static void main(String[] args)
                  throws InterruptedException{
    // 定义ArrayBlockingQueue的容量
    int capacity = 5;
     
    // 创建 ArrayBlockingQueue 的对象
    ArrayBlockingQueue<Integer> queue =
        new ArrayBlockingQueue<Integer>(capacity);
     
    // 向 ArrayBlockingQueue 中添加元素
    queue.add(23);
    queue.add(32);
    queue.add(45);
    queue.add(12);
     
    // 添加数字后打印队列
    System.out.print("添加数字后的队列："
                                                +queue);
 
        // 应用 take() 方法
    int head=queue.take();
     
    // 用 take() 方法打印队列的头部
    System.out.println("已删除的队列头部为 "
                                                +head);
    System.out.print("删除头部后的队列：");
    System.out.println(queue);
     
    // 应用 take() 方法
    head = queue.take();
     
    // 用 take() 方法打印队列的头部
    System.out.println("已删除的队列头部为 "
                                               + head);
    System.out.print("删除头部后的队列：");
    System.out.println(queue);
     
}
}

输出：

添加数字后的队列：[23, 32, 45, 12]已删除的队列头部为 23
删除头部后的队列：[32, 45, 12]
已删除的队列头部为 32
删除头部后的队列：[45, 12]

程序 2：

// 展示 ArrayBlockingQueue 的 take() 方法的程序
 
import java.util.concurrent.ArrayBlockingQueue;
 
public class GFG {
 
    // 创建一个拥有 name 和 age 属性的 User 对象
    public class User {
 
        public String name;
        public String age;
        User(String name, String age)
        {
            this.name = name;
            this.age = age;
        }
    }
 
    // 主方法
    public static void main(String[] args)
                        throws InterruptedException
    {
        GFG gfg = new GFG();
        gfg.takeMethodExample();
    }
 
    // take() 方法的示例
    public void takeMethodExample()
                        throws InterruptedException
    {
 
        // 定义 ArrayBlockingQueue 的容量为 5
        int capacity = 5;
 
        // 创建 ArrayBlockingQueue 对象
        ArrayBlockingQueue<User> queue =
               new ArrayBlockingQueue<User>(capacity);
 
        // 创建用户对象
        User user1 = new User("Aman", "24");
        User user2 = new User("Amar", "23");
        User user3 = new User("Sanjeet", "25");
        User user4 = new User("Suvo", "26");
        User user5 = new User("Ravi", "22");
 
        // 将对象添加到 ArrayBlockingQueue
        queue.offer(user1);
        queue.offer(user2);
        queue.offer(user3);
        queue.offer(user4);
        queue.offer(user5);
 
        // 执行 take() 方法
        User head = queue.take();
 
        // 打印 head
        System.out.println("Details of User Removed"
                    +" After Applying take() Method");
        System.out.println("User Name : " + head.name);
        System.out.println("User Age : " + head.age);
 
        // 执行 take() 方法
        head = queue.take();
 
        // 打印 head
        System.out.println("Details of User Removed"+
                      " After Applying take() Method");
        System.out.println("User Name : " + head.name);
        System.out.println("User Age : " + head.age);
    }
}

输出:

Details of User Removed After Applying take() Method
User Name : Aman
User Age : 24
Details of User Removed After Applying take() Method
User Name : Amar
User Age : 23

参考： https://docs.oracle.com/javase/7/docs/api/java/util/concurrent/ArrayBlockingQueue.html#take()