compact1, compact2, compact3

java.util.concurrent

Interface ForkJoinPool.ManagedBlocker

Enclosing class:

ForkJoinPool

public static interface ForkJoinPool.ManagedBlocker

扩展管理并行的任务运行在 ForkJoinPools接口。

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

方法摘要

Modifier and Type	Method and Description
boolean	block() 可能阻塞当前线程，例如等待锁或条件。
boolean	isReleasable() 返回 true如果阻塞是不必要的。

方法详细信息

block

boolean block()
       throws InterruptedException

可能阻塞当前线程，例如等待锁或条件。

结果

true如果没有额外的封锁是必要的（即，如果isreleasable将返回true）

异常

InterruptedException如果中断等待（该方法不要求这样做，而是允许）

isReleasable

boolean isReleasable()

返回 true如果阻塞是不必要的。

结果

true如果阻塞是不必要的