文档章节

生产者--消费者实践

1527
 1527
发布于 2015/12/15 22:29
字数 328
阅读 106
收藏 12
/**
 * 一个场景,共同的资源
 * 生产者消费者模式 	信号灯法
 * wait():等待,释放锁 	sleep():不释放锁
 * notify():释放锁
 * @author Administrator
 *
 */
public class Movie {

	private String pic;
	//信号灯 
	//flag -->T 生产者生产,消费者等待,生产完成后通知消费
	//flag -->F 消费者消费,生产者等待,消费完成后通知生产
	private boolean flag = true;
	/**
	 * 播放
	 * @param pic
	 */
	public synchronized void play(String pic){
		
		if(!flag){//生产者等待
			try {
				this.wait();
			} catch (InterruptedException e) {
				e.printStackTrace();
			}
		}
		//开始生产
		try {
			Thread.sleep(500);
		} catch (InterruptedException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		System.out.println("生产了"+pic);
		//生产完毕
		this.pic = pic;
		//通知消费
		this.notify();
		//生产者停下
		this.flag=false;
	}
	
	public synchronized void watch(){
		
		if(flag){//消费者等待
			try {
				this.wait();
			} catch (InterruptedException e) {
				e.printStackTrace();
			}
		}
		//开始消费
		try {
			Thread.sleep(200);
		} catch (InterruptedException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		System.out.println("消费了"+pic);
		//消费完毕
		
		//通知生产
		this.notifyAll();
		//消费停止
		this.flag = true;
		
	}
}

/**
 * 生产者
 * @author Administrator
 *
 */
public class Player implements Runnable{

	private Movie m;

	public Player(Movie m) {
		super();
		this.m = m;
	}

	@Override
	public void run() {

		for(int i=0;i<20;i++){
			if(i%2==0){
				m.play("左青龙");
			}else{
				m.play("右白虎");
			}
		}
	}

}


/**
 * 消费者
 * @author Administrator
 *
 */
public class Watcher implements Runnable {

	private Movie m;
	
	public Watcher(Movie m) {
		super();
		this.m = m;
	}

	@Override
	public void run() {

		for(int i=0;i<20;i++){
			m.watch();
		}
	}

	
}

public class App {

	public static void main(String[] args) {
		
		//共同的资源
		Movie m = new Movie();
		
		//线程
		Player p = new Player(m);
		Watcher w = new Watcher(m);
		
		new Thread(p).start();
		new Thread(w).start();
	}
}


© 著作权归作者所有

共有 人打赏支持
1527
粉丝 7
博文 108
码字总数 45500
作品 0
成都
程序员
私信 提问
基于 HBase 构建可伸缩的分布式事务队列

一个实时流处理框架通常需要两个基础架构:处理器和队列。处理器从队列中读取事件,执行用户的处理代码,如果要继续对结果进行处理,处理器还会把事件写到另外一个队列。队列由框架提供并管理...

oschina
2015/06/03
4.9K
9
java:一个生产者消费者模式的简单实现

先啰嗦一点: 由于最近工作中,涉及到生产者消费者设计模式,对此有一些体会,所以总结一下,与大家分享。 1、什么是生产者消费者模式 在工作中,大家可能会碰到这样一种情况:某个模块负责产...

jackson_open
2014/04/03
0
0
Disruptor 实践:整合到现有的爬虫框架

一. Disruptor Disruptor 是一个高性能的异步处理框架。 Disruptor 是 LMAX 在线交易平台的关键组成部分,LMAX平台使用该框架对订单处理速度能达到600万TPS,除金融领域之外,其他一般的应用...

fengzhizi715
2018/12/04
0
0
java:一个生产者消费者模式的简单实现

先啰嗦一点: 由于最近工作中,涉及到生产者消费者设计模式,对此有一些体会,所以总结一下,与大家分享。 1、什么是生产者消费者模式 在 工作中,大家可能会碰到这样一种情况:某个模块负责...

jackson_open
2014/02/14
0
0
如何在 Java 中正确使用 wait, notify 和 notifyAll – 以生产者消费者模型为例

wait, notify 和 notifyAll,这些在多线程中被经常用到的保留关键字,在实际开发的时候很多时候却并没有被大家重视。本文对这些关键字的使用进行了描述。 在 Java 中可以用 wait、notify 和 ...

牧师-Panda
2016/10/20
21
0

没有更多内容

加载失败,请刷新页面

加载更多

Java单例模式学习记录

在项目开发中经常能遇见的设计模式就是单例模式了,而实现的方式最常见的有两种:饿汉和饱汉(懒汉)。由于日常接触较多而研究的不够深入,导致面试的时候被询问到后有点没底,这里记录一下学习...

JerryLin123
昨天
3
0
VSCODE 无法调试

VSCODE 无法调试 可以运行 可能的原因: GCC 的参数忘了加 -g

shzwork
昨天
4
0
理解去中心化 稳定币 DAI

随着摩根大通推出JPM Coin 稳定币,可以预见稳定币将成为区块链落地的一大助推器。 坦白来讲,对于一个程序员的我来讲(不懂一点专业经济和金融),理解DAI的机制,真的有一点复杂。耐心看完...

Tiny熊
昨天
4
0
5.线程实现

用于线程实现的Python模块 Python线程有时称为轻量级进程,因为线程比进程占用的内存少得多。 线程允许一次执行多个任务。 在Python中,以下两个模块在一个程序中实现线程 - _thread 模块 th...

Eappo_Geng
昨天
6
0
ServiceLoader

创建一个接口文件在resources资源目录下创建META-INF/services文件夹在services文件夹中创建文件,以接口全名命名创建接口实现类 内容me.zzp.ar.d.PostgreSQLDialectme.zzp.ar.d.Hype...

Cobbage
昨天
6
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部