youhebuke52011 2015-08-10 09:12 采纳率: 0%
浏览 2334
已采纳

生产者与消费者问题(JAVA实现)

 public class TestProducerConsumer{
    public static void main(String[] agrs){
        SyncStack ss = new SyncStack();
        Producer p = new Producer(ss);
        ConSumer c = new ConSumer(ss);
        new Thread(p).start();
        new Thread(c).start();

    }
}

class Woto{

    int id;
    public Woto(int id){
        this.id = id;
    }

    public String toString(){
        return "Woto:" + id;
    }
}
class SyncStack{
    int index = 0;
    Woto[] w = new Woto[8];

    public synchronized void push(Woto wt){
        while(index == w.length){
            try {
                this.wait();
            } catch (InterruptedException e) {

                e.printStackTrace();
            }
        }
        this.notify();
        w[index] = wt;
        index++;
    }

    public synchronized Woto pop(){
        while(index == 0){
            try {
                this.wait();
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
        this.notify();
        index--;
        return w[index];
    }
}

class Producer implements Runnable{
    SyncStack ss = null;
    public Producer(SyncStack ss){
        this.ss = ss;
    }

    public void run() {
        for(int i = 0;i<10;i++){
            Woto wt = new Woto(i);
            ss.push(wt);
            System.out.println("生产了="+wt);
            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<10;i++){

            Woto wt =ss.pop();
            System.out.println("消费了="+wt);
            try {
                Thread.sleep((int) (Math.random() * 1000));
            } catch (InterruptedException e) {
                e.printStackTrace();
            }

        }
    }
}

为什么会先出现消费者呢 ?求大神解答

图片说明

这里很明显是先start生产者 怎么可能先消费者呢
new Thread(p).start();
new Thread(c).start();

  • 写回答

3条回答 默认 最新

  • 丵鹰 2015-08-10 09:50
    关注

    线程是异步的,不是你先写了谁谁就在前,看最好的效果就是弄2个线程通执行一个方法,,要想同步的只能是在同用一个方法时使用synchronized来修饰方法

    本回答被题主选为最佳回答 , 对您是否有帮助呢?
    评论
查看更多回答(2条)

报告相同问题?