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