Java中通过wait和notify来实现生产者和消费者模式

今天通过介绍一下如何通过wait和notify来实现生产者和消费者模式。

通过synchronized同步代码块实现线程的同步操作,从而保证数据的一致性。下面具体介绍一下这个模式的实现过程。

1.首先编写一个生产者类:

public class Producer implements Runnable {
	private PublicBox box;

	public Producer(PublicBox box) {
		this.box = box;
	}

	@Override
	public void run() {
		int i=0;
		while(true){
			try {
				System.out.println("生产者序号:" + i);
				i++;
				Thread.sleep(1000);
			} catch (InterruptedException e) {
				e.printStackTrace();
			}
			box.increace();
		}
	}
}

2.其次编写一个消费者类:

public class Consumer implements Runnable {
	private PublicBox box;

	public Consumer(PublicBox box) {
		this.box = box;
	}

	@Override
	public void run() {
		int i=0;
		while(true){
			try {
				System.out.println("消费者序号" + i);
				i++;
				Thread.sleep(3000);
			} catch (InterruptedException e) {
				// TODO: handle exception
				e.printStackTrace();
			}

			box.decreace();
		}
	}
}

3.最后编写仓库类:

public class PublicBox {
	private int product = 0;

	public synchronized void increace() {
		while (product == 5) {
			try {
				wait();
			} catch (InterruptedException e) {
				e.printStackTrace();
			}

		}
		product++;
		System.out.println("产品生产成功!目前产品的存储量:"+product);
		notify();
	}

	public synchronized void decreace() {
		while (product == 0) {
			try {
				wait();
			} catch (InterruptedException e) {
				e.printStackTrace();
			}
		}
		product--;
		System.out.println("产品消费成功!目前产品的存储量:"+product);
		notify();
	}

	public static void main(String[] args) {
		PublicBox box = new PublicBox();
		Consumer con = new Consumer(box);
		Producer pro = new Producer(box);
		Thread t1 = new Thread(con);
		Thread t2 = new Thread(pro);
		t1.start();
		t2.start();
	}
}

打印出来的部分结果:

这个执行过程有些人可能会有些疑问,我在这里具体描述一下这整个过程是如何实现的。

在这里因为生产者所休眠的时间比消费者短,所以生产者出现的频率会比消费者高一些。

1:首先是生产者和消费者都新建了各自的序号并打印出来。

2:因为是消费者先启动的,所以首先访问decreace同步块,可是因为条件不符合所以被wait了。

3:消费者被wait之后,生产者就开始启动increace同步块生产了。生产者一生产就会调用notify方法,这个时候第二步已经被wait的线程就会被唤醒,接着执行wait之后的代码。但是这里需要注意的是并不是生产者调用notify方法,消费者就会马上被唤醒执行接下来的代码。因为唤醒和执行都需要时间,这个过程可能生产者又生成新的产品了吗,也有可能是消费者马上被执行。

4:之后的过程就是按照前面三步骤进行循环输出的。

这个模式下的生产者消费者主要是通过synchronized 同步代码块来保证product这个变量的一致性。保证product变量在多个线程的调用的过程中,线程之间不会发生互相干扰,按正确的顺序执行这些过程。

如果对上面的内容还有什么疑义或者问题都可以加我QQ:208017534咨询。

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

发表于

我来说两句

0 条评论
登录 后参与评论

相关文章

来自专栏技术之路

翻译qmake文档(三) Creating Project Files

原英文文档:http://qt-project.org/doc/qt-5/qmake-project-files.html 创建项目文件      项目文件...

1896
来自专栏芋道源码1024

分布式消息队列 RocketMQ 源码分析 —— Message 拉取与消费(上)

摘要: 原创出处 http://www.iocoder.cn/RocketMQ/message-pull-and-consume-first/ 「芋道源码」欢迎...

3436
来自专栏编码小白

activiti学习笔记(三) 监听生命周期

activiti监听生命周期 activiti生命周期的作用 生命周期的作用是在构建processEngine实例时候或者关闭的时候调用对应处理方法,比如我在启...

4106
来自专栏Python

logging模块

logging模块 函数式简单配置 import logging logging.debug('debug message') logging.info...

1977
来自专栏菩提树下的杨过

java学习:eclipse + Weblogic 12c + svn 集成开发环境搭建

网上有很多文章都说eclipse要安装额外的插件才能支持weblogic,可能以前需要这样,但自从bea的weblogic被oracle收购后,现在已经很简单了...

2519
来自专栏腾讯云Elasticsearch Service

filebeat源码解析

在基于elk的日志系统中,filebeat几乎是其中必不可少的一个组件,例外是使用性能较差的logstash file input插件或自己造个功能类似的轮子:...

7766
来自专栏前端架构与工程

NativeScript工作原理

NativeScript是一个runtime,它提供一些机制可以使用JavaScript构建原生的IOS、Android甚至WP(未来会加入)应用。Native...

3677
来自专栏difcareer的技术笔记

Android Inline Hook 详解前言原理分析

网上有几篇关于Android inline hook的文章,这篇尤其不错,还有对应的示例代码。为了方便调试看结果,我将其改为gradle工程,代码见这里。你需要...

1302
来自专栏芋道源码1024

精尽 Dubbo 原理与源码专栏( 已经完成 69+ 篇,预计总共 75+ 篇 )

本小节,我们将 《精尽 Dubbo 源码解析》 和 《Dubbo 用户指南》 做一次映射,方便大家直接找到感兴趣的功能的具体源码实现。当然,如果有整理不到位的地...

3712
来自专栏主机笔记

centos安装ab工具给网站进行压力测试

在配置好网站服务器后,我们可以进行压力测试看一看实际环境中的效果怎么样,判断服务器质量、网站程序设计是否合理、提前预防突发事件。今天就介绍一款开源免费的压力测试...

25910

扫码关注云+社区