我正在查看 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: 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 daemon prio=5 os_prio=0 tid=0x00007f9de000c000 nid=0x7e53 waiting for monitor entry [0x00007f9d649db000] java.lang.Thread.State: BLOCKED (on object monitor) at java.lang.Object.wait(Native Method) - waiting on <0x00000006fa818a38> (a com.mchange.v2.async.ThreadPoolAsynchronousRunner) 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-#0" #248 daemon prio=5 os_prio=0 tid=0x00007f9de001a000 nid=0x7e52 waiting for monitor entry [0x00007f9d64a5c000] java.lang.Thread.State: BLOCKED (on object monitor) at java.lang.Object.wait(Native Method) - waiting on <0x00000006fa818a38> (a com.mchange.v2.async.ThreadPoolAsynchronousRunner) at com.mchange.v2.async.ThreadPoolAsynchronousRunner$PoolThread.run(ThreadPoolAsynchronousRunner.java:534) - locked <0x00000006fa818a38> (a com.mchange.v2.async.ThreadPoolAsynchronousRunner)
因此,在此日志中,这三个线程中的每一个都设法获得了相同的锁,并且底部的两个线程实际上被阻塞以等待相同的锁。
有人可以向我解释一下这个堆栈日志的含义吗?
最佳答案
最后两个线程正在等待使用 ThreadPoolAsynchronousRunner 的实例作为监视器来通知,因此其来源将如下所示:
synchronized(asyncRunner) {
// ...
asyncRunner.wait();
// ...
}
一旦调用 wait
,asyncRunner
上的同步就会“释放”,即应用程序的其他部分可以进入在该实例上同步的 block 。在您的特定情况下,似乎已经发生了这种情况,并且第一个线程的 wait
调用已返回,并且当前正在处理来自它的一些数据。您仍然在线程转储中看到多个锁定
行,以表明代码当前位于同步
block 内,但如上所述,“锁”在以下情况下被释放:调用等待
。
在将并发包添加到 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
-实例?)
关于java - 这些java线程是否正在等待它获取的锁?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/51047148/