Блог

Документы Java отсюда https://docs.oracle.com/javase/7/docs/api/java/util/concurrent/locks/Condition.html

Я пытаюсь понять концепцию Условий. В приведенном ниже коде поместите и возьмите оба ожидания на один и тот же замок. Док говорит это перед вызовом любого условия.await() нам нужно заполучить соответствующий замок (here line 2 : final Lock lock = new ReentrantLock();).

Мой вопрос в том, допустим, буфер заполнен. В этом случае, если мы попытаемся вставить объект, поток будет заблокирован, пока count == items.length , но блокировка здесь все еще остается с потоком, который пытается вставить. Как мы можем вызвать метод take (), чтобы уменьшить количество, так как take() должен получить доступ к той же блокировке. Мне кажется, что это будет тупик, так как take() нельзя вызвать, то же самое, если элементы пусты, мы не сможем вызвать put (), так как теперь блокировка уже с помощью take().

Пожалуйста, помогите мне понять, если я что-то упускаю.Заранее спасибо.

 class BoundedBuffer {
       final Lock lock = new ReentrantLock();
       final Condition notFull  = lock.newCondition(); 
       final Condition notEmpty = lock.newCondition(); 
    
       final Object[] items = new Object[100];
       int putptr, takeptr, count;
    
       public void put(Object x) throws InterruptedException {
         lock.lock();
         try {
           while (count == items.length)
             notFull.await();
           items[putptr] = x;
           if (  putptr == items.length) putptr = 0;
             count;
           notEmpty.signal();
         } finally {
           lock.unlock();
         }
       }
    
       public Object take() throws InterruptedException {
         lock.lock();
         try {
           while (count == 0)
             notEmpty.await();
           Object x = items[takeptr];
           if (  takeptr == items.length) takeptr = 0;
           --count;
           notFull.signal();
           return x;
         } finally {
           lock.unlock();
         }
       }
     }
 

Если вы посмотрите на документ api для условия#ожидание ( https://docs.oracle.com/javase/7/docs/api/java/util/concurrent/locks/Condition.html) там написано:

Блокировка, связанная с этим условием, атомарно освобождается, и текущий поток становится отключенным для целей планирования потоков и бездействует до тех пор, пока не произойдет одно из четырех событий:

Поскольку замок снят, нет никаких проблем с тем, чтобы поставить блокировку.