BlockingQueue add()在Java中的例子

BlockingQueue add()在Java中的例子

BlockingQueue 接口的 add(E e) 方法会将传入参数的元素插入到队列的末尾,如果有空间的话。如果 BlockingQueue 的容量限制且没有空间可供插入,则它会返回一个 IllegalStateException。

语法:

public void add(E e)

参数: 该方法接受一个必需参数 e ,它表示要插入到 BlockingQueue 末尾的元素。

返回值: 如果成功插入,则该方法返回true。

异常:

  • IllegalStateException :如果由于容量限制不能在此时添加元素
  • NullPointerException :如果指定的元素为null

注意: BlockingQueueadd() 方法继承自Java中的 Queue 类。

以下程序演示了 BlockingQueue 的add()方法:

程序1:

// Java程序演示BlockingQueue的add()方法
 
import java.util.*;
import java.util.concurrent.BlockingQueue;
import java.util.concurrent.LinkedBlockingDeque;
 
public class GFG {
    public static void main(String[] args)
        throws IllegalStateException
    {
 
        // 创建BlockingQueue对象
        BlockingQueue<Integer> BQ
            = new LinkedBlockingDeque<Integer>();
 
        // 将数字添加到BlockingQueue中
        BQ.add(7855642);
        BQ.add(35658786);
        BQ.add(5278367);
        BQ.add(74381793);
 
        // 在删除之前打印BlockingQueue
        System.out.println("Blocking Queue: " + BQ);
    }
}

输出

Blocking Queue: [7855642, 35658786, 5278367, 74381793]

程序2:

// Java程序演示LinkedBlockingDeque的add()方法
// 当插入null时
 
import java.util.*;
import java.util.concurrent.LinkedBlockingDeque;
 
public class GFG {
    public static void main(String[] args)
        throws IllegalStateException
    {
 
        // 创建LinkedBlockingDeque对象
        LinkedBlockingDeque<Integer> BQ
            = new LinkedBlockingDeque<Integer>();
 
        // 在LinkedBlockingDeque末尾添加数字
        BQ.add(7855642);
        BQ.add(35658786);
        BQ.add(5278367);
 
        // null
        BQ.add(null);
 
        // 在删除之前打印Deque
        System.out.println("Linked Blocking Deque: " + BQ);
    }
}

输出:

Exception in thread "main" java.lang.IllegalStateException: Deque full
    at java.util.concurrent.LinkedBlockingDeque.addLast(LinkedBlockingDeque.java:335)
    at java.util.concurrent.LinkedBlockingDeque.add(LinkedBlockingDeque.java:633)
    at GFG.main(GFG.java:25)

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

Python教程

Java教程

Web教程

数据库教程

图形图像教程

大数据教程

开发工具教程

计算机教程