Интерфейс 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;
   }
 }