生产者消费者ReentrantLock实现以及BlockingQueue实现

1.ReentrantLock实现

/*** 描述: 一个初始值为0的变量，两个线程对其交替操作，一个加一个减** @author xinjiao.yu@marketin.cn* @create 2020/2/22 11:55* @since 2.16.3*/
class ShareData{private int number = 0;private Lock lock = new ReentrantLock();private Condition condition = lock.newCondition();public void increment() throws Exception{lock.lock();try{// 1判断while(number != 0){// 等待，不能生产condition.await();}number++;System.out.println(Thread.currentThread().getName()+"\t"+number);// 通知唤醒condition.signalAll();}catch (Exception e){e.printStackTrace();}finally {lock.unlock();}}public void decrement() throws Exception{lock.lock();try{// 1判断while(number == 0){// 等待，不能生产condition.await();}number--;System.out.println(Thread.currentThread().getName()+"\t"+number);// 通知唤醒condition.signalAll();}catch (Exception e){e.printStackTrace();}finally {lock.unlock();}}
}
public class ProConsumer_ReentrantLockDemo {public static void main(String[] args) {ShareData shareData = new ShareData();new Thread(()->{for(int i=1;i<=5;i++){try{shareData.increment();}catch (Exception e){e.printStackTrace();}}},"AA").start();new Thread(()->{for(int i=1;i<=5;i++){try{shareData.decrement();}catch (Exception e){e.printStackTrace();}}},"BB").start();}
}

2.BlockingQueue实现

class MyResource{private volatile boolean FLAG = true;private AtomicInteger atomicInteger = new AtomicInteger();private 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 retValue;while (FLAG){data = atomicInteger.incrementAndGet()+"";retValue = blockingQueue.offer(data,2L, TimeUnit.SECONDS);if(retValue){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("")){FLAG = false;System.out.println(Thread.currentThread().getName()+"\t 超过2秒钟没有取到蛋糕，消费退出");System.out.println();return;}System.out.println(Thread.currentThread().getName()+"\t 消费队列"+result+"成功");}}public void myStop() throws Exception{this.FLAG=false;}
}
public class ProConsumer_BlockQueueDemo {public static void main(String[] args) throws Exception{MyResource myResource = new MyResource(new ArrayBlockingQueue<>(3));new Thread(()->{System.out.println(Thread.currentThread().getName()+"\t 生产者线程启动");try {myResource.myProd();} catch (Exception e) {e.printStackTrace();}},"Prod").start();new Thread(()->{System.out.println(Thread.currentThread().getName()+"\t 消费者线程启动");try {myResource.myConsumer();} catch (Exception e) {e.printStackTrace();}},"Consumer").start();// 暂停一会线程TimeUnit.SECONDS.sleep(5);System.out.println();System.out.println();System.out.println("5秒钟时间到，大老板main线程叫停，活动结束");myResource.myStop();}
}

生产者消费者ReentrantLock实现以及BlockingQueue实现相关推荐

Java阻塞队列(BlockingQueue)实现生产者/消费者示例
Java阻塞队列(BlockingQueue)实现生产者/消费者示例本文由 TonySpark 翻译自 Javarevisited.转载请参见文章末尾的要求. Java.util.concurr ...
【1】生产者-消费者模型的三种实现方式
(手写生产者消费者模型,写BlockingQueue较简便 ) 1.背景 ...
Java并发编程(二十三)------并发设计模式之生产者消费者模式
参考文章:Java实现生产者消费者问题与读者写者问题目录 1. 生产者消费者问题 1.1 wait() / notify()方法 1.2 await() / signal()方法 1.2.1 对sy ...
【生产者消费者模型】
Linux生产者消费者模型生产者消费者模型生产者消费者模型的概念生产者消费者模型的特点生产者消费者模型优点基于BlockingQueue的生产者消费者模型基于阻塞队列的生产者消费者模型模 ...
【Linux篇】第十六篇——生产者消费者模型
生产者消费者模型生产者消费者模型的概念生产者消费者模型的特点生产者消费者模型优点基于BlockingQueue的生产消费者模型基于阻塞队列的生产者消费者模型模拟实现基于阻塞队列的生产消费模 ...
Linux生产者消费者模型
文章目录生产者消费者模型生产者消费者模型的概念生产者消费者模型的特点生产者消费者模型优点基于BlockingQueue的生产者消费者模型基于阻塞队列的生产者消费者模型模拟实现基于阻塞队列 ...
【Linux入门】多线程(线程概念、生产者消费者模型、消息队列、线程池)万字解说
目录 1️⃣线程概念什么是线程线程的优点线程的缺点线程异常线程异常 Linux进程VS线程 2️⃣线程控制创建线程获取线程的id 线程终止等待线程线程分离 3️⃣线程互斥进程线程间 ...
Java多线程（十）：BlockingQueue实现生产者消费者模型
BlockingQueue BlockingQueue.解决了多线程中,如何高效安全"传输"数据的问题.程序员无需关心什么时候阻塞线程,什么时候唤醒线程,该唤醒哪个线程. 方法介绍 ...
生产者-消费者中的缓冲区：BlockingQueue接口
BlockingQueue接口使用场景相信大家对生产者-消费者模式不陌生,这个经典的多线程协作模式,最简单的描述就是生产者线程往内存缓冲区中提交任务,消费者线程从内存缓冲区里获取任务执行.在生产者- ...

生产者消费者ReentrantLock实现以及BlockingQueue实现

生产者消费者ReentrantLock实现以及BlockingQueue实现相关推荐

最新文章

热门文章