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

public static interface ForkJoinPool.ManagedBlocker

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

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;
   }
 }