关于java：如何在多线程中使用wait和notify协议

How to use wait and notify protocol with multiple threads

具体来说，谁能告诉我这段代码有什么问题。它应该启动线程，所以应该打印”进入线程..” 5 次，然后等到 notifyAll() 被调用。但是，它会随机打印”Entering..”和”Done..”，并且仍然在等待其他人。

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32

public class ThreadTest implements Runnable {
private int num;
private static Object obj = new Object();
ThreadTest(int n) {
num=n;
}
@Override
public void run() {
synchronized (obj) {
try {
System.out.println(“Entering thread”+num);
obj.wait();
System.out.println(“Done Thread”+num);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}

public static void main(String[] args) {
Runnable tc;
Thread t;
for(int i=0;i<5;i++) {
tc = new ThreadTest(i);
t = new Thread(tc);
t.start();
}
synchronized (obj) {
obj.notifyAll();
}
}
}

您没有对方法调用做任何明显错误的事情，但您有一个竞争条件。

虽然在理想世界中，主线程将在所有工作线程到达 wait() 调用后到达其同步块，但不能保证这一点(您明确告诉虚拟机您不想要线程通过使它们成为线程来与主线程按顺序执行)。可能会发生(例如，如果您只有一个内核)线程调度程序决定立即阻止所有工作线程，它们开始允许主线程继续。可能是由于缓存未命中，工作线程被上下文切换了。可能是一个工作线程阻塞了 I/O(打印语句)并且主线程被切换到它的位置。

因此，如果主线程在所有工作线程到达 wait() 调用之前设法到达同步块，则那些尚未到达 wait() 调用的工作线程将无法按预期运行。由于当前设置不允许您对此进行控制，因此您必须添加对此的显式处理。您可以添加某种变量，该变量在每个工作线程到达 wait() 时递增，并让主线程在此变量达到 5 之前不调用 notifyAll()，或者您可以让主线程循环并重复调用 notifyAll()，以便工作线程在多个组中释放。

看看 java.util.concurrent 包 – 有几个锁类提供了比基本同步锁更强大的功能 – 与以往一样，Java 使您免于重新发明轮子。 CountDownLatch 似乎特别相关。

总之，并发是很难的。您必须进行设计以确保当线程以您不想要的顺序以及您想要的顺序执行时一切仍然有效。

How to use wait and notify protocol with multiple threads

猜你喜欢