Многопоточность: организация нескольких wait-set 'ов для объекта

class CVBuffer {
       private final Mutex mutex = new Mutex();
       private final CondVar notFull = new CondVar(mutex);
       private final CondVar notEmpty = new CondVar(mutex);
       private int count = 0;
       private int takePtr = 0;     
       private int putPtr = 0;
       private final Object[] array;
     
       public CVBuffer(int capacity) { 
         array = new Object[capacity];
       }
     
       public void put(Object x) throws InterruptedException {
         mutex.acquire();
         try {
           while (count == array.length) {
             notFull.await();
           }
           array[putPtr] = x;
           putPtr = (putPtr + 1) % array.length;
           ++count;
           notEmpty.signal();
         }
         finally {
           mutex.release();
         }
       }
     
       public Object take() throws InterruptedException {
         Object x = null;
         mutex.acquire();
         try {
           while (count == 0) {
             notEmpty.await();
           }
           x = array[takePtr];
           array[takePtr] = null;
           takePtr = (takePtr + 1) % array.length;
           --count;
           notFull.signal();
         }
         finally {
           mutex.release();
         }
         return x;
     }
}
 
class CondVar { // реализация пропущена
    protected final Sync mutex;
    
    public CondVar(Sync loc) {
        mutex = loc;
    }
    
    public void await() throws InterruptedException; // analog of wait()
    public void timedwait(long ms) throws InterruptedException; // analog of attampt(long ms) 
    public void signal() throws InterruptedException; // analog of notify()
        public void broadcast() thwors InterruptedException; // analog of notifyAll()
}

public void await() throws InterruptedException {
    synchronized (this) {
        try {
            mutex.release();
            wait();
        } finally {
            mutex.acquire();
        }
    }
Ї
 
public void signal throws InterruptedException {
    synchronized (this) {
        mutex.release();
        notify();
    }
}