生产者消费者模式Java实现

package com.szc.java;/*** @Author szc* @Date 2021/8/24*/
//缓冲区（售货员）
class Clerk {private int quantity=0;public int getQuantity() {return quantity;}//当货物数量为20（满）时，唤醒消费者进程，并使得生产者进程阻塞。public synchronized void Purchase(){notify();while (quantity == 20){try {this.wait();} catch (InterruptedException e) {e.printStackTrace();}}quantity++;}//当货物数量为0时，唤醒生产者进程，并使得消费者进程阻塞。public synchronized void Sale(){notifyAll();while (quantity == 0){try {this.wait();} catch (InterruptedException e) {e.printStackTrace();}}quantity--;}}
//生产者进程
class  Producer implements Runnable{private Clerk clerk;public Producer(Clerk clerk) {this.clerk = clerk;}@Overridepublic void run() {while (true) {synchronized (clerk) {try {Thread.sleep(150);} catch (InterruptedException e) {e.printStackTrace();}clerk.Purchase();int x = clerk.getQuantity();System.out.println(Thread.currentThread().getName() + "生产了第" + x + "个产品");}}}
}
//消费者进程
class Consumer implements Runnable{private Clerk clerk;public Consumer(Clerk clerk) {this.clerk = clerk;}@Overridepublic void run() {while (true) {synchronized (clerk) {try {Thread.sleep(300);} catch (InterruptedException e) {e.printStackTrace();}clerk.Sale();int x = clerk.getQuantity()+1;System.out.println(Thread.currentThread().getName() + "消费了第" + x + "个产品");}}}
}
//主函数
public class Pipeline {public static void main(String[] args) {Clerk clerk = new Clerk();Producer producer = new Producer(clerk);Consumer consumer = new Consumer(clerk);Thread p1 = new Thread(producer);Thread c1 = new Thread(consumer);Thread c2 = new Thread(consumer);p1.setName("生产者1");c1.setName("消费者1");c2.setName("消费者2");p1.start();c1.start();c2.start();}}

生产者消费者模式Java实现相关推荐

java lock condition_Java 通过 Lock 和竞争条件 Condition 实现生产者消费者模式
更多 Java 并发编程方面的文章,请参见文集<Java 并发编程> 竞争条件多个线程共享对某些变量的访问,其最后结果取决于哪个线程偶然在竞争中获胜. condition.await() ...
java消费者模式_基于Java 生产者消费者模式(详细分析)
生产者消费者模式是多线程中最为常见的模式:生产者线程(一个或多个)生成面包放进篮子里(集合或数组),同时,消费者线程(一个或多个)从篮子里(集合或数组)取出面包消耗.虽然它们任务不同,但处理的资源是相 ...
Java并发编程实战~生产者-消费者模式
前面我们在<Worker Thread 模式>中讲到,Worker Thread 模式类比的是工厂里车间工人的工作模式.但其实在现实世界,工厂里还有一种流水线的工作模式,类比到编程领域,就 ...
java消费者生产者设计模式_java 多线程并发设计模式之四: 生产者消费者模式
生产者消费者模式是一个经典的多线程设计模式,其核心思想是:有两类线程和一个内存缓冲区或者队列, 一类线程发起任务,并提交到队列中.另一类线程用来处理这些任务,叫做消费者线程. 这两类线程进行通信的桥梁 ...
java 消费者模式多线程_[Java并发-24-并发设计模式] 生产者-消费者模式，并发提高效率...
生产者 - 消费者模式在编程领域的应用非常广泛,前面我们曾经提到,Java 线程池本质上就是用生产者 - 消费者模式实现的,所以每当使用线程池的时候,其实就是在应用生产者 - 消费者模式. 当然,除了 ...
菜鸟学习笔记：Java提升篇8（线程2——线程的基本信息、线程安全、死锁、生产者消费者模式、任务调度）
菜鸟学习笔记:Java提升篇8(线程2--线程的基本信息.线程安全.死锁.生产者消费者模式.任务调度) 线程的基本信息线程同步线程安全死锁生产者消费者模式任务调度(了解) 线程的基本信息 J ...
生产者消费者模式－java原生、Disruptor实现方案
生产者消费者模式介绍生产者消费者模式是通过一个容器来解决生产者和消费者的强耦合问题.生产者和消费者彼此之间不直接通讯,而通过阻塞队列来进行通讯,所以生产者生产完数据之后不用等待消费者处理,直接扔给阻 ...
java consumed_Java设计模式—生产者消费者模式（阻塞队列实现）
生产者消费者模式是并发.多线程编程中经典的真实世界中的生产者消费者模式生产者和消费者模式在生活当中随处可见,它描述的是协调与协作的关系.比如一个人正在准备食物(生产者),而另一个人正在吃(消费者) ...
Java（二十二） -- 生产者消费者模式
目录生产者消费者模式汉堡类容器类生产者消费者测试类案例:多线程并发卖票生产者消费者模式在一个生产环境中,生产者和消费者在同一时间段内共享同一块缓冲区,生产者负责向缓冲区添加数据,消费 ...

生产者消费者模式Java实现

生产者消费者模式Java实现相关推荐

最新文章

热门文章