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

public static interface ForkJoinPool.ManagedBlocker

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

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

Например, вот 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;
   }
 }

Методы

block

boolean block()
       throws InterruptedException

Возможно блокирует текущую нить, например, ожидая блокировки или условия.

Возвращает:

true если дополнительная блокировка не нужна (то есть, если isReleasable вернёт true)

Выбрасывает:

InterruptedException - если прервано во время ожидания (метод не обязан это делать, но может)

isReleasable

boolean isReleasable()

Возвращает true, если блокировка не нужна.

Возвращает:

true если блокировка не нужна