Java，锁定，条件 - 信号未唤醒等待线程

Question

我有一个问题，我被困了几个小时，我真的不知道如何解决它。这很简单——我有一些线程，其中一个需要等待来自另一个的信号。不知何故，即使我在某个条件下发出信号……什么也没有发生！看起来线程仍在休眠。确实是个很奇怪的问题，不过也有可能是我的错，我没看懂……

这是我的代码的一部分：

@Override
public void bodyProduced() {
    lock.lock();
    producedBodies++;
    if (producedEngines == 0) {
        while(producedEngines==0)
        {
            System.out.println("I am still waiting!");
            body.awaitUninterruptibly();
        }
        System.out.println("I waked up!");
        producedBodies--;
        producedEngines--;
    } else {
        engine.signalAll();
    }
}

我确定 body.signalAll();当有线程在该条件下等待时调用 - 我检查并调试器多次遍历该行。但是，“我在等待”这行在 thraad 中只出现一次，而“我醒来”则从未出现过......

任何想法，如何解决它，或检查什么？我几乎尝试了所有方法...

感谢您的宝贵时间和帮助！

Answer 1

如果您使用共享锁，您可能还需要在某个时候释放它。否则只有第一个线程能够越过第一行，其他线程将停止等待释放锁。

一旦你修复了锁，只要它们不是易失性的，你对producedBodies和producerEngines的增量和减量可能不会很好地工作。

无论如何，并发总是一个很难的话题，一般来说，不要自己编写这样的代码是一个很好的做法。每当您认为解决了并发问题时，您很可能只看到了冰山一角。

在您的情况下，我建议您考虑使用 Synchronized、CountDownLatch 还是 ExecutorServices？ （您还没有真正清楚地描述您遇到的问题）。如果 JDK 附带的所有功能都不适合您，那么还请查看 Heinz Kabutz's java newsletter，因为他知道如何使用并发。

Answer 2

当你使用ReentrantLock 时，你必须在你的临界区之后调用unlock()。这必须在 finally 子句中完成

lock.lock();
try{
 // critical section code (may throw exception)
} finally {
  lock.unlock();  
}

如果您不这样做（如在您的代码中），则没有线程能够进入此部分，因为它（正确地）假定此部分仍处于锁定状态。您必须明确解锁它才能允许其他线程进入。