转载

每日一博 | 如何写一个 jstack 检测不到的死锁

通常java程序排查死锁的办法是通过jstack 打印出线程信息，里面会直接显示发生死锁的情况。这里我们先解释下查死锁可以采用的两种办法。然后我们写一个用普通的方法检测不到的死锁。

这里我们先贴一个简单的发生死锁的代码。

//class A
public class A implements Runnable {
     public void run() {
        synchronized (B.class){
            try {
                TimeUnit.SECONDS.sleep(5);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            synchronized (A.class){
                System.out.println("A println: i am finished");
            }
        }
    }
}
//class B
public class B implements Runnable {
    public void run() {
        synchronized (A.class){
            try {
                TimeUnit.SECONDS.sleep(5);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            synchronized (B.class){
                System.out.println("B println: i am finished");
            }
        }
    }
}
//main class
public class ABTest {
    public static void main(String[]args){
        ExecutorService executorService= Executors.newCachedThreadPool();
        executorService.submit(new A());
        executorService.submit(new B());
    }
}

##jstack查死锁办法 jstack查看死锁只需要两步：

jps 或者 ps 拿到对应的java进程号。
jstack

这样我们就能拿到对应进程的线程信息，比如运行上面发生死锁的代码，然后执行jstack我们就可以看到如下信息(省落部分信息)。

"pool-1-thread-2":
	at com.yao.bytecode.B.run(B.java:22)
	- waiting to lock <0x00000007956f8a10> (a java.lang.Class for com.yao.bytecode.B)
	- locked <0x00000007956f4cb8> (a java.lang.Class for com.yao.bytecode.A)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
	at java.util.concurrent.FutureTask.run(FutureTask.java:266)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
	at java.lang.Thread.run(Thread.java:745)
"pool-1-thread-1":
	at com.yao.bytecode.A.run(A.java:19)
	- waiting to lock <0x00000007956f4cb8> (a java.lang.Class for com.yao.bytecode.A)
	- locked <0x00000007956f8a10> (a java.lang.Class for com.yao.bytecode.B)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
	at java.util.concurrent.FutureTask.run(FutureTask.java:266)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
	at java.lang.Thread.run(Thread.java:745)

Found one Java-level deadlock:
"pool-1-thread-2":
  waiting to lock monitor 0x00007fb42c020cc8 (object 0x00000007956f8a10, a java.lang.Class),
  which is held by "pool-1-thread-1"
"pool-1-thread-1":
  waiting to lock monitor 0x00007fb42c0234a8 (object 0x00000007956f4cb8, a java.lang.Class),
  which is held by "pool-1-thread-2"

上面的信息很清楚显示pool-1-thread-1和 pool-1-thread-2在相互等待对方锁住的锁。

##利用ThreadMXBean 查死锁

这种办法是通过JMX(Java管理扩展)提供的管理接口ThreadMXBean来查看有没有死锁发生。不了解的JMX的基本使用的同学可以通过下面的例子了解或者直接去搜索了解下。放个的小例子，也是从网上搜到的。

//EchoMBean
public interface EchoMBean {
    public String print(String name);
}
//Echo
public class Echo implements EchoMBean {

    public String print(String name) {
        System.out.println("hi "+ name);
        return "hi "+name;
    }
}
//
public class MbeanTest {
    public static void main(String[]args) throws Exception {
        MBeanServer mBeanServer= ManagementFactory.getPlatformMBeanServer();
       //这里包名要和实现类Echo的包名一致
        ObjectName name=new ObjectName("com.yao.mbean:type=Echo");
        Echo mbean=new Echo();
        mBeanServer.registerMBean(mbean,name);
        mBeanServer.invoke(name,"print",new Object[]{"hello"},new String[]{"java.lang.String"});
        TimeUnit.SECONDS.sleep(Integer.MAX_VALUE);
    }
}

运行上面的代码，然后打开jconsole 或者jprofiler(需要自己安装)界面，连接到我们的上面开的程序，然后就可以通过界面操作我们注入的管理bean,输入方法参数点击执行，我们就可以在后台看到我们想要的执行。

简单介绍下Mbean的使用后我继续说下ThreadMXBean，这个接口我们主要看findMonitorDeadlockedThreads方法和查看具体线程信息方法getThreadInfo。因为jvm启动时，会自动把ThreadMXBean的实现类注入到管理平台中，因此我们可以直接通过jprofiler -> MBeans 找到java.lang Threading，然后点击operation，执行findMonitorDeadlockedThreads。即可看到结果。

然后就可以拿到发生死锁的线程id,在通过id 用getThreadInfo 看具体的信息。

jstack检测不到的死锁

介绍这么多，我们还没说怎么写个jstack检测不到的死锁。下面直接看代码，里面逻辑摘自《实战Java虚拟机》。直接先上代码：

public class StaticA {
    static {
        try {
            TimeUnit.SECONDS.sleep(10);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        try {
            Class.forName("com.yao.bytecode.StaticB");
        } catch (ClassNotFoundException e) {
            e.printStackTrace();
        }
        System.out.println("StaticA init OK");
    }
}
public class StaticB {
    static {
        try {
            TimeUnit.SECONDS.sleep(10);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        try {
            Class.forName("com.yao.bytecode.StaticA");
        } catch (ClassNotFoundException e) {
            e.printStackTrace();
        }
        System.out.println("StaticB init OK");
    }
}

public class StaticABTest extends Thread {
    private String flag;
    public StaticABTest(String flag) {
        this.flag = flag;
    }
    @Override
    public void run() {
        try {
            Class.forName("com.yao.bytecode.Static"+flag);
        } catch (ClassNotFoundException e) {
            e.printStackTrace();
        }
    }
    public static void main(String[]args) throws Exception {
        StaticABTest staticA=new StaticABTest("A");
        StaticABTest staticB=new StaticABTest("B");
        staticA.start();
        staticB.start();
        staticA.join();
        staticB.join();
    }
}

运行上面代码，会发生死锁一直运行，然后在运行我们的jstack去获取stack信息,我们看到任何死锁信息，用ThreadMXBean 也看不到(本质和jstack查死锁的原理差不多)。这是为什呢？

这和JVM初始化java bean的逻辑有关系，我们都知道JVM加载一个class 会有很多步骤：加载-> 连接(验证,准备,解析)->初始化。在初始化步骤中，JVM会执行类的函数，而static块里的逻辑会被编译器放到函数中，当JVM执行时会给加上锁，防止多线程并发执行。因此当staticA staticB 进行初始化时都拿到一把锁，然后在通过Class.forName去加载对方，因此都想获取对方要执行cinit的锁，因此死锁就此发生。

原文 https://my.oschina.net/robinyao/blog/807450

正文到此结束