Состояние замка Reentrance

Question

public class MyLockConditionTest { 
    private final Lock alock = new ReentrantLock(); 
    private final Condition condition = alock.newCondition(); 
    private String message = null; 

    public void waitForCallback() { 
     alock.lock(); 
     try { 
      // wait for callback from a remote server 
      condition.await(); 
      doSomething(message); 
     } finally { 
       alock.unlock(); 
     } 
    } 

    // another thread will call this method as a callback to wake up the thread called condition.await() 
    public void onCallbackReceived(String message) { 
     alock.lock(); 
     try { 
      this.message = message 
      condition.signal(); 
     } finally { 
       alock.unlock(); 
     } 
    } 
} 

У меня есть этот код с использованием ReentrantLock и Condition для реализации класса, который будет ждать определенных обратных вызовов с удаленного сервера. Я тестировал этот код и, кажется, работаю, но у меня есть несколько вопросов.

1. Зачем мне нужно делать alock.lock()/unlock() в onCallbackReceived(). Без вызова lock()/unlock() я получал исключение IllegalState. Я запутался, потому что блокировка удерживается вызывающим объектом waitForCallback(), когда onCallbackReceived() вызывается другим потоком, так что alock.lock() в onCallbackReceived() всегда терпит неудачу.

2. Нужно ли обертывать условие.await() в waitForCallback() с циклом while?

   в то время как (сообщение == null) состояние.await();

Answer 1

Почему мне нужно сделать alock.lock()/разблокировки() в onCallbackReceived(). Без вызова lock()/unlock() я получал исключение IllegalState.

Вы пытаетесь установить signal состояние, в котором вы не являетесь владельцем замка. Единственный способ удерживать замок - если onCallbackReceived вызывается из doSomething, в котором нет указаний, которые происходят.

Нужно ли обертывать условие.await() в waitForCallback() с циклом while?

Да, представьте, что у вас есть 5 потоков, остановленных при условии, и 5 потоков заблокированы на lock. Только один поток может проснуться. Что, если, когда ожидающая нить наконец просыпается, в другом потоке было пустое поле? Вам нужно будет снова проверить, чтобы предикат по-прежнему оставался верным.