compact1、compact2、compact3

java.util.concurrent

インタフェースForkJoinPool.ManagedBlocker

含まれているクラス:

ForkJoinPool

public static interface ForkJoinPool.ManagedBlocker

ForkJoinPool内で実行中のタスクについての管理対象の並列性を拡張するためのインタフェースです。

ManagedBlockerは、2つのメソッドを提供します。ブロックが必要でない場合、isReleasableメソッドはtrueを返す必要があります。blockメソッドは、必要に応じて(おそらく、実際にブロックする前に内部的にisReleasableを呼び出して)現在のスレッドをブロックします。これらのアクションは、ForkJoinPool.managedBlock(ManagedBlocker)を呼び出す任意のスレッドによって実行されます。このAPI内の例外的なメソッドは、長時間ブロックする可能性のある(ただし、通常はない)シンクロナイザに対応しています。同様に、十分な並列性を確保するために追加のワーカーが必要になる可能性のある(ただし、通常はない)場合のより効率的な内部処理も可能になります。この目的のために、isReleasableメソッドの実装は、繰返しの呼出しに対応している必要があります。

たとえば、ReentrantLockに基づいたManagedBlockerを次に示します。

 
 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を返します。

メソッドの詳細

block

boolean block()
       throws InterruptedException

ロックまたは条件を待機しているスレッドなどの現在のスレッドを、可能な場合にブロックします。

戻り値:

追加のブロックが必要でない場合(つまり、isReleasableがtrueを返す場合)はtrue

例外:

InterruptedException - 待機中に割り込まれた場合(この処理はメソッドに必要ではないが、許可されている)

isReleasable

boolean isReleasable()

ブロックが不要な場合にtrueを返します。

戻り値:

ブロックが不要な場合はtrue