java多线程示例 模拟生产者消费者，多线程生产者,同步 多线程[Java]

java多线程示例 模拟生产者消费者，多线程生产者,同步 多线程[Java]

同步 多线程

[Java]代码

public class ProducerConsumer {    public static void main(String[] args) {        SyncStack ss=new SyncStack();        Producer pro=new Producer(ss);        Consumer con=new Consumer(ss);        new Thread(pro).start();        new Thread(pro).start();        new Thread(con).start();    }}class Product{    int id;    public Product(int id){        this.id=id;    }    public String toString(){//重写toString 方法，给pro加上编号，以便调试        return "product   "+id;    }}class SyncStack{//栈，先进后出    Product[] proArr=new Product[6];//定义容器只能装6件产品    int index=0;    public synchronized void push(Product pro){        while(index==proArr.length){//当容器装满了产品，暂停生产            try{                this.wait();            }catch(InterruptedException e){                e.printStackTrace();            }        }        this.notifyAll();//唤醒消费者消费        proArr[index]=pro;        index++;    }    public synchronized Product pop(){//同步，确保不被打断        while(index==0){//当容器里没有产品可消费，暂停消费            try{                this.wait();            }catch(InterruptedException e){                e.printStackTrace();            }        }        this.notifyAll();//唤醒生产者生产        index--;        return proArr[index];    }}class Producer implements Runnable{    SyncStack ss=null;    public Producer(SyncStack ss){        this.ss=ss;    }    public void run() {        for(int i=0;i<20;i++){            Product pro=new Product(i);            ss.push(pro);            System.out.println("生产了:"+pro);            try{//方便观察结果，没有实际意义                Thread.sleep((int)(Math.random()*200));            }catch(InterruptedException e){                e.printStackTrace();            }        }    }}class Consumer implements Runnable{    SyncStack ss=null;    public Consumer(SyncStack ss){        this.ss=ss;    }    public void run(){        for(int i=0;i<20;i++){            Product pro=ss.pop();            System.out.println("消费了:"+pro);            try{//方便观察结果，没有实际意义                Thread.sleep((int)(Math.random()*1000));            }catch(InterruptedException e){                e.printStackTrace();            }        }    }}