`

生产者消费者问题。

 
阅读更多
package learn;
class applePlate{
	int apple;
	int space;
	applePlate(int apple, int space){
		this.apple = apple;
		this.space = space;
	}
	void addapple(){
		apple++;
		space--;
	}
	void eatapple(){
		space++;
		apple--;
	}
	public String toString(){
		return "apple = " + apple + ", space = " + space;
	}
}

class ProduceApple implements Runnable{
	applePlate appleplate;
	int count;
	String name;
	ProduceApple(applePlate appleplate, int count, String name){
		this.appleplate = appleplate;
		this.count = count;
		this.name = name;
	}
	public void run(){
		while(count-- > 0){
			synchronized(appleplate){
				while(appleplate.space <= 0){
					try{
						appleplate.wait();
					}catch(InterruptedException e){
						throw new RuntimeException(e);
					}
				}
				appleplate.addapple();
				System.out.println(name + " produced: " + appleplate);
				appleplate.notifyAll();
			}
		}
	}
}

class Customer implements Runnable{
	applePlate appleplate;
	int count;
	String name;
	Customer(applePlate appleplate, int count, String name){
		this.appleplate = appleplate;
		this.count = count;
		this.name = name;
	}
	public void run(){
		while(count-- > 0){
			synchronized(appleplate){
				while(appleplate.apple <= 0){
					try{
						appleplate.wait();
					}catch(InterruptedException e){
						throw new RuntimeException(e);
					}
				}
				appleplate.eatapple();
				System.out.println(name + " ate: " + appleplate);
				appleplate.notifyAll();
				
			}
		}
	}
}


class Go{
	public static void main(String args[]){
		applePlate appleplate = new applePlate(3, 2);
		System.out.println(appleplate);
		new Thread( new Customer(appleplate, 5, "c1")).start();
		new Thread( new ProduceApple(appleplate, 4, "p1")).start();
		new Thread( new Customer(appleplate, 4, "c2")).start();
		new Thread( new ProduceApple(appleplate, 3, "p2")).start();
	}
}
分享到:
评论

相关推荐

    生产者消费者问题

    生产者消费者问题,C++。生产者-消费者(producer-consumer)问题,也称作有界缓冲区(bounded-buffer)问题,两个进程共享一个公共的固定大小的缓冲区。其中一个是生产者,用于将消息放入缓冲区;另外一个是消费者...

    生产者消费者问题 MFC 实现

    在计算机科学中,"生产者消费者问题"是一个经典的并发编程模型,用于展示如何在多线程环境下有效地管理和共享资源。MFC(Microsoft Foundation Classes)是微软提供的一种C++库,用于构建Windows应用程序,它提供了...

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

Global site tag (gtag.js) - Google Analytics