T626code学习笔记之生产者与消费者
2017-07-30 15:50
316 查看
生产者和消费者问题
题目描述:
生产者为商家生产商品,消费者从商家消费商品。
条件:
当商家已有产品50件时,生产者停止生产,停止给商家供货;
当商家货存小于等于零时停止为消费者提供商品消费。
分析:
1.是否是多线程问题? 是。生产者(producer)消费者(customer)。
2.是否存在线程安全问题?具有共享资源(shop)。
3.是否涉及线程通信?存在生产者和消费者的通信(wait()/notify()/notifyAll())。
用代码实现如下:
class Shop {//商店
int producer;//产品数量
public synchronized void addProducer() {//得到生产者产品
if(producer >= 50) {
try {
wait();
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}else{
producer++ ;
System.out.println(Thread.currentThread().getName()+"生产了第"+producer+"个产品");
notifyAll();
}
}
public synchronized void customerProducer() {//消费产品
if(producer <= 0) {
try {
wait();
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}else{
System.out.println(Thread.currentThread().getName()+"消费了第"+producer+"个产品");
producer-- ;
notifyAll();
}
}
}
class Customer implements Runnable {//消费者实现Runnable创建消费者线程
Shop shop;
public Customer(Shop shop) {
this.shop = shop;
}
@Override
public void run() {//重写run()方法
System.out.println("消费者消费产品");
while(true) {
try {
Thread.currentThread().sleep(100);//增加生产时间 方便观察效果
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
shop.customerProducer();
}
}
}
class Producer implements Runnable {//生产者实现Runnable创建生产者线程
Shop shop;
public Producer(Shop shop) {
this.shop = shop;
}
@Override
public void run() {//重写run()方法
System.out.println("生产者开始生产产品");
while(true) {
try {
Thread.currentThread().sleep(100);//增加生产时间 方便观察效果
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
shop.addProducer();
}
}
}
public class ProducerCustomer {//测试类
public static void main(String[] args) {
Shop shop = new Shop();
Producer p1 = new Producer(shop);//共享一个shop资源
Customer c1 = new Customer(shop);
Thread t1 = new Thread(p1);//一个生产者线程
Thread t2 = new Thread(c1);//一个消费者线程
Thread t3 = new Thread(p1);
t1.setName("生产者1");
t2.setName("消费者1");
t3.setName("生产者2");
t1.start();
t2.start();
t3.start();
}
}
运行结果:
生产者开始生产产品
生产者开始生产产品
消费者消费产品
生产者1生产了第1个产品
生产者2生产了第2个产品
消费者1消费了第2个产品
生产者1生产了第2个产品
生产者2生产了第3个产品
消费者1消费了第3个产品
生产者1生产了第3个产品
消费者1消费了第3个产品
生产者2生产了第3个产品
消费者1消费了第3个产品
生产者1生产了第3个产品
生产者2生产了第4个产品
生产者1生产了第5个产品
消费者1消费了第5个产品
生产者2生产了第5个产品
... ...
@T626code的学习笔记
题目描述:
生产者为商家生产商品,消费者从商家消费商品。
条件:
当商家已有产品50件时,生产者停止生产,停止给商家供货;
当商家货存小于等于零时停止为消费者提供商品消费。
分析:
1.是否是多线程问题? 是。生产者(producer)消费者(customer)。
2.是否存在线程安全问题?具有共享资源(shop)。
3.是否涉及线程通信?存在生产者和消费者的通信(wait()/notify()/notifyAll())。
用代码实现如下:
class Shop {//商店
int producer;//产品数量
public synchronized void addProducer() {//得到生产者产品
if(producer >= 50) {
try {
wait();
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}else{
producer++ ;
System.out.println(Thread.currentThread().getName()+"生产了第"+producer+"个产品");
notifyAll();
}
}
public synchronized void customerProducer() {//消费产品
if(producer <= 0) {
try {
wait();
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}else{
System.out.println(Thread.currentThread().getName()+"消费了第"+producer+"个产品");
producer-- ;
notifyAll();
}
}
}
class Customer implements Runnable {//消费者实现Runnable创建消费者线程
Shop shop;
public Customer(Shop shop) {
this.shop = shop;
}
@Override
public void run() {//重写run()方法
System.out.println("消费者消费产品");
while(true) {
try {
Thread.currentThread().sleep(100);//增加生产时间 方便观察效果
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
shop.customerProducer();
}
}
}
class Producer implements Runnable {//生产者实现Runnable创建生产者线程
Shop shop;
public Producer(Shop shop) {
this.shop = shop;
}
@Override
public void run() {//重写run()方法
System.out.println("生产者开始生产产品");
while(true) {
try {
Thread.currentThread().sleep(100);//增加生产时间 方便观察效果
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
shop.addProducer();
}
}
}
public class ProducerCustomer {//测试类
public static void main(String[] args) {
Shop shop = new Shop();
Producer p1 = new Producer(shop);//共享一个shop资源
Customer c1 = new Customer(shop);
Thread t1 = new Thread(p1);//一个生产者线程
Thread t2 = new Thread(c1);//一个消费者线程
Thread t3 = new Thread(p1);
t1.setName("生产者1");
t2.setName("消费者1");
t3.setName("生产者2");
t1.start();
t2.start();
t3.start();
}
}
运行结果:
生产者开始生产产品
生产者开始生产产品
消费者消费产品
生产者1生产了第1个产品
生产者2生产了第2个产品
消费者1消费了第2个产品
生产者1生产了第2个产品
生产者2生产了第3个产品
消费者1消费了第3个产品
生产者1生产了第3个产品
消费者1消费了第3个产品
生产者2生产了第3个产品
消费者1消费了第3个产品
生产者1生产了第3个产品
生产者2生产了第4个产品
生产者1生产了第5个产品
消费者1消费了第5个产品
生产者2生产了第5个产品
... ...
@T626code的学习笔记
相关文章推荐
- JAVA学习笔记(四十二)-生产者消费者模型
- 9. 多线程 Part 4 生产者及消费者模式 --- 学习笔记
- java学习笔记之多线程生产者与消费者
- 【操作系统】学习笔记(二)之生产者消费者问题
- java并发学习笔记(一):wait() notifyAll() 生产者 消费者
- 学习笔记7:wait(),notify()与notifyAll()及消费者生产者小案例
- <JAVA学习笔记7>——生产者、消费者案例(1)
- 操作系统学习笔记-信号量及PV操作与进程互斥和消费者生产者问题
- [知了堂学习笔记]_线程通信(生产者和消费者模式)
- JAVA学习笔记(1)_____模拟线程通信之生产者消费者问题
- 学习笔记之----生产者-消费者模型的实现
- 训练营学习笔记 java多线程(五)生产者/消费者
- 操作系统学习笔记——生产者与消费者,读者和写者
- Java 线程同步问题 生产者-消费者 算法实现 -Java学习笔记(29)
- Java SE学习笔记:线程通信、生产者与消费者案例、线程状态(线程的生命周期)、线程操作、Condition类
- <JAVA学习笔记8>——生产者、消费者案例(2)
- 分布式服务框架学习笔记9 ActiveMQ入门2 管理、生产者/消费者模式
- Android(java)学习笔记71:生产者和消费者之等待唤醒机制
- Apache CMS学习笔记4 - Message生产者消费者
- java个人学习笔记19(多生产者多消费者+循环判断标记+notifyAll()+Lock+Condition)