生产者和消费者的样例

柔光的暖阳◎ 2023-05-29 11:47 20阅读 0赞

package 线程;
    import java.util.*;
    
    /******* 有一个仓库 公用 ， 仓库的容量 为10 生产者有两个， 每个生产者总共， 生产10个产品， 如果仓库处于满的状态， 生产者处于等待状态 消费者有两个， 每一消费者消费10 个产品 ， 如果仓库没有 产品 消费者 处于等待状态 ************/
    
    public class Main { 
    
    	public static void main(String[] args) { 
    		Storage storage = new Storage();
    		Thread p1 = new Thread(new Producer(storage));
    		Thread p2 = new Thread(new Producer(storage));
    		
    		p2.start();
    		p1.start();
    		try { 
    			Thread.sleep(1000);
    		} catch (InterruptedException e) { 
    			// TODO Auto-generated catch block
    			e.printStackTrace();
    		}
    		Thread c1 = new Thread(new Consumer(storage));
    		Thread c2 = new Thread(new Consumer(storage));
    		c1.start();
    		c2.start();
    		
    	}
    
    }
    class Storage{ 
    	private Product[] products  = new Product[10];
    	private int top = 0; 
    	
    	public synchronized void push(Product product) { 
    		while(top == products.length) { 
    			try { 
    				System.out.println("producer wait");
    				wait();
    			}catch(InterruptedException e) { 
    				e.printStackTrace();
    			}
    			
    		}
    		products[top++] = product;
    		System.out.println(Thread.currentThread().getName()+"生产了产品"+product);
    		System.out.println("producer notifyAll");
    		notify();
    		
    	}
    	
    	public synchronized Product pop() { 
    		while(top == 0) { 
    			
    				System.out.println("consumer wait");
    			
    		}
    		
    		--top;
    		Product p = new Product(products[top].getId(),products[top].getName());
    		
    		products[top] = null;
    		System.out.println(Thread.currentThread().getName()+"消费了产品 "+ p);
    		System.out.println("comsumer notifyAll");
    		notifyAll();
    		
    		return p;
    		
    		
    	}
    }
    
    class Producer implements Runnable{ 
    	private Storage storage;
    	
    	public Producer(Storage storage) { 
    		this.storage = storage;
    	}
    
    	@Override
    	public void run() { 
    		// TODO Auto-generated method stub
    		int i= 0;
    		
    		Random r = new Random();
    		while(i < 10) { 
    			i++;
    			Product product  = new Product(i, "电话 "+r.nextInt(100));//r 产生一个 [0, 100) 的随机数
    			
    			storage.push(product);
    		}
    	}
    	
    	
    }
    
    class Product{ 
    	private int id;
    	private String name;
    	
    	public Product(int id, String name) { 
    		this.id = id;
    		this.name = name;
    	}
    	
    	public String toString() { 
    		return  "产品 ID" + id + "产品名称 "+name;
    	}
    	public int getId() { 
    		return id;
    	}
    	public void setId(int id) { 
    		this.id = id;
    	}
    	public String getName() { 
    		return name;
    	}
    }
    
    class  Consumer implements Runnable{ 
    	private Storage storage;
    	
    	public Consumer(Storage storage) { 
    		this.storage = storage;
    	}
    	
    	public void run() { 
    		int i = 0;
    		while(i < 10) { 
    			i++;
    			storage.pop();
    			try { 
    				Thread.sleep(100);
    			}catch(InterruptedException e) { 
    				e.printStackTrace();
    			}
    		}
    	}
    }