Java, Lock, Condition - Signal not waking waiting thread

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(); вызывается, когда в этом состоянии присутствуют потоки - я проверил, и отладчик много раз перебирает эту строку. Тем не менее, строка «Я жду» появляется только один раз за трэд, а «я просыпаюсь» никогда ...

Любые идеи, как исправить, или что проверить? Я попробовал почти все ...

Спасибо за ваше время и помощь!

Answer 1

Если вы используете общий замок, вам, вероятно, также придется отпустить его в какой-то момент. иначе только первая нить сможет пройти мимо первой строки, а остальные потоки перестанут ждать освобождения блокировки.

Также ваши приращения и декреты произведенных органов и произведенных двигателей, вероятно, не будут работать очень хорошо, как только вы исправите предмет блокировки, если они не будут изменчивыми.

В любом случае, параллелизм всегда является сложной темой, и, как правило, очень хорошая практика не писать такой код по вашему. Всякий раз, когда вы думаете, вы решили проблему параллелизма, вы, скорее всего, видите только вершину айсберга.

в вашем случае, я рекомендую, учитывая использование Synchronized, CountDownLatch или, возможно, ExecutorServices? (Вы на самом деле не описали проблему, которая у вас есть). Если ни одна из функций, прилагаемых к JDK, не работает для вас, пожалуйста, также взгляните на Heinz Kabutz's java newsletter, потому что этот парень знает, как работать с параллелизмом.

Answer 2

Когда вы используете ReentrantLock, вы должны вызвать unlock() после критического раздела. Это должно быть сделано в наконец пункте

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

Если вы не сделаете это (например, в коде), ни один поток не сможет войти в этот раздел, поскольку он предполагает (правильно), что этот раздел по-прежнему заблокирован , Вы должны явно разблокировать его, чтобы разрешить другой поток.