Java小程序模拟生产者和消费者事件

古城微笑少年丶 2022-05-10 12:14 176阅读 0赞

package jave;
    /*利用生产窝窝头和吃窝窝头模拟--生产者和消费者事件(线程)*/
    public class ProducerConsumer {
    	public static void main(String[] args) {
    		SyncStack ss = new SyncStack();
    		Producer p = new Producer(ss);
    		Consumer c = new Consumer(ss);
    		new Thread(p).start();
    		new Thread(c).start();		
    	}
    }
    
    
    //窝窝头
    class WoTou {
    	int id;
    	WoTou(int id) {
    		this.id = id;
    	}
    	
    	public String toString() {
    		return "WoTou : " + id;
    	}
    }
    
    
    //容器--篮子
    class SyncStack {
    	int index = 0;
    	WoTou[] arrWT = new WoTou[6];
    	
    	public synchronized void push(WoTou wt) throws InterruptedException {
    		if(index == arrWT.length) {
    			this.wait();//只有当前线程被锁定，才可以wait使得线程等待
    		}
    		
    		this.notify();//与wait对应,叫醒一个现在正在我这个对象上wait的线程
    		arrWT[index] = wt;
    		index++;
    	}
    	
    	public synchronized WoTou pop() throws InterruptedException {
    		if(index == 0) {
    			this.wait();
    		}
    		
    		this.notify();
    		index--;
    		return arrWT[index];
    	}
    }
    
    
    //生产窝窝头
    class Producer implements Runnable{
    	SyncStack ss = null;
    	Producer(SyncStack ss) {
    		this.ss = ss;
    	}
    	
    	public void run() {
    		for(int i = 0; i < 20; i++) {
    			WoTou wt = new WoTou(i);
    			try {
    				ss.push(wt);
    				System.out.println("生产了： " + wt);
    				Thread.sleep(5000);
    			} catch (InterruptedException e) {
    				// TODO Auto-generated catch block
    				e.printStackTrace();
    			}
    		}
    	}
    }
    
    //消费窝窝头
    class Consumer implements Runnable{
    	SyncStack ss = null;
    	Consumer(SyncStack ss) {
    		this.ss = ss;
    	}
    	
    	public void run() {
    		for(int i = 0; i < 20; i++) {
    			WoTou wt = null;
    			try {
    				wt = ss.pop();
    			} catch (InterruptedException e1) {
    				// TODO Auto-generated catch block
    				e1.printStackTrace();
    			}
    			try {
    				ss.pop();
    				System.out.println("消费了： " + wt);
    				Thread.sleep(5000);
    			} catch (InterruptedException e) {
    				// TODO Auto-generated catch block
    				e.printStackTrace();
    			}
    		}
    	}
    }

![70][]

[70]: /images/20220510/f5ec2fcf49cd4b0e8b3fda4e459decd4.png