【发布时间】:2016-03-15 21:48:05
【问题描述】:
我试图阅读 Producer Consumer 解决方案,但遇到了以下代码:
package SampleProjects;
public class ProducerConsumerTest {
public static void main(String[] args) {
CubbyHole c = new CubbyHole();
Producer p1 = new Producer(c, 1);
Consumer c1 = new Consumer(c, 1);
p1.start();
c1.start();
}
}
class CubbyHole {
private int contents;
private boolean available = false;
public synchronized int get() {
while (available == false) {
try {
wait();
} catch (InterruptedException e) {
}
}
available = false;
notifyAll();
return contents;
}
public synchronized void put(int value) {
while (available == true) {
try {
wait();
} catch (InterruptedException e) {
}
}
contents = value;
available = true;
notifyAll();
}
}
class Consumer extends Thread {
private final CubbyHole cubbyhole;
private final int number;
public Consumer(CubbyHole c, int number) {
cubbyhole = c;
this.number = number;
}
@Override
public void run() {
for (int i = 0; i < 10; i++) {
int value = cubbyhole.get();
System.out.println("Consumer #" + this.number + " got: " + value);
}
}
}
class Producer extends Thread {
private final CubbyHole cubbyhole;
private final int number;
public Producer(CubbyHole c, int number) {
cubbyhole = c;
this.number = number;
}
@Override
public void run() {
for (int i = 0; i < 10; i++) {
cubbyhole.put(i);
System.out.println("Producer #" + this.number + " put: " + i);
try {
sleep((int) (Math.random() * 100));
} catch (InterruptedException e) {
}
}
}
}
在这段代码中,两个线程都调用了不同的方法,即生产者线程只关心put方法,消费者线程只关心get方法,所以我想知道当我们有一个循环来检查时为什么我们需要同步它们对于内容“while(available)”
然后我删除了 synchronized 关键字,它抛出了一个 IllegalStateMonitor 异常
所以我的问题是我们是否需要同步关键字才能调用 notifyAll()
【问题讨论】:
标签: java multithreading synchronized