すべての既知の実装クラス:
AbstractQueuedLongSynchronizer.ConditionObject、AbstractQueuedSynchronizer.ConditionObject
public interface Condition
<br>
条件 は になりますオブジェクト
監視メソッド (wait
、notify
、および notifyAll
) Condition
将 Object
监视器方法(wait
、notify
和 notifyAll
)分解成截然不同的对象,以便通过将这些对象与任意 Lock
实现组合使用,为每个对象提供多个等待 set(wait-set)。其中,Lock
替代了 synchronized
方法和语句的使用,Condition
替代了 Object 监视器方法的使用。
条件(也称为条件队列 或条件变量)为线程提供了一个含义,以便在某个状态条件现在可能为 true 的另一个线程通知它之前,一直挂起该线程(即让其“等待”)。因为访问此共享状态信息发生在不同的线程中,所以它必须受保护,因此要将某种形式的锁与该条件相关联。等待提供一个条件的主要属性是:以原子方式 释放相关的锁,并挂起当前线程,就像 Object.wait
做的那样。
Condition
实例实质上被绑定到一个锁上。要为特定 Lock
实例获得 Condition
实例,请使用其 newCondition()
方法。
作为一个示例,假定有一个绑定的缓冲区,它支持 put
和 take
方法。如果试图在空的缓冲区上执行 take
操作,则在某一个项变得可用之前,线程将一直阻塞;如果试图在满的缓冲区上执行 put
操作,则在有空间变得可用之前,线程将一直阻塞。我们喜欢在单独的等待 set 中保存 put
线程和 take
线程,这样就可以在缓冲区中的项或空间变得可用时利用最佳规划,一次只通知一个线程。可以使用两个 Condition
实例来做到这一点。
class BoundedBuffer { final Lock lock = new ReentrantLock(); final Condition notFull = lock.newCondition(); final Condition notEmpty = lock.newCondition(); final Object[] items = new Object[100]; int putptr, takeptr, count; public void put(Object x) throws InterruptedException { lock.lock(); try { while (count == items.length) notFull.await(); items[putptr] = x; if (++putptr == items.length) putptr = 0; ++count; notEmpty.signal(); } finally { lock.unlock(); } } public Object take() throws InterruptedException { lock.lock(); try { while (count == 0) notEmpty.await(); Object x = items[takeptr]; if (++takeptr == items.length) takeptr = 0; --count; notFull.signal(); return x; } finally { lock.unlock(); } } }
(ArrayBlockingQueue
类提供了这项功能,因此没有理由去实现这个示例类。)
Condition
实现可以提供不同于 Object
监视器方法的行为和语义,比如受保证的通知排序,或者在执行通知时不需要保持一个锁。如果某个实现提供了这样特殊的语义,则该实现必须记录这些语义。
注意,Condition
实例只是一些普通的对象,它们自身可以用作 synchronized
语句中的目标,并且可以调用自己的 wait
和 notification
监视器方法。获取 Condition
实例的监视器锁或者使用其监视器方法,与获取和该 Condition
相关的 Lock
或使用其 waiting
和 signalling
方法没有什么特定的关系。为了避免混淆,建议除了在其自身的实现中之外,切勿以这种方式使用 Condition
实例。
除非另行说明,否则为任何参数传递 null
值将导致抛出 NullPointerException
。
在等待 Condition
时,允许发生“虚假唤醒”,这通常作为对基础平台语义的让步。对于大多数应用程序,这带来的实际影响很小,因为 Condition
個別のオブジェクトに分解します。
Lock
実装
Lock
は synchronized
メソッドとステートメントの使用を置き換え、Condition
はオブジェクト モニター メソッドの使用を置き換えます
Object.wait
と同様に、 関連するロックをアトミックに解放し、現在のスレッドを一時停止することです。 🎜🎜🎜Condition
インスタンスは基本的にロックにバインドされています。特定の 🎜Lock
🎜 インスタンスの Condition
インスタンスを取得するには、その 🎜newCondition()
🎜 メソッドを使用します。 🎜🎜🎜例として、put
メソッドと take
メソッドをサポートするバインド バッファがあると仮定します。空のバッファーで take
操作を実行しようとすると、項目が使用可能になるまでスレッドはブロックされます。また、満杯のバッファーで put
操作を実行しようとすると、スレッドはブロックされます。スレッドはアイテムが使用可能になるまでブロックされます。> 操作の場合、スレッドはスペースが使用可能になるまでブロックされます。私たちは put
スレッドと take
スレッドを別々の待機セットに保持して、バッファー内の項目またはスペースが使用可能になったときに最適なプランを活用できるようにすることを好みます。一度に 1 つのスレッドのみを通知します。これは、2 つの Condition
インスタンスを使用して実行できます。 🎜void await() throws InterruptedException
ArrayBlockingQueue
クラスはこの機能を提供するため、このサンプル クラスを実装する理由はありません。) 🎜🎜Condition
実装は、Object とは異なる機能を提供できます。
code> 通知の順序の保証や、通知の実行中にロックを保持する必要性など、モニター メソッドの動作とセマンティクス。実装がそのような特別なセマンティクスを提供する場合、実装はこれらのセマンティクスを文書化しなければなりません (MUST)。 🎜🎜 Condition
インスタンスは、それ自体が synchronized
ステートメントのターゲットとして使用でき、独自の wait
および を呼び出すことができる単なる通常のオブジェクトであることに注意してください。 >notification
監視メソッド。 Condition
インスタンスのモニター ロックを取得するか、そのモニター メソッドを使用し、Condition
に関連付けられた Lock
を取得するか、その waiting を使用します。
は、signalling
メソッドと特別な関係はありません。混乱を避けるため、 Condition
インスタンスは、独自の実装内以外では決してこの方法で使用しないことをお勧めします。 🎜🎜特に明記されていない限り、パラメータに null
値を渡すと、NullPointerException
がスローされます。 🎜Condition
の待機中に「偽ウェイク」が発生することを許可します。 Condition
は常にループ内で待機し、待機中の状態ステートメントをテストする必要があるため、ほとんどのアプリケーションでは、これは実際的な影響はほとんどありません。実装では、発生する可能性のある偽のウェイクアップを自由に削除できますが、アプリケーション プログラマは、これらの偽のウェイクアップが発生する可能性があることを常に想定し、常にループ内で待機することをお勧めします。 🎜🎜一部のプラットフォームでの 3 つの形式の条件付き待機 (中断可能、中断不可能、タイムアウト) の実装とそのパフォーマンス特性は異なる場合があります。特に、これらの機能を提供し、順序保証などの特定のセマンティクスを維持することは困難な場合があります。さらに、🎜、スレッドの実際の一時停止を中断する機能は、すべてのプラットフォームで常に可能であるとは限りません。 🎜🎜🎜 したがって、実装では、3 つの待機形式すべてに対してまったく同じ保証やセマンティクスを定義する必要はなく、また、割り込みスレッドの実際の一時停止をサポートする必要もありません。 🎜🎜 実装では、各待機メソッドによって提供されるセマンティクスと保証を明確に文書化する必要があります。実装が割り込みスレッドの一時停止をサポートしていない場合は、このインターフェイスで定義された割り込みセマンティクスに準拠する必要があります。 🎜通常、割り込みはキャンセルを意味し、割り込みチェックは通常ほとんど実行されないため、実装は通常のメソッドが戻る前に割り込みに応答できます。これは、別の操作の後に発生する割り込みによってスレッド ロックが解放される場合にも当てはまります。実装ではこの動作を文書化する必要があります。
開始元:
1.5
<br>
メソッドの概要 | ||
---|---|---|
void void
|
<strong>await</strong>() <br> 造成当前线程在接到信号或被中断之前一直处于等待状态。
|
|
boolean |
<strong>await</strong>(long time, TimeUnit unit) <br> 造成当前线程在接到信号、被中断或到达指定等待时间之前一直处于等待状态。
|
|
long |
<strong>awaitNanos</strong>(long nanosTimeout) <br> 造成当前线程在接到信号、被中断或到达指定等待时间之前一直处于等待状态。
|
|
void |
<strong>awaitUninterruptibly</strong>() <br> 造成当前线程在接到信号之前一直处于等待状态。
|
|
boolean |
<strong>awaitUntil</strong>(Date deadline) <br> 造成当前线程在接到信号、被中断或到达指定最后期限之前一直处于等待状态。
|
|
void |
<strong>signal</strong>() <br> 唤醒一个等待线程。
|
|
void |
<strong>signalAll</strong>() |
<br>await<span style="font-size: 14px">()</span> |
<br>boolean
long
🎜🎜🎜awaitNanos🎜(long nanosTimeout)
🎜🎜🎜 現在のスレッドがシグナルを受信する、中断される、または到達するようにします。指定した時間 待ち時間まで待っています。 🎜🎜🎜🎜🎜🎜 void
🎜🎜🎜awaitUninterruptibly🎜()
🎜🎜🎜 現在のスレッドがシグナルを受信するまで待機します。 🎜🎜🎜🎜🎜🎜boolean
🎜🎜🎜awaitUntil🎜(日付期限)
🎜🎜🎜 現在のスレッドがシグナルを受信する、中断される、または到達するようにします。指定された時刻 期限が保留中です。 🎜🎜🎜🎜🎜🎜 void
🎜🎜🎜signal🎜()
🎜🎜🎜 待機中のスレッドを起動します。 🎜🎜🎜🎜🎜🎜 void
🎜🎜🎜signalAll🎜()
🎜🎜🎜 待機中のすべてのスレッドを起動します。 🎜🎜🎜🎜🎜🎜🎜🎜🎜🎜🎜🎜🎜🎜🎜🎜方法の詳細🎜🎜🎜🎜🎜🎜<br>
void await() throws InterruptedException
造成当前线程在接到信号或被中断之前一直处于等待状态。
与此 Condition
相关的锁以原子方式释放,并且出于线程调度的目的,将禁用当前线程,且在发生以下四种情况之一 以前,当前线程将一直处于休眠状态:
其他某个线程调用此 Condition
的 signal()
方法,并且碰巧将当前线程选为被唤醒的线程;或者
其他某个线程调用此 Condition
的 signalAll()
方法;或者
其他某个线程中断当前线程,且支持中断线程的挂起;或者
发生“虚假唤醒”
在所有情况下,在此方法可以返回当前线程之前,都必须重新获取与此条件有关的锁。在线程返回时,可以保证 它保持此锁。
如果当前线程:
在进入此方法时已经设置了该线程的中断状态;或者
在支持等待和中断线程挂起时,线程被中断,
则抛出 InterruptedException
,并清除当前线程的中断状态。在第一种情况下,没有指定是否在释放锁之前发生中断测试。
实现注意事项
假定调用此方法时,当前线程保持了与此 Condition
有关联的锁。这取决于确定是否为这种情况以及不是时,如何对此作出响应的实现。通常,将抛出一个异常(比如 IllegalMonitorStateException
)并且该实现必须对此进行记录。
与响应某个信号而返回的普通方法相比,实现可能更喜欢响应某个中断。在这种情况下,实现必须确保信号被重定向到另一个等待线程(如果有的话)。
抛出:
InterruptedException
- 如果当前线程被中断(并且支持中断线程挂起)
<br>
void awaitUninterruptibly()
造成当前线程在接到信号之前一直处于等待状态。
与此条件相关的锁以原子方式释放,并且出于线程调度的目的,将禁用当前线程,且在发生以下三种情况之一 以前,当前线程将一直处于休眠状态:
其他某个线程调用此 Condition
的 signal()
方法,并且碰巧将当前线程选为被唤醒的线程;或者
其他某个线程调用此 Condition
的 signalAll()
方法;或者
发生“虚假唤醒”
在所有情况下,在此方法可以返回当前线程之前,都必须重新获取与此条件有关的锁。在线程返回时,可以保证 它保持此锁。
如果在进入此方法时设置了当前线程的中断状态,或者在等待时,线程被中断,那么在接到信号之前,它将继续等待。当最终从此方法返回时,仍然将设置其中断状态。
实现注意事项
假定调用此方法时,当前线程保持了与此 Condition
有关联的锁。这取决于确定是否为这种情况以及不是时,如何对此作出响应的实现。通常,将抛出一个异常(比如 IllegalMonitorStateException
)并且该实现必须对此进行记录。
<br>
long awaitNanos(long nanosTimeout) throws InterruptedException
造成当前线程在接到信号、被中断或到达指定等待时间之前一直处于等待状态。
与此条件相关的锁以原子方式释放,并且出于线程调度的目的,将禁用当前线程,且在发生以下五种情况之一 以前,当前线程将一直处于休眠状态:
其他某个线程调用此 Condition
的 signal()
方法,并且碰巧将当前线程选为被唤醒的线程;或者
其他某个线程调用此 Condition
的 signalAll()
方法;或者
其他某个线程中断当前线程,且支持中断线程的挂起;或者
已超过指定的等待时间;或者
发生“虚假唤醒”。
在所有情况下,在此方法可以返回当前线程之前,都必须重新获取与此条件有关的锁。在线程返回时,可以保证 它保持此锁。
如果当前线程:
在进入此方法时已经设置了该线程的中断状态;或者
在支持等待和中断线程挂起时,线程被中断,
则抛出 InterruptedException
,并且清除当前线程的已中断状态。在第一种情况下,没有指定是否在释放锁之前发生中断测试。
在返回时,该方法返回了所剩毫微秒数的一个估计值,以等待所提供的 nanosTimeout
值的时间,如果超时,则返回一个小于等于 0 的值。可以用此值来确定在等待返回但某一等待条件仍不具备的情况下,是否要再次等待,以及再次等待的时间。此方法的典型用法采用以下形式:
synchronized boolean aMethod(long timeout, TimeUnit unit) { long nanosTimeout = unit.toNanos(timeout); while (!conditionBeingWaitedFor) { if (nanosTimeout > 0) nanosTimeout = theCondition.awaitNanos(nanosTimeout); else return false; } // ... }
设计注意事项:此方法需要一个 nanosecond 参数,以避免在报告剩余时间时出现截断错误。在发生重新等待时,这种精度损失使得程序员难以确保总的等待时间不少于指定等待时间。
实现注意事项
假定调用此方法时,当前线程保持了与此 Condition
有关联的锁。这取决于确定是否为这种情况以及不是时,如何对此作出响应的实现。通常会抛出一个异常(比如 IllegalMonitorStateException
)并且该实现必须对此进行记录。
与响应某个信号而返回的普通方法相比,或者与指示所使用的指定等待时间相比,实现可能更喜欢响应某个中断。在任意一种情况下,实现必须确保信号被重定向到另一个等待线程(如果有的话)。
参数:
nanosTimeout
- 等待的最长时间,以毫微秒为单位
返回:
nanosTimeout
值减去花费在等待此方法的返回结果的时间的估算。正值可以用作对此方法进行后续调用的参数,来完成等待所需时间结束。小于等于零的值表示没有剩余时间。
抛出:
InterruptedException
- 如果当前线程被中断(并且支持中断线程挂起)
<br>
boolean await(long time, TimeUnit unit) throws InterruptedException
造成当前线程在接到信号、被中断或到达指定等待时间之前一直处于等待状态。此方法在行为上等效于:
awaitNanos(unit.toNanos(time)) > 0
参数:
time
- 最长等待时间
unit
- time
参数的时间单位
返回:
如果在从此方法返回前检测到等待时间超时,则返回 false
,否则返回 true
抛出:
InterruptedException
- 如果当前线程被中断(并且支持中断线程挂起)
<br>
boolean awaitUntil(Date deadline) throws InterruptedException
造成当前线程在接到信号、被中断或到达指定最后期限之前一直处于等待状态。
与此条件相关的锁以原子方式释放,并且出于线程调度的目的,将禁用当前线程,且在发生以下五种情况之一 以前,当前线程将一直处于休眠状态:
其他某个线程调用此 Condition
的 signal()
方法,并且碰巧将当前线程选为被唤醒的线程;或者
其他某个线程调用此 Condition
的 signalAll()
方法;或者
其他某个线程中断当前线程,且支持中断线程的挂起;或者
指定的最后期限到了;或者
发生“虚假唤醒”。
在所有情况下,在此方法可以返回当前线程之前,都必须重新获取与此条件有关的锁。在线程返回时,可以保证 它保持此锁。
如果当前线程:
在进入此方法时已经设置了该线程的中断状态;或者
在支持等待和中断线程挂起时,线程被中断,
则抛出 InterruptedException
,并且清除当前线程的已中断状态。在第一种情况下,没有指定是否在释放锁之前发生中断测试。
返回值指示是否到达最后期限,使用方式如下:
synchronized boolean aMethod(Date deadline) { boolean stillWaiting = true; while (!conditionBeingWaitedFor) { if (stillWaiting) stillWaiting = theCondition.awaitUntil(deadline); else return false; } // ... }
实现注意事项
假定调用此方法时,当前线程保持了与此 Condition
有关联的锁。这取决于确定是否为这种情况以及不是时,如何对此作出响应的实现。通常,将抛出一个异常(比如 IllegalMonitorStateException
)并且该实现必须对此进行记录。
与响应某个信号而返回的普通方法相比,或者与指示是否到达指定最终期限相比,实现可能更喜欢响应某个中断。在任意一种情况下,实现必须确保信号被重定向到另一个等待线程(如果有的话)。
参数:
deadline
- 一直处于等待状态的绝对时间
返回:
如果在返回时已经到达最后期限,则返回 false
,否则返回 true
抛出:
InterruptedException
- 如果当前线程被中断(并且支持中断线程挂起)
<br>
void signal()
唤醒一个等待线程。
如果所有的线程都在等待此条件,则选择其中的一个唤醒。在从 await
返回之前,该线程必须重新获取锁。
<br>
void signalAll()
唤醒所有等待线程。
如果所有的线程都在等待此条件,则唤醒所有线程。在从 await
返回之前,每个线程都必须重新获取锁。
以上がインターフェースの状態の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。