死锁是指多个线程在等待不可能被释放的锁,导致程序无法继续运行,下面用一个例子来说明。线程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进程。如下:
我们关心的进程是6696 AppMain。
使用jstack工具查看进程状态,发现死锁。如下:
关于jstack的使用可以参考:
http://www.cnblogs.com/zhengyun_ustc/archive/2013/01/06/dumpanalysis.html
参考:
java多线程编程核心技术