多线程编程
编写生产者/消费者模式程序:生产者向堆栈中压数据,消费者从堆栈中取数据。生产者和消费者共同使用同一个堆栈。
要求:生产者每隔600ms产生一个0~999之间的一个随机数,保存在堆栈中,一共200个。消费者从堆栈中取出200个数据,间隔500ms。试编写堆栈类,编写创建消费者、生产者的线程,并演示两个生产者线程,三个消费者线程运行过程。
好像有个地方出错了,怎么改呀???
追答线程上有点冲突……等我回头改改
package StackDemo;
import java.util.Random;
import java.util.Stack;
public class StackDemo {
private static Stack stack = new Stack();
class Worker implements Runnable {
private String name;
private Random random = new Random();
private int data;
private boolean isProducer;
public Worker(String name, boolean isProducer) {
this.name = name;
this.isProducer = isProducer;
}
public void run() {
while (true) {
synchronized (this) {
if (isProducer) {
if (StackDemo.stack.size() < 200) {
try {
Thread.sleep(600);
} catch (InterruptedException e) {
e.printStackTrace();
}
data = random.nextInt(1000);
StackDemo.stack.push(data);
System.out.println(Thread.currentThread().getName()
+ this.name + "生产了" + data + " 堆栈里还剩下"
+ StackDemo.stack.size() + "个数据");
}
} else {
if (!StackDemo.stack.isEmpty()) {
try {
Thread.sleep(500);
} catch (InterruptedException e) {
e.printStackTrace();
}
int data = StackDemo.stack.pop();
System.out.println(Thread.currentThread().getName()
+ this.name + "消耗了" + data + " 堆栈里还剩下"
+ StackDemo.stack.size() + "个数据");
}
}
}
}
}
}
public static void main(String[] args) {
StackDemo stackDemo = new StackDemo();
Worker p1 = stackDemo.new Worker("生产者", true);
Worker t1 = stackDemo.new Worker("消费者", false);
new Threa
发不全,你留邮箱吧
追问谢谢了
还是不正确
我都不知道怎么改
追答类名根文件名保存一致………
大兄弟你这是啥也不会啊……
追问保持一致了也不行啊
生产消费停不下来了
追答不用停下来
追问不是生产200个么???
追答容器大小是200。意味着生产者最多能生产200,但是当消费者将其消耗了之后,容器又空了,就又可以生产了
本回答被提问者采纳