多线程之经典生产者消费者问题

深碍√TFBOYSˉ_ 2022-08-13 12:51 218阅读 0赞

通过信号量，wait,nofity,synchronized来解决生产者消费者问题。

实例如下：

package thread;
    
    public class ThreadWaitAndNotifyTest {
    
    	/**
    	 * @param args
    	 */
    	public static void main(String[] args) {
    		Iphone iphone = new Iphone();
    		Thread t1 = new Thread(new Producer(iphone));
    		Thread t2 = new Thread(new Salesman(iphone));
    		t1.start();
    		t2.start();
    	}
    
    }
    
    class Iphone {
    	// Iphone是否已卖掉
    	private boolean isSaled = true;
    	private String name;
    	
    	public synchronized void  setName(int i) {
    		System.out.println(Thread.currentThread().getName()+"正在生产第"+(i)+"部IPhone...");
    		if (!isSaled) {
    			System.out.println(Thread.currentThread().getName()+"第" + (i-1)+ "部IPhone等待被卖掉。");
    			try {
    				wait();
    			} catch (InterruptedException e) {
    				e.printStackTrace();
    			}
    //			System.out.println(Thread.currentThread().getName()+"第" + (i-1)+ "部IPhone已被卖掉。");
    		}
    		
    		this.name = "Iphone 5S("+i+")";
    		this.isSaled = false;
    		System.out.println(Thread.currentThread().getName()+"已生产第"+(i)+"部IPhone...");
    		notify(); // 通知消费者线程已生产IPhone，等待被卖掉。
    	}
    	
    	public synchronized String getName(int i) {
    		if (isSaled) {
    			System.out.println(Thread.currentThread().getName()+"wait for sale start...");
    			try {
    				wait();
    			} catch (InterruptedException e) {
    				// TODO Auto-generated catch block
    				e.printStackTrace();
    			}
    			System.out.println(Thread.currentThread().getName()+"wait for sale end...");
    		}
    		
    		this.isSaled = true;
    		System.out.println(Thread.currentThread().getName() + "第"+i+"部IPhone已被卖掉。");
    		notify(); // 通知生产者线程该IPhone已被卖掉，可以生产下一部了。
    		return this.name;
    	}
    }
    
    class Producer implements Runnable {
    	Iphone iphone ;
    	
    	public Producer(Iphone iphone) {
    		this.iphone = iphone;
    	}
    	
    	@Override
    	public void run() {
    		for (int i=0;i<10;i++) {
    			try {
    				this.iphone.setName(i+1);
    				Thread.sleep(500);
    			} catch (InterruptedException e) {
    				// TODO Auto-generated catch block
    				e.printStackTrace();
    			}
    		}
    	}
    	
    }
    
    class Salesman implements Runnable {
    	Iphone iphone;
    	Salesman(Iphone iphone) {
    		this.iphone = iphone;
    	}
    	@Override
    	public void run() {
    		for (int i=0;i<10;i++) {
    			this.iphone.getName(i+1);
    			try {
    				Thread.sleep(1000);
    			} catch (InterruptedException e) {
    				e.printStackTrace();
    			}
    		}
    	}
    	
    }

<p style="margin: 0px auto; padding-top: 0px; padding-bottom: 0px; list-style: none;">程序运行结果如下:</p><p style="margin: 0px auto; padding-top: 0px; padding-bottom: 0px; list-style: none;">Thread-0正在生产第1部IPhone...</p><p style="margin: 0px auto; padding-top: 0px; padding-bottom: 0px; list-style: none;">Thread-0已生产第1部IPhone...</p><p style="margin: 0px auto; padding-top: 0px; padding-bottom: 0px; list-style: none;">Thread-1第1部IPhone已被卖掉。</p><p style="margin: 0px auto; padding-top: 0px; padding-bottom: 0px; list-style: none;">Thread-0正在生产第2部IPhone...</p><p style="margin: 0px auto; padding-top: 0px; padding-bottom: 0px; list-style: none;">Thread-0已生产第2部IPhone...</p><p style="margin: 0px auto; padding-top: 0px; padding-bottom: 0px; list-style: none;">Thread-0正在生产第3部IPhone...</p><p style="margin: 0px auto; padding-top: 0px; padding-bottom: 0px; list-style: none;">Thread-0第2部IPhone等待被卖掉。</p><p style="margin: 0px auto; padding-top: 0px; padding-bottom: 0px; list-style: none;">Thread-1第2部IPhone已被卖掉。</p><p style="margin: 0px auto; padding-top: 0px; padding-bottom: 0px; list-style: none;">Thread-0已生产第3部IPhone...</p><p style="margin: 0px auto; padding-top: 0px; padding-bottom: 0px; list-style: none;">Thread-0正在生产第4部IPhone...</p><p style="margin: 0px auto; padding-top: 0px; padding-bottom: 0px; list-style: none;">Thread-0第3部IPhone等待被卖掉。</p><p style="margin: 0px auto; padding-top: 0px; padding-bottom: 0px; list-style: none;">Thread-1第3部IPhone已被卖掉。</p><p style="margin: 0px auto; padding-top: 0px; padding-bottom: 0px; list-style: none;">Thread-0已生产第4部IPhone...</p><p style="margin: 0px auto; padding-top: 0px; padding-bottom: 0px; list-style: none;">Thread-0正在生产第5部IPhone...</p><p style="margin: 0px auto; padding-top: 0px; padding-bottom: 0px; list-style: none;">Thread-0第4部IPhone等待被卖掉。</p><p style="margin: 0px auto; padding-top: 0px; padding-bottom: 0px; list-style: none;">Thread-1第4部IPhone已被卖掉。</p><p style="margin: 0px auto; padding-top: 0px; padding-bottom: 0px; list-style: none;">Thread-0已生产第5部IPhone...</p><p style="margin: 0px auto; padding-top: 0px; padding-bottom: 0px; list-style: none;">Thread-0正在生产第6部IPhone...</p><p style="margin: 0px auto; padding-top: 0px; padding-bottom: 0px; list-style: none;">Thread-0第5部IPhone等待被卖掉。</p><p style="margin: 0px auto; padding-top: 0px; padding-bottom: 0px; list-style: none;">Thread-1第5部IPhone已被卖掉。</p><p style="margin: 0px auto; padding-top: 0px; padding-bottom: 0px; list-style: none;">Thread-0已生产第6部IPhone...</p><p style="margin: 0px auto; padding-top: 0px; padding-bottom: 0px; list-style: none;">Thread-0正在生产第7部IPhone...</p><p style="margin: 0px auto; padding-top: 0px; padding-bottom: 0px; list-style: none;">Thread-0第6部IPhone等待被卖掉。</p><p style="margin: 0px auto; padding-top: 0px; padding-bottom: 0px; list-style: none;">Thread-1第6部IPhone已被卖掉。</p><p style="margin: 0px auto; padding-top: 0px; padding-bottom: 0px; list-style: none;">Thread-0已生产第7部IPhone...</p><p style="margin: 0px auto; padding-top: 0px; padding-bottom: 0px; list-style: none;">Thread-0正在生产第8部IPhone...</p><p style="margin: 0px auto; padding-top: 0px; padding-bottom: 0px; list-style: none;">Thread-0第7部IPhone等待被卖掉。</p><p style="margin: 0px auto; padding-top: 0px; padding-bottom: 0px; list-style: none;">Thread-1第7部IPhone已被卖掉。</p><p style="margin: 0px auto; padding-top: 0px; padding-bottom: 0px; list-style: none;">Thread-0已生产第8部IPhone...</p><p style="margin: 0px auto; padding-top: 0px; padding-bottom: 0px; list-style: none;">Thread-0正在生产第9部IPhone...</p><p style="margin: 0px auto; padding-top: 0px; padding-bottom: 0px; list-style: none;">Thread-0第8部IPhone等待被卖掉。</p><p style="margin: 0px auto; padding-top: 0px; padding-bottom: 0px; list-style: none;">Thread-1第8部IPhone已被卖掉。</p><p style="margin: 0px auto; padding-top: 0px; padding-bottom: 0px; list-style: none;">Thread-0已生产第9部IPhone...</p><p style="margin: 0px auto; padding-top: 0px; padding-bottom: 0px; list-style: none;">Thread-0正在生产第10部IPhone...</p><p style="margin: 0px auto; padding-top: 0px; padding-bottom: 0px; list-style: none;">Thread-0第9部IPhone等待被卖掉。</p><p style="margin: 0px auto; padding-top: 0px; padding-bottom: 0px; list-style: none;">Thread-1第9部IPhone已被卖掉。</p><p style="margin: 0px auto; padding-top: 0px; padding-bottom: 0px; list-style: none;">Thread-0已生产第10部IPhone...</p><p style="margin: 0px auto; padding-top: 0px; padding-bottom: 0px; list-style: none;">Thread-1第10部IPhone已被卖掉。</p>

发表评论取消回复

表情：

评论列表（有 0 条评论，218人围观）

还没有评论，来说两句吧...

相关阅读

相关多线程13/经典例题：生产者/消费者问题⭐

经典例题：生产者/消费者问题 ●生产者(Productor)将产品交给店员(Clerk)，而消费者(Customer)从店员处取走产品，店员一次只能持有固定数量的产品(

桃扇骨/ 2023年10月04日 16:39/ 0 赞/ 72 阅读

相关 Java多线程——生产者/消费者问题

文章目录经典例题：生产者/消费者问题分析：代码示例 Product.java Produc

痛定思痛。/ 2022年11月12日 13:54/ 0 赞/ 264 阅读

相关多线程之经典生产者消费者问题

通过信号量，wait,nofity,synchronized来解决生产者消费者问题。实例如下： package thread; pub

深碍√TFBOYSˉ_/ 2022年08月13日 12:51/ 0 赞/ 219 阅读

相关 Java多线程—生产者-消费者问题

public class CubbyHole { private int seq; //数据 private boolean available

川长思鸟来/ 2022年07月15日 11:24/ 0 赞/ 244 阅读

相关 Java多线程—生产者-消费者问题

public class CubbyHole { private int seq; //数据 private boolean available

太过爱你忘了你带给我的痛/ 2022年07月15日 11:24/ 0 赞/ 261 阅读

相关多线程之生产者与消费者问题

考虑这样一个饭店，他有一个厨师和一个服务生，然后服务生必须等待厨师准备好食物，当厨师准备好食物时，他会通知服务生，然后服务生上菜，然后返回继续等待。 /

骑猪看日落/ 2022年06月15日 08:08/ 0 赞/ 256 阅读

相关多线程经典例子--生产者、消费者（1）

/ 生产者，消费者。多生产者，多消费者的问题。 if判断标记，只有一次，会导致不该运行的线程运行了。出现了数据错误的情况。

男娘i/ 2022年06月02日 08:05/ 0 赞/ 211 阅读

相关多线程之生产者与消费者

多线程之生产者与消费者问题描述程序编写问题描述生产者消费者问题是一个非常典型性的线程交互的问题。 1. 使用栈来存放数据

比眉伴天荒/ 2022年04月25日 05:00/ 0 赞/ 247 阅读

相关 Java多线程经典问题之生产者消费者模式

1.线程共享的类： package cn.skh.producter; / 一个场景共同的资源生产者消费者模式信号灯法

男娘i/ 2022年04月04日 10:44/ 0 赞/ 180 阅读

相关多线程_生产者消费者问题

什么是多线程的生产者-消费者问题当一个或者多个线程只负责往"数据缓冲区"中添加数据,而一个或者多个线程只负责从"数据缓冲区"中取数据时可能造成的存数据时数据缓冲区满,

客官°小女子只卖身不卖艺/ 2021年07月24日 22:47/ 0 赞/ 487 阅读