• 主页
  • 文章
  • 一般的
  • 什么是 Lock()、UnLock()、ReentrantLock()、TryLock() 以及它与 Java 中的同步块有何不同？]

什么是 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 ( ) ;
}

示例详细信息：

  1. 创建类：CrunchifyLockTutorial.java
  2. 创建内部类：Company 和 CrunchifyLoop
  3. 从 Main 创建两个 Company 类的对象
  4. 在这些对象上启动 10 个线程循环
  5. 当 Company1 与 Company2 对话时，它会锁定一个对象。 如果同时——如果Company2想与Company1交谈，那么它会说——冲突——锁已经存在。 （两家公司已经在谈）。
Java
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的实用程序所做的一切。