3 回答
![?](http://img1.sycdn.imooc.com/5f33c0c90001f9ad05720572-100-100.jpg)
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?)
![?](http://img1.sycdn.imooc.com/5458477300014deb02200220-100-100.jpg)
TA贡献1982条经验 获得超2个赞
只有线程#2设法成功获得对象锁定,并且它处于RUNNABLE状态。其他2个线程(即Thread-#0和Thread-#1)正在等待Thread-#2释放该锁。只要Thread-#2保持锁定,Thread-#0和Thread-#1将保持锁定状态,并处于BLOCKED状态。
如果您有权访问源代码,则可以查看该代码,以确保是否以正确的顺序进行了锁定和解锁,并且仅在必要时才对部分代码进行了锁定。请记住,这两个线程不是处于WAIT状态,而是处于BLOCKED状态,这是WAIT状态之后的一个步骤,并且在锁定可用后立即进入RUNNABLE状态之前的一个步骤。
在此日志片段中未发现任何问题。这还不是僵局。
![?](http://img1.sycdn.imooc.com/5333a1920001d36402200220-100-100.jpg)
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>
添加回答
举报