生产者消费者3.0 阻塞队列版本


import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.BlockingQueue;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.atomic.AtomicInteger;/*** 描述:生产者消费者 3.0  阻塞队列 版** @author 小纸人* @create 2019-07-31 22:05* <p>* 使用的技术 ：* volatile、CAS、atomicInteger、BlockQueue、线程交互、原子引用*/class MyResource {private volatile boolean FLAG = true; //默认开启，生产 + 消费private AtomicInteger atomicInteger = new AtomicInteger();BlockingQueue<String> blockingQueue = null;public MyResource(BlockingQueue<String> blockingQueue) {this.blockingQueue = blockingQueue;System.out.println("使用了：" + blockingQueue.getClass().getName());}public void myProd() throws Exception {String data = null;boolean returnVal = false;while (FLAG) {data = atomicInteger.incrementAndGet() + "";returnVal = blockingQueue.offer(data, 2L, TimeUnit.SECONDS);if (returnVal) {System.out.println(Thread.currentThread().getName() + "\t 插入队列" + data + "成功");} else {System.out.println(Thread.currentThread().getName() + "\t 插入队列" + data + "失败");}//一秒钟生产一次TimeUnit.SECONDS.sleep(1);}System.out.println(Thread.currentThread().getName() + "\t FLAG = false，生产结束");}public void myConsumer() throws Exception {String result = null;while (FLAG) {result = blockingQueue.poll(2L, TimeUnit.SECONDS);if (null == result || result.equalsIgnoreCase("")) {System.out.println(Thread.currentThread().getName() + "\t 超过2秒没有消费。消费退出");return;}System.out.println(Thread.currentThread().getName() + "\t 消费" + result + "成功");}}public void stop() {this.FLAG = false;}
}public class Version3_0 {public static void main(String[] args) {MyResource myResource = new MyResource(new ArrayBlockingQueue<>(10));new Thread(() -> {System.out.println("生产者线程启动");try {myResource.myProd();} catch (Exception e) {e.printStackTrace();}}, "Prod").start();new Thread(() -> {System.out.println("消费者线程启动");try {myResource.myConsumer();} catch (Exception e) {e.printStackTrace();}}, "Consumer").start();//暂停一会线程try { TimeUnit.SECONDS.sleep(5); } catch (Exception e) { e.printStackTrace(); }System.out.println();System.out.println("5秒钟时间到！活动结束");myResource.stop();}
}

生产者消费者3.0 阻塞队列版本相关推荐

java consumed_Java设计模式—生产者消费者模式（阻塞队列实现）
生产者消费者模式是并发.多线程编程中经典的真实世界中的生产者消费者模式生产者和消费者模式在生活当中随处可见,它描述的是协调与协作的关系.比如一个人正在准备食物(生产者),而另一个人正在吃(消费者) ...
生产者消费者2.0（lock）
import java.util.concurrent.locks.Condition; import java.util.concurrent.locks.Lock; import java.uti ...
生产者消费者1.0(wait notify)
/*** 描述: 生产者消费者 1.0 wait notify 版* wait notify** Thread1 对 number 加 1* Thread2 对 number 减 1* @author ...
生产者消费者之阻塞队列版本
通过标志位的可见,和原子的一致,和阻塞队列,实现生产者和消费者同步
java多线程队列_java多线程消费者生产者模式(BlockingQueue 通过阻塞队列实现)
import java.util.concurrent.BlockingQueue; import java.util.concurrent.LinkedBlockingQueue; /** * Cr ...
［Linux］生产者消费者模型（基于BlockQueue的生产者消费者模型 | 基于环形队列的生产者消费者模型 | 信号量）
文章目录生产者消费者模型函数调用角度理解生产者消费者模型生活角度理解生产者消费者模型为什么要使用生产者消费者模型生产者消费者模型优点 321原则基于BlockingQueue的生产者消费者 ...
【Linux】生产者消费者模型-基于环形队列实现
1.环形缓冲区的优势在上篇博客基于阻塞队列的生产者消费者模型中我介绍了什么是生产者消费者模型以及生产者-消费者模式,还没了解的可以戳链接查看. 基于阻塞队列的实现,虽然简单,但是对内存分配性能要求较 ...
【Linux入门】多线程(线程概念、生产者消费者模型、消息队列、线程池)万字解说
目录 1️⃣线程概念什么是线程线程的优点线程的缺点线程异常线程异常 Linux进程VS线程 2️⃣线程控制创建线程获取线程的id 线程终止等待线程线程分离 3️⃣线程互斥进程线程间 ...
python queue 生产者消费者_Queue: 应用于生产者-消费者模式的Python队列
图片来源于网络版权声明 © 著作权归作者所有允许自由转载,但请保持署名和原文链接. 不允许商业用途.盈利行为及衍生盈利行为. 什么是Queue? Queue是Python标准库中的线程安全的队列( ...

生产者消费者3.0 阻塞队列版本

生产者消费者3.0 阻塞队列版本相关推荐

最新文章

热门文章