读书人

生产者跟消费者不异步

发布时间: 2013-04-02 12:35:26 作者: rapoo

生产者和消费者不异步
代码见下 运行结果:
仓库已空,正等待生产...
生产者 生产了 1
生产者 生产了 2
生产者 生产了 3
。。。
生产者 生产了 10
仓库已满,正等待消费...
消费者 消费了 1
消费者 消费了 2
消费者 消费了 3
。。。
消费者 消费了 10

总是生产满了才消费 什么原因?


class Product {

private int productId = 0;

public Product(int productId) {
this.productId = productId;
}

public int getProductId() {
return productId;
}

public String toString() {
return Integer.toString(productId);
}
}



class StoreHouse {

private int base = 0;

private int top = 0;

// private Product[] products = new Product[10];
private LinkedList<Product> products=new LinkedList<Product>();

public synchronized void push(Product product) {
// while (top == products.length) {
while (products.size() == 10) {
notify();
try {
System.out.println("仓库已满,正等待消费...");
wait();
} catch (InterruptedException e) {
System.out.println("stop push product because other reasons");

}
}
// products[top] = product;
products.addLast(product);//add or addLast?
// top++;
}

public synchronized Product pop() {
Product pro = null;
// while (top == base) {
while (products.size() == 0) {
notify();
try {
System.out.println("仓库已空,正等待生产...");
wait();


} catch (InterruptedException e) {
System.out.println("stop push product because other reasons");

}
}
// top--;
// pro = products[top];
// products[top] = null;
pro=products.removeFirst();
return pro;
}
}





class Producer implements Runnable {

private String producerName = null;

private StoreHouse storeHouse = null;

public Producer(String producerName, StoreHouse storeHouse) {
this.producerName = producerName;
this.storeHouse = storeHouse;
}

public void setProducerName(String producerName) {
this.producerName = producerName;
}

public String getProducerName() {
return producerName;
}

public void produceProduct() {
int i = 0;
while (true) {
i++;
Product pro = new Product(i);
storeHouse.push(pro);
System.out.println(getProducerName() + " 生产了 " + pro);
try {
Thread.sleep(2000);
} catch (InterruptedException e) {
return;
}
}
}

public void run() {
produceProduct();
}

}




class Consumer implements Runnable {

private String consumerName = null;


private StoreHouse storeHouse = null;

public Consumer(String consumerName, StoreHouse storeHouse) {
this.consumerName = consumerName;
this.storeHouse = storeHouse;
}

public void setConsumerName(String consumerName) {
this.consumerName = consumerName;
}

public String getConsumerName() {
return consumerName;
}

public void consumerProduct() {
while (true) {
System.out.println(getConsumerName() + " 消费了 " + storeHouse.pop());
try {
Thread.sleep(5000);
} catch (InterruptedException e) {
return;
}
}
}

public void run() {
consumerProduct();
}

}




public class TestPc {
public static void main(String[] args) {
StoreHouse storeHouse = new StoreHouse();
Producer producer = new Producer("生产者", storeHouse);
Consumer comsumer = new Consumer("消费者", storeHouse);
Thread t1 = new Thread(producer);
Thread t2 = new Thread(comsumer);
t1.start();
t2.start();
}
}

[解决办法]
while (products.size() == 10)
[解决办法]
把notify方法放在while语句块的外面。push和pop方法都改。然后把生产者类和消费者类的sleep时间改成一样的。再试试。
[解决办法]
修改 StoreHouse 类

将第13行 放到第23行下面
将第31行放到第43行下面



[解决办法]
绿色行的有用到的吗?
------解决方案--------------------


读书人网 >J2SE开发

热点推荐