这些java线程是否在等待它获得的锁？

Question

我正在查看一个j堆栈日志，这就是我所看到的：

"com.mchange.v2.async.ThreadPoolAsynchronousRunner$PoolThread-#2“#250个守护进程prio=5 os_prio=0 tid=0x00007f9de0016000 nid=0x7e54 runnable 0x00007f9d6495a000 java.lang.Thread.State: RUNNABLE at com.mchange.v2.async.ThreadPoolAsynchronousRunner$PoolThread.run(ThreadPoolAsynchronousRunner.java:534) - locked <0x00000006fa818a38> (a 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:阻塞(在对象监视器上) at java.lang.Object.wait(原生方法)-等待<0x00000006fa818a38> ( com.mchange.v2.async.ThreadPoolAsynchronousRunner) at com.mchange.v2.async.ThreadPoolAsynchronousRunner$PoolThread.run(ThreadPoolAsynchronousRunner.java:534)锁定<0x00000006fa818a38> ( com.mchange.v2.async.ThreadPoolAsynchronousRunner) )) "com.mchange.v2.async.ThreadPoolAsynchronousRunner$PoolThread-#0“#248守护进程prio=5 os_prio=0 tid=0x00007f9de001a000 nid=0x7e52等待监视器条目0x00007f9d64a5c000 java.lang.Thread.State:阻塞(在对象监视器上) at java.lang.Object.wait(本机方法)-等待<0x00000006fa818a38> ( com.mchange.v2.async.ThreadPoolAsynchronousRunner) at com.mchange.v2.async.ThreadPoolAsynchronousRunner$PoolThread.run(ThreadPoolAsynchronousRunner.java:534) -锁定<0x00000006fa818a38> ( com.mchange.v2.async.ThreadPoolAsynchronousRunner) ))

因此，在这个日志中，这三个线程中的每一个都成功地获得了相同的锁，下面两个线程实际上被阻塞，等待相同的锁。

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

Answer 1

只有线程#2成功地获得了对象锁，并且处于可运行的状态。其他2个线程，即线程-#0和Thread-#1正在等待线程#2释放该锁。只要线程#2持有锁，Thread#0和Thread#1将保持锁定状态，并处于阻塞状态。

如果您可以访问源代码，您可以查看该代码，以确保是否按正确的顺序进行锁定和解锁，并且在必要时只对部分代码持有锁。请记住，这两个线程不是处于等待状态，而是处于阻塞状态，这是等待状态之后的一个步骤，在锁可用时进入RUNNABLE状态仅一步。

在这个日志片段中没有观察到问题。这还不是一个死锁的场景。

Answer 2

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

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

一旦调用wait，asyncRunner上的同步就会被“释放”，也就是说，应用程序的其他部分可以进入一个在该实例上同步的块。在您的特殊情况下，似乎已经发生了这种情况，并且返回了第一个线程的wait-call，并且它目前正在处理来自它的一些数据。您仍然可以在线程转储中看到多个locked-lines，以显示代码当前在synchronized-block中，但正如所述，调用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();
    }
}

如果添加了要处理的新消息，ThreadPoolAsynchronousRunner将启动PoolThreads并执行notifyAll。

// 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
    }
}

notifyAll将导致所有线程的wait-methods返回，因此您必须检查父线程中的队列是否仍然包含数据(有时wait甚至在未发生通知的情况下返回，因此即使不使用notifyAll也需要进行此检查)。如果是这种情况，则启动处理方法。您应该在synchronized-block之外这样做，否则异步处理类一次只处理一条消息(除非，这是您想要的--但是为什么要运行多个PoolThread-instances?)

Answer 3

我能看到和理解的是

线程-#2处于可运行状态，并已获得对象的锁。

"com.mchange.v2.async.ThreadPoolAsynchronousRunner$PoolThread-#2“java.lang.Thread.State: RUNNABLE

线程-#1和Thread-#0正在等待该对象锁的释放，因此现在被阻塞。

"com.mchange.v2.async.ThreadPoolAsynchronousRunner$PoolThread-#1“"com.mchange.v2.async.ThreadPoolAsynchronousRunner$PoolThread-#0”java.lang.Thread.State:在java.lang.Object.wait(原生方法)处阻塞(对象监视器)-等待<0x00000006fa818a38>