这些java线程正在等待它获取的锁吗？

Question

我正在查看一个jstack日志,下面是我看到的：

“com.mchange.v2.async.ThreadPoolAsynchronousRunner$PoolThread-#2”#250 daemon prio=5 os_prio=0 tid=0x00007F9DE0016000 nid=0x7e54 runnable[0x00007F9D6495A000]java.lang.Thread.State：在com.mchange.v2.async.ThreadPoolAsynchronousRunner处可运行$PoolThread.Run(ThreadPoolAsynchronousRunner.java:534)-锁定<0x00000006FA818A38>（一个com.mchange.v2.async.ThreadPoolAsynchronousRunner）

“com.mchange.v2.async.ThreadPoolAsynchronousRunner$PoolThread-#1”#249后台进程prio=5 OS_prio=0 tid=0x00007F9DE000C000 NID=0x7E53等待监视器条目[0x00007F9D649DB000]java.lang.Thread.State：在java.lang.object.wait（本机方法）-在<0x00000006FA818A38>（com.mchange.v2.async.ThreadPoolAsynchronousRunner）在com.mchange.v2.async.ThreadPoolAsynchronousRunner$PoolThread.run（ThreadPoolAsynchronousRunner上等待OusRunner.java:534)-锁定<0x00000006FA818A38>（一个com.mchange.v2.async.ThreadPoolAsynchronousRunner)

“com.mchange.v2.async.ThreadPoolAsynchronousRunner$PoolThread-#0”#248 daemon prio=5 os_prio=0 tid=0x00007F9DE001A000 nid=0x7e52等待监视器条目[0x00007F9D64A5C000]java.lang.Thread.state：在java.lang.object.wait（本机方法）-在<0x00000006FA818A38>（com.mchange.v2.async.ThreadPoolAsynchronousRunner）在com.mchange.v2.async.ThreadPoolAsynchronousRunner$PoolThread.run（ThreadPoolAsynn）上被阻止（在对象监视器上）ChronousRunner.java:534)-锁定<0x00000006FA818A38>（一个com.mchange.v2.async.ThreadPoolAsynchronousRunner)

因此，在本日志中，这三个线程中的每一个线程都设法获得了相同的锁，而底部的两个线程实际上被阻塞了，等待相同的锁。

有人能给我解释一下这个堆栈日志是什么意思吗？

Answer 1

最后两个线程正在等待通过使用ThreadPoolAsynchronousRunner的实例作为监视器得到通知，因此其来源如下所示：

synchronized(asyncRunner) {
    // ...
    asyncRunner.wait();
    // ...
}

只要调用wait，Asyncrunner上的同步就会“释放”，即应用程序的其他部分可以进入在该实例上同步的块。在您的特定情况下，似乎已经发生了这种情况，第一个线程的wait-call返回，并且它当前正在处理来自它的一些数据。您仍然会在线程转储中看到多个locked行，以显示代码当前在synchronized块中，但如前所述，当调用wait时会释放“锁”。

您在这里看到的线程转储技术在将并发包添加到JDK以避免代价高昂的线程创建之前是非常常见的。您的线程转储类似于这种实现。下面是一个简单的实现，它看起来像是“在引擎盖下”：

// class ThreadPoolAsynchronousRunner
private Deque<AsyncMessage> queue;

public synchronized void addAsyncMessage(AsyncMessage msg) {
    queue.add(msg);
    notifyAll();
}

public void start() {
    for (int i = 0; i < 4; i++) {
        PoolThread pt = new PoolThread(this);
        pt.start();
    }
}

// PoolThread

public PoolThread(ThreadPoolAsynchronousRunner parent) {
    this.parent = parent;
}

public void run() {
    try {
        while (true) {
            AsyncMessage  msg = null;
            synchronized(parent) {
                parent.wait();
                if (!parent.queue.isEmpty()) {
                    msg = queue.removeFirst();
                }
            }
            if (msg != null) {
                processMsg(msg);
            }
        }
    }
    catch(InterruptedException ie) {
        // exit
    }
}