`
一路欢笑一路走
  • 浏览: 11642 次
  • 性别: Icon_minigender_1
  • 来自: 上海
社区版块
存档分类
最新评论

生产者消费者问题

阅读更多

1.生产者消费者问题

 生产者消费者类

 

public class Producer {
	public void produce(){
		System.out.println("生产一个");
	}
}
public class Consumer {
	public void consumer(){
		System.out.println("消费一个");
	}
}

  

  超市实体类

  

public class SuperMark {

	// 此超市最大库存是3
	// 当超市库存为0时,消费者不能消费
	// 当超市库存==3时,生产者不能生产

	// 最大库存
	private final int MAX_STORE = 3;
	// 当前库存
	private int currentStore = 3;

	Producer producer;

	Consumer consumer;
        
        public SuperMark() {

		producer = new Producer();
		consumer = new Consumer();

	}

	public  synchronized void stockProduct() {

		while (MAX_STORE == currentStore) {
			try {
				wait();
			} catch (InterruptedException e) {
				e.printStackTrace();
			}
		}
		producer.produce();

		currentStore++;
		System.out.println("当前库存" + currentStore);
		notify();
	}
	
	
	public  synchronized void sellProduct(){
		while (0 == currentStore) {
			try {
				wait();
			} catch (InterruptedException e) {
				e.printStackTrace();
			}
		}
		consumer.consumer();
		currentStore--;
		System.out.println("当前库存"+currentStore);
		notify();
	}

 

  消费和生产线程类

  

class ProduceThread extends Thread{
	
	SuperMark superMark;
	
	public ProduceThread(SuperMark superMark){
		this.superMark=superMark;
	}
	@Override
	public void run() {
		for(int i=0;i<10;i++){
			superMark.stockProduct();
		}
	}
}




class ConsumerThread extends Thread{
	
	SuperMark superMark;
	
	public ConsumerThread(SuperMark superMark){
		this.superMark=superMark;
	}
	@Override
	public void run() {
		for(int i=0;i<10;i++){
			superMark.sellProduct();
		}
	}
	
}

 

  测试类

  

public static void main(String[] args) {
		SuperMark superMark = new SuperMark();
		ProduceThread thread1 = new ProduceThread(superMark);
		ConsumerThread thread2 = new ConsumerThread(superMark);
		ProduceThread thread3 = new ProduceThread(superMark);
		ConsumerThread thread4 = new ConsumerThread(superMark);
		thread1.start();
		thread3.start();
		thread4.start();
		thread2.start();
}

 

  结果

  

消费一个
当前库存2
消费一个
当前库存1
消费一个
当前库存0
生产一个
当前库存1
生产一个
当前库存2

 

  可以看出库存不会大于3和低于0

 

分享到:
评论

相关推荐

    生产者消费者问题c++实现

    生产者消费者问题是多线程编程中的一个经典案例,它展示了如何通过线程间的协作来解决资源的同步和异步操作。在C++中,我们可以利用标准库中的互斥量(mutex)、条件变量(condition_variable)等工具来实现这个问题...

    实验一 生产者消费者问题

    生产者消费者问题是多线程编程中的经典模型,用于展示如何在并发环境中协调生产者和消费者之间的数据处理。在这个问题中,生产者线程负责生成数据,而消费者线程则负责消费这些数据。为了保证系统的稳定性和正确性,...

    生产者消费者问题C#

    生产者消费者问题是多线程编程中的一个经典案例,它展示了如何通过线程间的协作来解决资源的并发访问问题。在C#中,我们可以利用System.Threading命名空间提供的工具来实现这一模型。下面将详细阐述这个问题的背景、...

    利用数组解决生产者消费者问题

    生产者消费者问题是多线程编程中的经典模型,用于模拟两个或多个并发执行的实体(生产者和消费者)共享有限资源的情况。在这个问题中,生产者负责生成数据并放入缓冲区,而消费者则从缓冲区取出数据进行处理。当缓冲...

    生产者消费者问题的解决代码

    ### 生产者消费者问题解析与实现 #### 一、生产者消费者问题简介 生产者消费者问题(Producer-Consumer Problem)是计算机科学中经典的同步问题之一,通常用来展示进程间通信和同步机制。该问题涉及两个类别的进程...

    pv.rar_pv_pv操作_生产者消费者_生产者消费者问题_生产者消费者问题 c

    在IT领域,生产者消费者问题是多线程编程中一个经典的同步问题,主要涉及进程或线程间的通信与协作。此问题描述的是一个系统中有两个角色:生产者和消费者,生产者负责生成数据,而消费者负责消费这些数据。为了保证...

    C语言实现生产者消费者问题

    C语言实现生产者消费者问题,分配具有n个缓冲区的缓冲池,作为共享资源。 定义两个资源型信号量empty 和full,empty信号量表示当前空的缓冲区数量,full表示当前满的缓冲区数量。 定义互斥信号量mutex,当某个进程...

    多线程代码 经典线程同步互斥问题 生产者消费者问题

    a: 创建一个线程 ...h: problem1 生产者消费者问题 (1生产者 1消费者 1缓冲区) problem1 more 生产者消费者问题 (1生产者 2消费者 4缓冲区) problem2 读者与写着问题 I: 信号量 semaphore 解决线程同步问题

    利用管程_信号量解决生产者消费者问题

    ### 利用管程与信号量解决生产者消费者问题 #### 概述 生产者-消费者问题是计算机科学中一个经典的问题,它用于演示进程间通信和同步的基本概念。该问题通常涉及一组生产者进程(负责生成数据)和一组消费者进程...

    生产者消费者问题 MFC

    生产者消费者问题是多线程编程中的一个经典案例,它展示了如何通过共享资源在并发环境中实现线程间的协调。在这个问题中,"生产者"线程负责生成数据,而"消费者"线程则负责消费这些数据。MFC(Microsoft Foundation ...

    生产者消费者问题 进程实现

    生产者消费者问题进程实现 在计算机科学中,生产者消费者问题(Producer-Consumer problem)是操作系统中的一种典型问题。它描述了两个或多个进程之间的协作关系,其中一个或多个生产者进程生产数据,并将其存储在...

    java 生产者消费者问题(源码)

    Java生产者消费者问题是多线程编程中的一个经典案例,它主要展示了如何通过共享资源来实现线程间的协作。这个问题源于现实生活中的生产流水线,其中生产者负责制造产品,而消费者负责消耗这些产品。在计算机系统中,...

    操作系统课程设计——生产者消费者问题Java图形界面动态演示

    设计目的:通过研究Linux 的进程机制和信号量实现生产者消费者问题的并发控制。说明:有界缓冲区内设有20 个存储单元,放入/取出的数据项设定为1‐20 这20 个整型数。设计要求:1)每个生产者和消费者对有界缓冲区...

Global site tag (gtag.js) - Google Analytics