什麼是 Lock()、UnLock()、ReentrantLock()、TryLock() 以及它與 Java 中的同步塊有何不同?]
已發表: 2020-07-05
在本教程中,我們將討論 Lock()、UnLock()、ReentrantLock()、TryLock() 以及它與 Java 中的同步塊有何不同。
如果您還有以下問題,那麼您來對地方了。
- Java中的鎖
- Java 鎖示例和並發鎖與同步
- Java 並發教程——可重入鎖
- 同步 – Java 的正確鎖定/解鎖用法
- java - 同步與鎖定
- java鎖解鎖示例
- java中的鎖定機制
- java lock 解鎖不同的線程
讓我們開始吧。 首先讓我們理解這些術語中的每一個,然後我們將回顧工作示例。
鎖():
java.util.concurrent.locks
。 鎖是一種線程同步機制,類似於同步塊,除了鎖可以比 Java 的同步塊更複雜。 它是一個接口和類,為鎖定和等待與內置同步和監視器不同的條件提供框架。
開鎖():
UnLock() 釋放對 Object 的鎖定。
重入鎖():
ReentrantLock
由上次成功鎖定但尚未解鎖的線程擁有。 當鎖不被另一個線程擁有時,調用lock
的線程將返回,成功獲取鎖。 如果當前線程已經擁有鎖,該方法將立即返回。
嘗試鎖定():
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 類的對象
- 在這些對像上啟動 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

您可以使用synchronized
、 volatile
或wait
低級原語來實現java.util.concurrent
的實用程序所做的一切。