| 网站首页 | 业界新闻 | 小组 | 威客 | 人才 | 下载频道 | 博客 | 代码贴 | 在线编程 | 编程论坛
欢迎加入我们,一同切磋技术
用户名:   
 
密 码:  
共有 570 人关注过本帖
标题:生产者和消费者问题?
只看楼主 加入收藏
E_xuan
Rank: 1
等 级:新手上路
帖 子:30
专家分:1
注 册:2009-9-13
结帖率:90%
收藏
 问题点数:0 回复次数:1 
生产者和消费者问题?
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) {
        while(index == arrWT.length) {
            try {
                this.wait();
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
        this.notify();        
        arrWT[index] = wt;
        index ++;
    }
   
    public synchronized WoTou pop() {
        while(index == 0) {
            try {
                this.wait();
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
        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);
            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;
    Consumer(SyncStack ss) {
        this.ss = ss;
    }
   
    public void run() {
        for(int i=0; i<20; i++) {
            WoTou wt = ss.pop();
System.out.println("消费了: " + wt);
            try {
                Thread.sleep((int)(Math.random() * 1000));
            } catch (InterruptedException e) {
                e.printStackTrace();
            }            
        }
    }
}

麻烦高手指点下,就是下面的方法我弄的有点乱,下面红色勾勒出来的是我的问题?
还有能不能详细说明下程序是如何执行的?

public synchronized void push(WoTou wt) {
        while(index == arrWT.length) {
            try {
                this.wait();       当生产者生产满的时候,调用wait方法时,会wait,然后执行其他线程,不会执行下面的this.notifyAll()方法吗?               
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
        this.notifyAll();        
        arrWT[index] = wt;
        index ++;
    }
搜索更多相关主题的帖子: 生产者 消费者 
2009-09-29 17:43
lixingjiang
Rank: 3Rank: 3
来 自:滁州学院
等 级:论坛游侠
帖 子:104
专家分:184
注 册:2009-4-17
收藏
得分:0 
不懂!

为梦想冲刺
2009-09-30 12:31
快速回复:生产者和消费者问题?
数据加载中...
 
   



关于我们 | 广告合作 | 编程中国 | 清除Cookies | TOP | 手机版

编程中国 版权所有,并保留所有权利。
Powered by Discuz, Processed in 0.044568 second(s), 8 queries.
Copyright©2004-2024, BCCN.NET, All Rights Reserved