BlockingQueue add()在Java中的例子
BlockingQueue 接口的 add(E e) 方法会将传入参数的元素插入到队列的末尾,如果有空间的话。如果 BlockingQueue 的容量限制且没有空间可供插入,则它会返回一个 IllegalStateException。
语法:
public void add(E e)
参数: 该方法接受一个必需参数 e ,它表示要插入到 BlockingQueue 末尾的元素。
返回值: 如果成功插入,则该方法返回true。
异常:
- IllegalStateException :如果由于容量限制不能在此时添加元素
- NullPointerException :如果指定的元素为null
注意: BlockingQueue 的 add() 方法继承自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)
极客教程