为了账号安全,请及时绑定邮箱和手机立即绑定

这些Java线程是否在等待它获得的锁?

这些Java线程是否在等待它获得的锁?

12345678_0001 2021-04-12 21:23:08
我正在查看一个jstack日志,这是我所看到的:“ com.mchange.v2.async.ThreadPoolAsynchronousRunner $ PoolThread-#2”#250守护程序prio = 5 os_prio = 0 tid = 0x00007f9de0016000 nid = 0x7e54可运行[0x00007f9d6495a000] java.lang.Thread.State:com.mchange.v在RUNNABLE .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.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:BLOCKED(在对象上监视器)在java.lang.Object.wait(本机方法)-在< 0x00000006fa818a38 >(com.mchange.v2.async.ThreadPoolAsynchronousRunner)(在com.mchange.v2.async.ThreadPoolAsynchronousRunner $ PoolThread.run(ThreadPoolAsynchronousRunner.java)上等待:534)-锁定< 0x00000006fa818a38 >(com.mchange.v2.async.ThreadPoolAsynchronousRunner)因此,在此日志中,这三个线程中的每个线程都设法获得了相同的锁,并且实际上阻塞了底部的两个线程,以等待相同的锁。有人可以告诉我这个堆栈日志是什么意思吗?
查看完整描述

3 回答

?
白衣非少年

TA贡献1155条经验 获得超0个赞

最后两个线程正在等待使用ThreadPoolAsynchronousRunneras监视器的实例进行通知,因此该线程的源将如下所示:


synchronized(asyncRunner) {

    // ...

    asyncRunner.wait();

    // ...

}

调用时wait,同步asyncRunner“已释放”,即应用程序的其他部分可以输入在该实例上同步的块。在您的特定情况下,这似乎已经发生,并且第一个线程的wait-call返回了,并且当前正在处理来自它的一些数据。您仍会locked在线程转储中看到多行代码,以向您显示代码当前位于-block中,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();

    }

}

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线程的所有方法都返回,因此您必须检查父级队列中是否仍然包含数据(有时wait即使没有通知也会返回数据,因此即使不使用,也需要进行此检查notifyAll)。如果是这种情况,请启动处理方法。您应该在synchronized-block之外执行此操作,否则异步处理类一次只能处理一条消息(除非那是您想要的-但是为什么要运行多个PoolThread-instances?)


查看完整回答
反对 回复 2021-04-28
?
临摹微笑

TA贡献1982条经验 获得超2个赞

只有线程#2设法成功获得对象锁定,并且它处于RUNNABLE状态。其他2个线程(即Thread-#0Thread-#1)正在等待Thread-#2释放该锁。只要Thread-#2保持锁定,Thread-#0Thread-#1将保持锁定状态,并处于BLOCKED状态。

如果您有权访问源代码,则可以查看该代码,以确保是否以正确的顺序进行了锁定和解锁,并且仅在必要时才对部分代码进行了锁定。请记住,这两个线程不是处于WAIT状态,而是处于BLOCKED状态,这是WAIT状态之后的一个步骤,并且在锁定可用后立即进入RUNNABLE状态之前的一个步骤。

在此日志片段中未发现任何问题。这还不是僵局。


查看完整回答
反对 回复 2021-04-28
?
绝地无双

TA贡献1946条经验 获得超4个赞

我能看到和理解的是

线程#2处于可运行状态,并已获得对象上的锁

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

线程#1线程#0正在等待该对象锁被释放并因此立即被阻塞。

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


查看完整回答
反对 回复 2021-04-28
  • 3 回答
  • 0 关注
  • 194 浏览

添加回答

举报

0/150
提交
取消
意见反馈 帮助中心 APP下载
官方微信