【JUC 阻塞队列中常用的四组方法】

本文主要是介绍【JUC 阻塞队列中常用的四组方法】，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

---

BlockingQueue 中的 4 组不同的方法

	抛异常	特定值	阻塞	超时
插入	add(o)	offset(o)	put(o)	offset(o, time, unit)
移除	remove()	poll()	take()	poll(time, unit)
检查	element()	peek()

---

提示：以下是本篇文章正文内容，下面案例可供参考

① add，remove，element

相当于一个普通的队列

富二代，脾气暴躁，稍微不合心意，就会抛出异常（你不说，我都不知道我这么🐂逼呢）。

代码如下（示例）：

public class Test {public static void main(String[] args) throws InterruptedException {// 第一组，抛出异常组// add 和 remove，element// 指定容量为 3BlockingQueue<String> blockingQueue = new ArrayBlockingQueue<>(3);System.out.println(blockingQueue.add("a"));System.out.println(blockingQueue.add("b"));System.out.println(blockingQueue.add("c"));// 添加第 4 个
//        blockingQueue.add("d");/** 抛出如下异常** Exception in thread "main" java.lang.IllegalStateException: Queue full*/// 判断队列是否为 null，如果是则抛异常，不为空返回队首元素，但不删除System.out.println(blockingQueue.element());// 队列，先进先出System.out.println(blockingQueue.remove());System.out.println(blockingQueue.remove());System.out.println(blockingQueue.remove());// 无元素，仍要出队列
//        System.out.println(blockingQueue.remove());/*** 抛出异常* Exception in thread "main" java.util.NoSuchElementException*/}
}

---

② offer，poll，peek

还是一个普通的队列
普通人，脾气温和，讲道理，不合适就返回一个特殊值。（施主如果听不懂大乘佛法，贫僧也是略懂一些拳脚）

代码如下（示例）：

public class Test {public static void main(String[] args) throws InterruptedException {// 第二组，返回特殊值// offer，poll，peek// 指定容量为 3BlockingQueue<String> blockingQueue = new ArrayBlockingQueue<>(3);System.out.println(blockingQueue.offer("a"));System.out.println(blockingQueue.offer("b"));System.out.println(blockingQueue.offer("c"));// 如果队列不为 null，返回队列头元素，队列为空返回 null
//        System.out.println(blockingQueue.peek());// 插入第四个元素
//        System.out.println(blockingQueue.offer("d"));/*** 进不去，返回* false*/System.out.println(blockingQueue.poll());System.out.println(blockingQueue.poll());System.out.println(blockingQueue.poll());System.out.println(blockingQueue.poll());/** 没有第四个，返回* null*/}
}

---

③ put，take

这时候才是阻塞队列
老实人，一直等待，直到她回心转意（燕子，没有你我怎么活啊~~~）

代码如下（示例）：

public class Test {public static void main(String[] args) throws InterruptedException {// 第三组，阻塞（无返回值）// put，takeBlockingQueue<String> blockingQueue = new ArrayBlockingQueue<>(3);blockingQueue.put("a");blockingQueue.put("b");blockingQueue.put("c");//        blockingQueue.put("d");/*** 一直卡住，直到有其他线程取出*/blockingQueue.take();blockingQueue.take();blockingQueue.take();//        blockingQueue.take();/*** 一直卡住，直到有其他线程放入新的元素*/}
}

---

④ offset(o, time, unit)，poll(time, unit)

阻塞队列
土豪，就是任性（给你机会你也不中用啊）

public class Test {public static void main(String[] args) throws InterruptedException {// 第四组，有的等待时间// 容量为 3BlockingQueue<String> blockingQueue = new ArrayBlockingQueue<>(3);// 有空间相当于普通的 offsetSystem.out.println(blockingQueue.offer("a", 2L, TimeUnit.SECONDS));System.out.println(blockingQueue.offer("b", 2L, TimeUnit.SECONDS));System.out.println(blockingQueue.offer("c", 2L, TimeUnit.SECONDS));//        System.out.println(blockingQueue.offer("d", 2L, TimeUnit.SECONDS));/** 两秒内不要，我就不给了* 等待两秒后，直接返回 false*/// 有元素，相当于普通的 pollSystem.out.println(blockingQueue.poll(2, TimeUnit.SECONDS));System.out.println(blockingQueue.poll(2, TimeUnit.SECONDS));System.out.println(blockingQueue.poll(2, TimeUnit.SECONDS));//        System.out.println(blockingQueue.poll(2, TimeUnit.SECONDS));/** 两秒内不给，我就不要了*      等待两秒。返回 null**/}
}

这篇关于【JUC 阻塞队列中常用的四组方法】的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！

---