24小时热门版块排行榜

返回列表

本帖产生 1 个程序强帖，点击这里进行查看

当前只显示满足指定条件的回帖，点击这里查看本话题的所有回帖

qqhegg

荣誉版主 (文坛精英)

珊瑚小美-----小元家的九妹

程序强帖: 2
应助: 10 (幼儿园)
贵宾: 3.115
金币: 23915.9
散金: 14806
红花: 179
沙发: 138
帖子: 11542
在线: 770.7小时
虫号: 1212338
注册: 2011-02-24
性别: MM
管辖: 基金申请交流

【答案】应助回帖

★ ★
感谢参与，应助指数 +1
微尘、梦想(金币+2, 程序强帖+1): 好久不见，有心了，祝好~ 2011-12-16 12:13:49
sangzhipei1178(金币+70): xiexie 2011-12-19 23:43:25

看一下可不可以，找人帮你写的呵呵呵
package thread;

class ShareData
{
private char c;
private boolean isProduced = false; // 信号量

public synchronized void putShareChar(char c)  // 同步方法putShareChar()
{
if (isProduced)    // 如果产品还未消费，则生产者等待
{
try
{
wait();       // 生产者等待
}catch(InterruptedException e){
e.printStackTrace();
}
}
this.c = c;
isProduced = true; // 标记已经生产
notify();          // 通知消费者已经生产，可以消费
}

public synchronized char getShareChar()  // 同步方法getShareChar()
{
if (!isProduced) // 如果产品还未生产，则消费者等待
{
try
{
wait();    // 消费者等待
}catch(InterruptedException e){
e.printStackTrace();
}
}
isProduced = false; // 标记已经消费
notify();          // 通知需要生产
return this.c;
}
}

class Producer extends Thread    // 生产者线程
{
private ShareData s;
Producer(ShareData s)
{
this.s = s;
}
public void run()
{
for (char ch = 'A'; ch <= 'D'; ch++)
{
try
{
Thread.sleep((int)(Math.random()*3000));
}catch(InterruptedException e){
e.printStackTrace();
}
s.putShareChar(ch);  // 将产品放入仓库
System.out.println(ch + " is produced by Producer."

;
}
}
}

class Consumer extends Thread // 消费者线程
{
private ShareData s;
Consumer(ShareData s)
{
this.s = s;
}
public void run()
{
char ch;
do{
try
{
Thread.sleep((int)(Math.random()*3000));
}catch(InterruptedException e){
e.printStackTrace();
}
ch = s.getShareChar(); // 从仓库中取出产品
System.out.println(ch + " is consumed by Consumer. "

;
}while (ch != 'D');
}
}

public class CommunicationDemo
{
public static void main(String[] args)
{
ShareData s = new ShareData();
new Consumer(s).start();
new Producer(s).start();
}
}

赞一下(1人)

回复此楼

每天都是新的一天，每天上帝都会给你不同的惊喜

3楼2011-12-16 11:11:29

已阅回复此楼关注TA 给TA发消息送TA红花 TA的回帖

相关版块跳转我要订阅楼主 sangzhipei1178 的主题更新

返回列表