文档章节

生产者与消费者问题

猪刚烈
 猪刚烈
发布于 2014/10/12 11:40
字数 1142
阅读 19
收藏 1

      多线程编程中的一个典型问题是生产者与消费者问题,这是线程同步或者说是线程间通信的一个典型实例。这里再简单复习一下吧。
      在这个问题中,有一个生产者负责源源不断地生成产品放入仓库,还一个消费者源源不断地从仓库中提出产品。仓库有一个固定的容量,仓库满的时候生产者的操作要暂时挂起等待仓库有空间时再放入产品,当仓库空的时候,消费者提取产品的工作也会挂起,等待仓库中有产品放入后再继续。因此说,存放产品和提取产品是两个需要同步的操作,或者准确地说:消费者的消费操作和生产者的生产操作是可以同步进行的(并发执行),但同时它们之间又必须通过一定的机制来相互的协调,在某些特殊的时刻,让谁先执行,谁后执行,才能避免出现上述问题。
      在java中,这个问题就是通过wait和notify来实现的。注意:wait和notify必须放在同步块中!一般情况是同步块的加锁对象就是wait和notify的从属对象。wait方法将释放当前对象的锁,这样当前线程就被置于block状态(因为当前线程在当前对象上是同步的),以便其他线程可以执行,直到它需要的某个条件由其他线程实现了。而notify方法正是那个实现了某个条件的线程用来通知虚拟机,可以尝试唤醒其他线程了。等到这个线程执行完毕,归还了当前对象的锁,某个被唤醒的线程会得到这个锁,比如说前一个wait的线程,这时候它们条件已经满足,因而可以继续执行下去了。
    
wait和notify与同步机制的关系: “竞争条件”是指两个以上的线程会因为执行顺序的不同而导致程序变量或是返回值的不同。这样必然会出现错误的结果,这种错误的结果有一种叫法:共享数据的腐蚀。同步机制正是用来解决“竞争条件”问题的。但是仅有同步是不够的,本质上,同步是确保共享数据能被线程安全地访问, 它是从“ 隔离 线程”角度来安排线程的推进的。但是线程除了需要隔离,还需要相互通信,以协调地完成一项工作,这正是wait和notify的作用。以下是Java Theads一书的摘入:

     The wait-and-notify mechanism is a synchronization mechanism. However, it is more of a communication mechanism: it allows one thread to communicate to another thread that a particular condition has occurred. The wait-and-notify mechanism does not specify what the specific condition is.

     Can the wait-and-notify mechanism be used to replace the synchronized mechanism? Actually, the answer is no; wait-and-notify does not solve the race condition problem that the synchronized mechanism solves. As a matter of fact, wait-and-notify must be used in conjunction with the synchronized lock to prevent a race condition in the wait-and-notify mechanism itself.

 

下面是生产者与消费者的代码:

Store:仓库类

package producer;
import java.util.LinkedList;
import java.util.Queue;
public class Store {
	private Queue<String> queue = new LinkedList<String>();
	public synchronized String get() {
		try {
			System.out.println("Start to get...");
			System.out.println("The store's size is " + queue.size());
			//NOTE: Here is while NOT if. If there are two consumers, 
			//When  a producer set a product to this store, and notified other
			//threads, one of those two consumers will get lock and go on get production,
			//but there is a notification too in get method, it may await the other consumer,
			//that consumer try to get product, however, there's no product at that time!
			//So, we have to let program check again!
			while (queue.isEmpty()) {
				System.out.println("waiting get...");
				wait();
			}
			System.out.println("The store's size is " + queue.size());
			String product = queue.remove();
			System.out.println("End to get...");
			notify();
			return product;
		} catch (InterruptedException e) {
			e.printStackTrace();
			return null;
		}
	}
	public synchronized void set(String product) {
		try {
			System.out.println("Start to set...");
			System.out.println("The store's size is " + queue.size());
			while (queue.size() == 3) {
				System.out.println("waiting set...");
				wait();
			}
			System.out.println("The store's size is " + queue.size());
			queue.add(product);
			System.out.println("End to set...");
			notify();
		} catch (InterruptedException e) {
			e.printStackTrace();
		}
	}
	public static void main(String[] args) {
		Store s = new Store();
		Consumer c1 = new Consumer(s);
		Producer p1 = new Producer(s);
		Consumer c2 = new Consumer(s);
		Producer p2 = new Producer(s);
		Thread t1 = new Thread(c1);
		Thread t2 = new Thread(p1);
		Thread t3 = new Thread(c2);
		Thread t4 = new Thread(p2);
		t1.start();
		t2.start();
		t3.start();
		t4.start();
	}
}

 

Producer:生产者

package producer;
import java.util.Random;
public class Producer implements Runnable {
	private Store store;
	public Producer(Store store) {
		super();
		this.store = store;
	}
	@Override
	public void run() {
		try {
			while(true){
				store.set("a");
				System.out.println();
				Thread.sleep(new Random().nextInt(1000));
			}
		} catch (InterruptedException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
	}
}

Consumer:消费者

package producer;
import java.util.Random;
public class Consumer implements Runnable{
	
	private Store store;
	
	
	public Consumer(Store store) {
		super();
		this.store = store;
	}
	@Override
	public void run() {
		try {
			while(true){
				Thread.sleep(new Random().nextInt(1000));
				System.out.println(store.get());
			}
		} catch (InterruptedException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
	}
}

本文转载自:http://blog.csdn.net/bluishglc/article/details/5783390

共有 人打赏支持
猪刚烈
粉丝 22
博文 708
码字总数 110
作品 1
海淀
程序员
私信 提问
秒杀多线程第十篇 生产者消费者问题

继经典线程同步问题之后,我们来看看生产者消费者问题及读者写者问题。生产者消费者问题是一个著名的线程同步问题,该问题描述如下:有一个生产者在生产产品,这些产品将提供给若干个消费者去...

晨曦之光
2012/05/21
119
0
秒杀多线程第十篇 生产者消费者问题

继经典线程同步问题之后,我们来看看生产者消费者问题及读者写者问题。生产者消费者问题是一个著名的线程同步问题,该问题描述如下:有一个生产者在生产产品,这些产品将提供给若干个消费者去...

长平狐
2012/12/10
56
0
生产者—消费者模型

生产者消费者问题是线程模型中的经典问题:生产者和消费者在同一时间段内共用同一存储空间,生产者向空间里生产数据,而消费者取走数据。 这里实现如下情况的生产--消费模型: 生产者不断交替...

architect刘源源
01/30
0
0
Java 多线程:生产者消费者问题

概念 *** 生产者消费者问题描述了两个线程(即生产者线程和消费者线程),共享固定大小的缓冲区,在实际运行中可能出现的问题。 生成者:生成一定量的数据放到缓冲区中,然后重复此过程。 消...

icanos
2016/07/21
12
0
Java并发编程初级篇(十六):Lock+Condition实现生产者消费者问题

之前我们在“Java并发编程初级篇(十二):使用wait和notify生产者消费者问题”,已经使用Java提供的synchronized关键字和wait(),notify(),notifyAll()方法实现过来生产者消费者问题。Java ...

阿拉德大陆的魔法师
2016/11/25
18
0

没有更多内容

加载失败,请刷新页面

加载更多

Ubuntu16.04下安装docker

[TOC] 本文开发环境为Ubuntu 16.04 LTS 64位系统,通过apt的docker官方源安装最新的Docker CE(Community Edition),即Docker社区版,是开发人员和小型团队的理想选择。 1. 开始安装 1.1 由于...

豫华商
30分钟前
3
0
使用XShell工具密钥认证登录Linux系统

如果你是一名Linux运维,那么Linux服务器的系统安全问题,可能是你要考虑的,而系统登录方式有两种,密码和密钥。哪一种更加安全呢? 无疑是后者! 这里我为大家分享用Xshell利器使用密钥的方...

dragon_tech
42分钟前
1
0
day178-2018-12-15-英语流利阅读-待学习

“真蛛奶茶”了解一下?蜘蛛也会产奶了 Lala 2018-12-15 1.今日导读 “蛋白质含量是牛奶的 4 倍,并有着更低的脂肪和含糖量”,听起来诱人又美味的并不是羊奶或豆奶,而是你可能打死都想不到...

飞鱼说编程
47分钟前
9
0
npm WARN optional SKIPPING OPTIONAL DEPENDENCY: fsevents

场景重现 npm install --verbose 安装依赖的时,出现如下警告 强迫症患者表示不能接受 npm WARN optional SKIPPING OPTIONAL DEPENDENCY: fsevents@1.2.4 (node_modules\fsevents):npm WARN......

taadis
51分钟前
2
0
OSChina 周六乱弹 —— 你一口我一口多咬一口是小狗

Osc乱弹歌单(2018)请戳(这里) 【今日歌曲】 @达尔文 :分享Roy Orbison的单曲《She's a Mystery to Me》 《She's a Mystery to Me》- Roy Orbison 手机党少年们想听歌,请使劲儿戳(这里...

小小编辑
今天
363
6

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部