Интерфейс 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 если блокировка не нужна