LockSupport クラス

定義

[Android.Runtime.Register("java/util/concurrent/locks/LockSupport", DoNotGenerateAcw=true)]
public class LockSupport : Java.Lang.Object

[<Android.Runtime.Register("java/util/concurrent/locks/LockSupport", DoNotGenerateAcw=true)>]
type LockSupport = class
    inherit Object

継承

Object

JavaObject

Object

LockSupport

属性

RegisterAttribute

注釈

ロックやその他の同期クラスを作成するための基本的なスレッド ブロック プリミティブ。

このクラスは、それを使用する各スレッドに許可 ( java.util.concurrent.Semaphore Semaphore クラスの意味で) を関連付けます。 parkの呼び出しは、許可が利用可能な場合は直ちに返され、プロセスで使用されます。それ以外の場合は、ブロック<em>may</em>。 unparkを呼び出すと、許可がまだ利用できない場合に使用できるようになります。 (ただし、セマフォとは異なり、許可は蓄積されません。最大 1 つがあります)。)信頼性の高い使用には、揮発性 (またはアトミック) 変数を使用して、パークまたはパーク解除のタイミングを制御する必要があります。 これらのメソッドの呼び出しの順序は、揮発性変数アクセスに関しては維持されますが、必ずしも不揮発性変数アクセスとは限りません。

メソッド park および unpark では、非推奨のメソッドが Thread.suspend し、そのような目的で使用できない問題が発生しないスレッドをブロック Thread.resume およびブロック解除する効率的な手段が提供されます。許可により、 park を呼び出すスレッドと unpark しようとする別のスレッドの間の競合は、許可のために生き生きと維持されます。 さらに、呼び出し元のスレッドが中断され、タイムアウト バージョンがサポートされている場合は、 park が返されます。 park メソッドは、"理由なし" の他の時点でも返される可能性があるため、一般に、戻り時に条件を再確認するループ内で呼び出す必要があります。 この意味では、 park は、スピンする時間を無駄にしないが、有効にするには unpark と組み合わせなければならない「ビジー待機」の最適化として機能します。

各 park の 3 つの形式では、 blocker オブジェクト パラメーターもサポートされています。 このオブジェクトは、スレッドがブロックされている間に記録され、スレッドがブロックされる理由を識別するための監視および診断ツールが許可されます。 (このようなツールは、メソッド #getBlocker(Thread)を使用してブロックにアクセスする場合があります)。このパラメーターを指定しない元のフォームではなく、これらのフォームを使用することを強くお勧めします。 ロック実装内で blocker として指定する通常の引数は this。

これらのメソッドは、上位レベルの同期ユーティリティを作成するためのツールとして使用するように設計されており、それ自体はほとんどのコンカレンシー制御アプリケーションには役立ちません。 parkメソッドは、フォームの構築でのみ使用するように設計されています。

{@code
            while (!canProceed()) {
              // ensure request to unpark is visible to other threads
              ...
              LockSupport.park(this);
            }}

parkの呼び出しの前に、アンパーク要求を発行するスレッドによるアクションがロックまたはブロックを伴う場合。 各スレッドには許可が 1 つだけ関連付けられているため、クラスの読み込みを介して暗黙的に含めて、 parkを中間的に使用すると、応答しないスレッド ("lost unpark") が発生する可能性があります。

<b>Sample Usage.</b> 先入れ先出しの非再入ロック クラスのスケッチを次に示します。

{@code
            class FIFOMutex {
              private final AtomicBoolean locked = new AtomicBoolean(false);
              private final Queue<Thread> waiters
                = new ConcurrentLinkedQueue<>();

              public void lock() {
                boolean wasInterrupted = false;
                // publish current thread for unparkers
                waiters.add(Thread.currentThread());

                // Block while not first in queue or cannot acquire lock
                while (waiters.peek() != Thread.currentThread() ||
                       !locked.compareAndSet(false, true)) {
                  LockSupport.park(this);
                  // ignore interrupts while waiting
                  if (Thread.interrupted())
                    wasInterrupted = true;
                }

                waiters.remove();
                // ensure correct interrupt status on return
                if (wasInterrupted)
                  Thread.currentThread().interrupt();
              }

              public void unlock() {
                locked.set(false);
                LockSupport.unpark(waiters.peek());
              }

              static {
                // Reduce the risk of "lost unpark" due to classloading
                Class<?> ensureLoaded = LockSupport.class;
              }
            }}

1\.5 で追加されました。

Javaドキュメント。

このページの一部は、によって作成および共有され、に記載されている条件に従って使用される作業に基づく変更です。