一次由wait造成的死锁问题分析
文章目录
在多种方式实现在Java中用线程轮流打印ABC中自己本想用单个锁通过调用wait()实现轮流打印，但一直遇到全部等待并停止执行的死锁问题，经过网上求助和自己分析，最终找到问题原因，简单记录下。
原始代码
public class ThreadPrint4Test {
public static void main(String[] args) {
new ThreadPrint4Test().testPrint();
}
public void testPrint() {
Object lock = new Object();
new Thread(new PrintThread("A",lock),"thread-A").start();
new Thread(new PrintThread("B",lock),"thread-B").start();
new Thread(new PrintThread("C",lock),"thread-C").start();
try {
TimeUnit.SECONDS.sleep(1);
} catch (InterruptedException e) {
throw new RuntimeException(e);
}
new Thread(() -> {
synchronized (lock) {
lock.notifyAll();
}
}).start();
}
class PrintThread implements Runnable {
private Object lock;
private String value;
public PrintThread(String value, Object lock) {
this.value = value;
this.lock = lock;
}
public void run() {
while (true) {
try {
synchronized (lock) {
lock.wait();
System.out.println(LocalTime.now() + "\t" + value);
lock.notifyAll();
}
} catch (InterruptedException e) {
throw new RuntimeException(e);
}
}
}
}
}
执行结果&状态查看
运行上述程序，可发现在输出若干字符后，程序处于阻塞状态，输出停止：
利用jps和jstack命令查看，可发现3个进程都处于WAITING状态形成类似死锁的现象，由此导致程序停止输出。
由于多次运行上述代码，均能出现此问题(只不过出现的时间间隔不同)，可知程序代码肯定编写不正确。
原因分析
最开始检查代码时看起来一切正常:
- 某线程首先通过
wait()进入等待状态 - 只有被唤醒后才能继续往下执行输出代码
- 输出完毕后通过
notifyAll() - 被
notifyAll()唤醒的线程从步骤2开始往下执行 - 之后该线程调用
wait()进入等待状态，重复步骤1实现不间断的打印
public void run() {
while (true) {
try {
synchronized (lock) {
lock.wait();
System.out.println(LocalTime.now() + "\t" + value);
lock.notifyAll();
}
} catch (InterruptedException e) {
throw new RuntimeException(e);
}
}
}
上述推理与代码看起来很完美，无懈可击，但程序执行时就是每次都不能一直打印下去，肯定是自己的理解有问题。
为了便于定位问题，将run()方法修改为如下代码：
public void run() {
while (true) {
try {
synchronized (lock) {
String name = Thread.currentThread().getName();
System.out.println(name + "\t" + LocalTime.now() + "\t" + " will invoke wait");
lock.wait();
System.out.println(name + "\t" + LocalTime.now() + "\t" + " is notified");
System.out.println(name + "\t" + LocalTime.now() + "\t" + value);
lock.notifyAll();
}
} catch (InterruptedException e) {
throw new RuntimeException(e);
}
}
}
}
之后多次重新执行该程序，执行结果类似如下：
从上图可以看出中无法找出具体的问题复现规律，查看wait()的官方文档，有如下说明
The current thread must own this object’s monitor. The thread releases ownership of this monitor and waits until another thread notifies threads waiting on this object’s monitor to wake up either through a call to the
notifymethod or thenotifyAllmethod. The thread then waits until it can re-obtain ownership of the monitor and resumes execution.
查看notifyAll()的官方文档，有如下说明：
The awakened threads will not be able to proceed until the current thread relinquishes the lock on this object. The awakened threads will compete in the usual manner with any other threads that might be actively competing to synchronize on this object;
从上述说明中可获得如下信息：
- 调用
wait()方法后，程序会处于等待状态，同时释放锁 - 被
notifyAll()唤醒的线程并不会立即执行，需要等当前调用notifyAll()的线程释放对应的锁 - 被
notfiyAll()唤醒的线程需要与其它正在执行的线程一并去竞争获取锁，并没有区别对待
至此，可以大致找出问题原因
三个线程在某个时间段先后调用了
wait()方法都进入了WAITING状态，同时没有其它线程来唤醒它们，导致最终程序停止输出。
以线程A造成死锁为例，其过程如下:
- 线程A调用
wait()方法进入WAITING状态并释放锁 - 线程B获得锁，进入
synchronized代码块 - 线程B执行
wait()方法进行WAITING状态并释放锁 - 线程C获得锁，进入
synchronized代码块 - 线程C执行
wait()方法进行WAITING状态并释放锁 - 至此线程A、线程B、线程C均处于
WAITING状态，程序停止输出
图示说明如下：
改进代码
找到问题原因后，要修复此问题也很容，只需要避免所有的线程同时调用wait()方法即可，可在调用wait()前加个判断，确保始终有一个线程不用进入WAITING状态，能够释放锁。
消除死循环
public class ThreadPrint4Test {
public static void main(String[] args) {
new ThreadPrint4Test().testPrint();
}
private volatile String runThread;
public void testPrint() {
Object lock = new Object();
new Thread(new PrintThread("A", lock), "thread-A").start();
new Thread(new PrintThread("B", lock), "thread-B").start();
new Thread(new PrintThread("C", lock), "thread-C").start();
try {
TimeUnit.SECONDS.sleep(1);
} catch (InterruptedException e) {
throw new RuntimeException(e);
}
new Thread(() -> {
synchronized (lock) {
lock.notifyAll();
}
}).start();
}
class PrintThread implements Runnable {
private Object lock;
private String value;
public PrintThread(String value, Object lock) {
this.value = value;
this.lock = lock;
}
public void run() {
while (true) {
try {
synchronized (lock) {
boolean process = value.equals(runThread);
if (!process) {
lock.wait();
System.out.println(LocalTime.now() + "\t" + value);
runThread = value;
}
lock.notifyAll();
}
} catch (InterruptedException e) {
throw new RuntimeException(e);
}
}
}
}
}
实现轮流打印
public class ThreadPrint4Test {
public static void main(String[] args) {
new ThreadPrint4Test().testPrint();
}
private volatile int count = 0;
public void testPrint() {
Object lock = new Object();
new Thread(new PrintThread("A", lock), "thread-A").start();
new Thread(new PrintThread("B", lock), "thread-B").start();
new Thread(new PrintThread("C", lock), "thread-C").start();
}
class PrintThread implements Runnable {
private Object lock;
private String value;
public PrintThread(String value, Object lock) {
this.value = value;
this.lock = lock;
}
public void run() {
while (true) {
try {
synchronized (lock) {
boolean process = "A".equals(value) && count % 3 == 0;
if (process) {
count = 0;
}
process = process || ("B".equals(value) && count % 3 == 1);
process = process || ("C".equals(value) && count % 3 == 2);
if (process) {
lock.wait();
System.out.println(value);
count++;
Thread.sleep(500);
}
lock.notifyAll();
}
} catch (InterruptedException e) {
throw new RuntimeException(e);
}
}
}
}
}