由于LinkedBlockingQueue 实现是线程安全的,实现了先进先出等特性,是作为生产者消费者的首选,LinkedBlockingQueue 可以指定容量,也可以不指定,不指定的话,默认最大是Integer.MAX_VALUE,其中主要用到put和take方法,put方法在队列满的时候会阻塞直到有队列成员被消费,take方法在队列空的时候会阻塞,直到有队列成员被放进来。下面是一个例子,一看就明白了。
package com.spell.designPattern.producer_consumer;
import java.util.UUID;
import java.util.concurrent.BlockingQueue;
/**
* 生产者类,任务是产生个uuid放在队列中
*
* @author Administrator
*
*/
public class Producer implements Runnable {
private BlockingQueue<String> queue;
public Producer(BlockingQueue<String> queue) {
this.queue = queue;
}
@Override
public void run() {
String uuid = UUID.randomUUID().toString();
try {
queue.put(uuid);
System.out
.println(Thread.currentThread() + " produce uuid:" + uuid);
} catch (InterruptedException e) {
System.out.println(e.getMessage());
}
}
}
package com.spell.designPattern.producer_consumer;
import java.util.concurrent.BlockingQueue;
/**
* 消费者队列,任务是取得队列中的uuid打印下
*
* @author Administrator
*
*/
public class Consumer implements Runnable {
private BlockingQueue<String> queue;
public Consumer(BlockingQueue<String> queue) {
this.queue = queue;
}
@Override
public void run() {
try {
String uuid = queue.take();
System.out
.println(Thread.currentThread() + " consume uuid:" + uuid);
} catch (InterruptedException e) {
System.out.println(e.getMessage());
}
}
}
package com.spell.designPattern.producer_consumer;
import java.util.concurrent.LinkedBlockingQueue;
/**
* 测试类
*
* @author Administrator
*
*/
public class Tester {
public static void main(String[] args) throws InterruptedException {
// 队列
LinkedBlockingQueue<String> queue = new LinkedBlockingQueue<String>(10);
// 生产者一号
Producer producer = new Producer(queue);
// 生产者二号
Producer producer2 = new Producer(queue);
// 消费者
Consumer consumer = new Consumer(queue);
for (int i = 0; i < 15; i++) {
new Thread(producer).start();
}
for (int i = 0; i < 15; i++) {
new Thread(producer2).start();
}
for (int i = 0; i < 30; i++) {
new Thread(consumer).start();
}
}
}
分享到:
相关推荐
NULL 博文链接:https://xiongjiajia.iteye.com/blog/2325943
并发容器之ArrayBlockingQueue和LinkedBlockingQueue实现原理详解
源码:BlockingQueue实现生产者消费者模式→ 输出结果截图 1. Queue接口 – 队列 public interface Queue extends Collection Collection的子接口,表示队列FIFO(First In First Out) 常用方法: (1)抛出异常...
linkedblockingqueue测试程序
首先 LinkedBlockingQueue 是一个 “可选且有界” 的阻塞队列实现,你可以根据需要指定队列的大小。 接下来,我将创建一个 LinkedBlockingQueue ,它最多可以包含100个元素: BlockingQueue<Integer> ...
【2018最新最详细】并发多线程教程,课程结构如下 1.并发编程的优缺点 2.线程的状态转换以及基本操作 3.java内存模型以及happens-before规则 4.彻底理解synchronized ...27.一篇文章,让你彻底弄懂生产者--消费者问题
并发队列ConcurrentLinkedQueue和阻塞队列LinkedBlockingQueue用法
LinkedBlockingQueuejava.pdf
单向链表源码 博文链接:https://uule.iteye.com/blog/1561753
JDK容器学习之Queue:LinkedBlockingQueue
主要介绍了详细分析Java并发集合LinkedBlockingQueue的用法,小编觉得挺不错的,现在分享给大家,也给大家做个参考。一起跟随小编过来看看吧
主要介绍了java中LinkedBlockingQueue与ArrayBlockingQueue的异同,需要的朋友可以参考下
Java线程池的几种实现方法和区别介绍 使用:LinkedBlockingQueue实现线程池讲解
NULL 博文链接:https://kanpiaoxue.iteye.com/blog/2101309
主要重点是在不牺牲可读性的前提下实现简单性和高性能。 实际上,我试图提供有关代码的良好文档以及一些用法示例。 提供的队列 ArrayBlockingQueue :由切片支持的有界阻塞队列 LinkedBlockingQueue :由容器/列表...
网络爬虫Web-Crawler 是使用最少的组件构建的HTTP ... 这里给出的实现在以下方面与架构不同进程内 LinkedBlockingQueue 已被用作组件之间的消息传递机制持久性由 HSQLDB 的内存实例提供索引器和页面缓存组件的模拟实现
│ 高并发编程第一阶段26讲、多线程下的生产者消费者模型,以及详细介绍notifyAll方法.mp4 │ 高并发编程第一阶段27讲、wait和sleep的本质区别是什么,深入分析(面试常见问题).mp4 │ 高并发编程第一阶段28讲、...
│ 高并发编程第一阶段26讲、多线程下的生产者消费者模型,以及详细介绍notifyAll方法.mp4 │ 高并发编程第一阶段27讲、wait和sleep的本质区别是什么,深入分析(面试常见问题).mp4 │ 高并发编程第一阶段28讲、...