Lock()、UnLock()、ReentrantLock()、TryLock()とは何ですか?Javaの同期ブロックとの違いは何ですか?]
公開: 2020-07-05
このチュートリアルでは、Lock()、UnLock()、ReentrantLock()、TryLock()、およびJavaの同期ブロックとの違いについて説明します。
以下の質問もある場合は、適切な場所にいます。
- Javaでのロック
- Javaロックの例と同時実行ロックと同期
- Java同時実行チュートリアル–リエントラントロック
- 同期–Javaの適切なロック/ロック解除の使用法
- java –同期とロック
- Javaロックロック解除の例
- Javaのロックメカニズム
- Javaロックは別のスレッドのロックを解除します
始めましょう。 まず、これらの各用語を理解してから、実際の例を見ていきましょう。
ロック():
java.util.concurrent.locks
。 ロックは同期ブロックのようなスレッド同期メカニズムですが、ロックはJavaの同期ブロックよりも高度な場合があります。 これは、組み込みの同期およびモニターとは異なる条件をロックおよび待機するためのフレームワークを提供するインターフェースおよびクラスです。
UnLock():
UnLock()は、オブジェクトのロックを解除します。
ReentrantLock():
ReentrantLock
は、最後に正常にロックされたスレッドによって所有されていますが、まだロック解除されていません。 ロックが別のスレッドによって所有されていない場合、ロックを呼び出すスレッドは戻り、 lock
を正常に取得します。 現在のスレッドがすでにロックを所有している場合、メソッドはすぐに戻ります。
TryLock():
TryLock()は、呼び出し時にロックが解放されている場合にのみロックを取得します。
ヒント-1
単にオブジェクトをロックしている場合は、 synchronized.
1 2 3 |
Lock . lock ( ) ; youMethod ( ) ; // Throws a NullPointerException! Lock . unlock ( ) ; // Here you never release the lock! |
同期されている場合、間違いを犯すことは非常に明確で不可能です。
1 2 3 |
synchronized ( myObject ) { doSomethingNifty ( ) ; } |
例の詳細:
- クラスを作成します:CrunchifyLockTutorial.java
- 内部クラスを作成する:CompanyとCrunchifyLoop
- Mainから、Companyクラスの2つのオブジェクトを作成します
- それらのオブジェクトで10のスレッドループを開始します
- Company1がCompany2と通信している間、オブジェクトをロックします。 同時に、
Company2
がCompany1
と通信したい場合は、「競合」と表示されます。ロックはすでに存在します。 (両社はすでに話し合っています)。
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 |
package crunchify . com . tutorial ; import java . util . Random ; import java . util . concurrent . locks . Lock ; import java . util . concurrent . locks . ReentrantLock ; /** * @author Crunchify.com * */ public class CrunchifyLockTutorial { public static void main ( String [ ] args ) { final Company crunchify = new Company ( "Crunchify" ) ; final Company google = new Company ( "Google" ) ; new Thread ( new CrunchifyLoop ( crunchify , google ) ) . start ( ) ; new Thread ( new CrunchifyLoop ( google , crunchify ) ) . start ( ) ; } // Class CrunchifyLoop static class CrunchifyLoop implements Runnable { private Company companyName1 ; private Company companyName2 ; public CrunchifyLoop ( Company companyName1 , Company companyName2 ) { this . companyName1 = companyName1 ; this . companyName2 = companyName2 ; } public void run ( ) { Random random = new Random ( ) ; // Loop 10 for ( int counter = 0 ; counter < = 10 ; counter ++ ) { try { Thread . sleep ( random . nextInt ( 5 ) ) ; } catch ( InterruptedException e ) { } companyName2 . crunchifyTalking ( companyName1 ) ; } } } // Class Company static class Company { private final String companyName ; // ReentrantLock: Creates an instance of ReentrantLock. This is equivalent to using ReentrantLock(false) private final Lock lock = new ReentrantLock ( ) ; // Constructor public Company ( String name ) { this . companyName = name ; } public String getName ( ) { return this . companyName ; } public boolean isTalking ( Company companyName ) { Boolean crunchifyLock = false ; Boolean googleLock = false ; try { // tryLock: Acquires the lock only if it is free at the time of invocation. crunchifyLock = lock . tryLock ( ) ; googleLock = companyName . lock . tryLock ( ) ; } finally { if ( ! ( crunchifyLock && googleLock)) { if (crunchifyLock) { // unlock: Releases the lock. lock.unlock(); } if ( googleLock ) { companyName . lock . unlock ( ) ; } } } return crunchifyLock && googleLock; } public void crunchifyTalking ( Company companyName ) { // Check if Lock is already exist? if ( isTalking ( companyName ) ) { try { System . out . format ( "I'm %s: talking to %s %n" , this . companyName , companyName . getName ( ) ) ; } finally { lock . unlock ( ) ; companyName . lock . unlock ( ) ; } } else { System . out . format ( "\tLock Situation ==> I'm %s: talking to %s, but it seems" + " we are already talking. Conflicting. %n" , this . companyName , companyName . getName ( ) ) ; } } } } |
出力:
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 |
I 'm Crunchify: talking to Google Lock Situation ==> I' m Google : talking to Crunchify , but it seems we are already talking . Conflicting . I 'm Google: talking to Crunchify I' m Google : talking to Crunchify I 'm Crunchify: talking to Google I' m Google : talking to Crunchify I 'm Google: talking to Crunchify I' m Crunchify : talking to Google Lock Situation == > I 'm Google: talking to Crunchify, but it seems we are already talking. Conflicting. Lock Situation ==> I' m Crunchify : talking to Google , but it seems we are already talking . Conflicting . Lock Situation == > I 'm Google: talking to Crunchify, but it seems we are already talking. Conflicting. I' m Crunchify : talking to Google I 'm Google: talking to Crunchify I' m Google : talking to Crunchify I 'm Crunchify: talking to Google I' m Google : talking to Crunchify Lock Situation == > I 'm Google: talking to Crunchify, but it seems we are already talking. Conflicting. Lock Situation ==> I' m Crunchify : talking to Google , but it seems we are already talking . Conflicting . I 'm Crunchify: talking to Google I' m Crunchify : talking to Google I 'm Crunchify: talking to Google I' m Crunchify : talking to Google |
ヒント-2

java.util.concurrent
のユーティリティは、 synchronized
、 volatile
、 wait
などの低レベルのプリミティブを使用してすべてを実行できます。