java.util.concurrent

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

Включение класса:

ForkJoinPool

public static interface ForkJoinPool.ManagedBlocker

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

A ManagedBlocker обеспечивает два метода. Метод isReleasable должен возвратиться true если блокирование не необходимо. Метод block блокирует текущий поток в случае необходимости (возможно, внутренне вызов isReleasable перед фактическим блокированием). Эти действия выполняются любым вызовом потока ForkJoinPool.managedBlock(java.util.concurrent.ForkJoinPool.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;
   }
 }

Сводка метода

Методы

Модификатор и Тип	Метод и Описание
boolean	block() Возможно блокирует текущий поток, например ожидающий блокировки или условия.
boolean	isReleasable() Возвраты true если блокирование является ненужным.

Деталь метода

блок

boolean block()
              throws InterruptedException

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

Возвраты:

true если бы никакое дополнительное блокирование не необходимо (то есть, если isReleasable возвратил бы true),

Броски:

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

isReleasable

boolean isReleasable()

Возвраты true если блокирование является ненужным.