Java死锁示例及检测

时间:2021-12-11 16:35:17

死锁是指多个线程在等待不可能被释放的锁,导致程序无法继续运行,下面用一个例子来说明。线程A持有lock1,在等待lock2,线程B持有lock2,在等待lock1,这样就发生了死锁。

首先看一个类DealThread,这个类含有互斥锁,以synchronized代码块的形式表示,线程A使用锁的顺序是lock1->lock2。线程B使用锁的顺序是lock2->lock1。在一个线程获得一个锁后,在获得第二个锁之前,要sleep一段时间,好让第二个线程先获得第二个锁。代码如下:

package deaklock;

public class DealThread implements Runnable {

private Object lock1 = new Object();
private Object lock2 = new Object();

@Override
public void run() {
String threadName = Thread.currentThread().getName();

if(threadName.equals("A")){ //A线程,获取锁的顺序为先lock1,后lock2
synchronized (lock1){
System.out.println("thread A get lock1,run and try to get lock2");

try {Thread.sleep(1000);} catch (InterruptedException e) {e.printStackTrace();}

synchronized (lock2){
System.out.println("thread A get lock2");
}

System.out.print("A finish its job");
}

}else if(threadName.equals("B")){ //B线程,获取锁的顺序为先lock2,后lock1
synchronized (lock2){
System.out.println("thread B get lock2, run and try to get lock1");

try {Thread.sleep(1000);} catch (InterruptedException e) {e.printStackTrace();}

synchronized (lock1){
System.out.println("thread B get lock1");
}

System.out.print("B finish its job");
}
}

}
}

下面是测试代码,利用上面的实现的Runnable接口创建两个不同的线程,第二个参数为线程的名字。

package deaklock;

public class DeadLockTest {

public static void main(String[] args){
DealThread dealThread = new DealThread();

Thread t1 = new Thread(dealThread,"A");
Thread t2 = new Thread(dealThread,"B");

t1.start();
t2.start();
}

}

程序输出如下,没有其他输出了,说明程序还没执行完:

thread A get lock1,run and try to get lock2
thread B get lock2, run and try to get lock1

发送死锁之后,我们可以使用java自动的一些工具进行检测。
首先是使用jps工具查看java进程。如下:
Java死锁示例及检测
我们关心的进程是6696 AppMain。

使用jstack工具查看进程状态,发现死锁。如下:
Java死锁示例及检测

关于jstack的使用可以参考:
http://www.cnblogs.com/zhengyun_ustc/archive/2013/01/06/dumpanalysis.html

参考:
java多线程编程核心技术