Java中的ArrayBlockingQueue peek()方法

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

• ArrayBlockingQueue 类是Java集合框架的一部分。
• 有界意味着它将具有固定的大小，你不能存储超过队列容量的元素。
• 队列也遵循FIFO(先进先出)规则，用于存储和删除队列中的元素。
• 如果你试图将元素放入一个已满的队列中，或从一个空的队列中取出元素，那么队列将阻塞你。

peek() 方法用于返回队列头部元素。它检索但不删除该队列的头部元素。如果队列为空，则该方法返回null。

语法:

public E peek()

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

返回值: 该方法返回该队列头部的元素。

下面的程序说明了ArrayBlockingQueue的peek()方法。

程序 1:

// 演示ArrayBlockingQueue的peek()方法的程序

import java.util.concurrent.ArrayBlockingQueue;

public class GFG {

public static void main(String[] args) {
    // 定义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.println("添加数字后队列为 ");
    System.out.println(queue);

    // 使用peek()方法打印队列头部
    System.out.println("队列头部 "+queue.peek());

}
}

输出:

添加数字后队列为 
[23, 32, 45, 12]
队列头部 23

程序 2:

// 展示 ArrayBlockingQueue 中 peek() 方法的示例代码
 
import java.util.concurrent.ArrayBlockingQueue;
 
public class GFG {
     
    // 创建一个 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) {
        GFG gfg=new GFG();
        gfg.offerExample();
         
    }
     
    // 示例方法
    public void offerExample() {
         
        //定义 ArrayBlockingQueue 的容量
        int capacity = 5;
             
        // 创建 ArrayBlockingQueue 对象
        ArrayBlockingQueue<User> queue = new ArrayBlockingQueue<User>(capacity);
             
        // 创建 User 对象
        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);
             
        // 获取 queue 的首个元素
        User head = queue.peek();
           
        // 输出首个元素
        System.out.println("Details of First User Inserted");
        System.out.println("User Name : " + head.name);
        System.out.println("User Age : " + head.age);
    }
}

输出:

Details of First User Inserted
User Name : Aman
User Age : 24

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