生产者与消费者问题

知识点:生产者与消费者问题

场景

生产者(Producer)生产产品,送到店员那里(Clerk)那里,消费者(Customer)从店员那里取走产品,店员只能持有一定数量的产品(如:20),如果店员那里已经有了20个产品,店员会通知生产者停一下(wait()),店中有空位置放产品时,通知生产者继续生产,如果店员那里没有产品了,会通知消费者等一下,店中有产品了,通知消费者继续消费。

 

实例

class Clerk { //店员
int product;
public synchronized void AddProduct(){
if(product<20){ //产品小于20时,继续生产产品
product++;
System.out.println(Thread.currentThread().getName()+"生产了第"+product+"个产品");
notifyAll(); //产品为0时,消费者等待,产品product++,有产品了,通知消费者继续消费
}else {
try {
wait(); //产品大于等于20时,生产者等待
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
public synchronized void ConsumeProduct(){
if(product>0){ //产品大于0时,消费者取走产品
System.out.println(Thread.currentThread().getName()+"消费了第"+product+"个产品");
product--;
notifyAll(); //产品为20时,生产者等待,产品product--,有产品的空位置时,通知生产者继续生产
}else {
try {
wait(); //产品为0时,消费者等待
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
}
class Producer implements Runnable{//生产者
Clerk clerk;
public Producer(Clerk clerk){
this.clerk=clerk;
}
@Override
public void run() {
while (true){
clerk.AddProduct();
}
}
}

class Consumer implements Runnable{ //消费者
Clerk clerk;
public Consumer(Clerk clerk){
this.clerk=clerk;
}
@Override
public void run() {
while (true) {
clerk.ConsumeProduct();
}
}
}
上一篇:一、托业单词之办公室事宜 Office matters


下一篇:Oracle并列排名显示