Интерфейс ForkJoinPool.ManagedBlocker

public static interface ForkJoinPool.ManagedBlocker

Интерфейс для расширения управляемой параллельности для задач, выполняемых в ForkJoinPool.

A ManagedBlocker предоставляет два метода. Метод isReleasable() должен возвращать true если блокировка не требуется. Метод block() блокирует текущую нить, если это необходимо (возможно, внутри вызывая isReleasable перед фактической блокировкой). Эти действия выполняются любой нитью, вызывающей ForkJoinPool.managedBlock(ManagedBlocker). Необычные методы в этом API соответствуют синхронизаторам, которые могут, но обычно не блокируют на длительное время. Аналогично, они позволяют более эффективно обрабатывать внутренние случаи, когда дополнительные рабочие нити могут, но обычно не нужны для обеспечения достаточной параллельности. В этих целях реализации метода isReleasable должны быть совместимы с многократным вызовом. Ни один метод не вызывается после предыдущего вызова isReleasable или block возвращает true.

Например, вот ManagedBlocker, основанный на ReentrantLock:

 
 class ManagedLocker implements ManagedBlocker {
   final ReentrantLock lock;
   boolean hasLock = false;
   ManagedLocker(ReentrantLock lock) { this.lock = lock; }
   public boolean block() {
     if (!hasLock)
       lock.lock();
     return true;
   }
   public boolean isReleasable() {
     return hasLock || (hasLock = lock.tryLock());
   }
 }

Вот класс, который, возможно, блокирует ожидание элемента в заданной очереди:

 
 class QueueTaker<E> implements ManagedBlocker {
   final BlockingQueue<E> queue;
   volatile E item = null;
   QueueTaker(BlockingQueue<E> q) { this.queue = q; }
   public boolean block() throws InterruptedException {
     if (item == null)
       item = queue.take();
     return true;
   }
   public boolean isReleasable() {
     return item != null || (item = queue.poll()) != null;
   }
   public E getItem() { // call after pool.managedBlock completes
     return item;
   }
 }