java 中Lock的使用
ReentrantLock也可以让代码块原子执行，可是比synchronized更增强大，ReentrantLock具备嗅探锁定、多路分支通知等功能。
嗅探锁定：是指获取锁时若是锁已经被其余线程获取到ReentrantLock能够进行指定等待时间获取锁或者
多路分支通知：是指线程发生await时，线程能够选择注册在不一样的监视器Condition对象上，在适当的时候能够选择指定的监视器Condition对象上的线程进行signal通知、执行java
一、多线程执行同一代码块互斥
import java.util.concurrent.locks.ReentrantLock;
class MyService {
private ReentrantLock lock = new ReentrantLock();
public void method() {
try {
lock.lock();
for (int i = 1; i <= 3; i++) {
Thread.sleep(1000);
System.out.println("ThreadName=" + Thread.currentThread().getName() + " " + i);
}
} catch (InterruptedException e) {
e.printStackTrace();
}finally {
lock.unlock();
}
}
}
class MyThread extends Thread {
private MyService service;
MyThread(MyService service) {
this.service = service;
}
@Override
public void run() {
service.method();
}
}
public class Test {
public static void main(String[] args) {
MyService service = new MyService();
MyThread myThread1 = new MyThread(service);
MyThread myThread2 = new MyThread(service);
myThread1.start();
myThread2.start();
}
}
- 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
结果
ThreadName=Thread-0 1
ThreadName=Thread-0 2
ThreadName=Thread-0 3
ThreadName=Thread-1 1
ThreadName=Thread-1 2
ThreadName=Thread-1 3多线程
二、多线程执行不一样代码块互斥
import java.util.concurrent.locks.ReentrantLock;
class MyService {
private ReentrantLock lock = new ReentrantLock();
public void methodA() {
lock.lock();
try {
System.out.println("MethodA begin ThreadName=" + Thread.currentThread().getName());
for (int i = 1; i <= 3; i++) {
System.out.println("ThreadName=" + Thread.currentThread().getName() + " " + i);
Thread.sleep(1000);
}
System.out.println("MethodA end ThreadName=" + Thread.currentThread().getName());
} catch (InterruptedException e) {
e.printStackTrace();
} finally {
lock.unlock();
}
}
public void methodB() {
lock.lock();
try {
System.out.println("MethodB begin ThreadName=" + Thread.currentThread().getName());
for (int i = 1; i <= 3; i++) {
System.out.println("ThreadName=" + Thread.currentThread().getName() + " " + i);
Thread.sleep(1000);
}
System.out.println("MethodB end ThreadName=" + Thread.currentThread().getName());
} catch (InterruptedException e) {
e.printStackTrace();
} finally {
lock.unlock();
}
}
}
class ThreadA extends Thread {
private MyService service;
ThreadA(MyService service) {
this.service = service;
}
@Override
public void run() {
service.methodA();
}
}
class ThreadB extends Thread {
private MyService service;
ThreadB(MyService service) {
this.service = service;
}
@Override
public void run() {
service.methodB();
}
}
public class Test {
public static void main(String[] args) {
MyService service = new MyService();
ThreadA threadA = new ThreadA(service);
threadA.setName("A");
ThreadB threadB = new ThreadB(service);
threadB.setName("B");
threadA.start();
threadB.start();
}
}
- 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
结果：
MethodA begin ThreadName=A
ThreadName=A 1
ThreadName=A 2
ThreadName=A 3
MethodA end ThreadName=A
MethodB begin ThreadName=B
ThreadName=B 1
ThreadName=B 2
ThreadName=B 3
MethodB end ThreadName=Bide
三、多路通知
当多线程进入await状态时，利用Condition监视器对不一样类型线程通知测试
import java.util.concurrent.locks.Condition;
import java.util.concurrent.locks.ReentrantLock;
class MyService {
private ReentrantLock lock = new ReentrantLock();
private Condition conditionA = lock.newCondition();
private Condition conditionB = lock.newCondition();
public void methodA() {
lock.lock();
try {
System.out.println("MethodA begin ThreadName=" + Thread.currentThread().getName() + " " + System.currentTimeMillis());
conditionA.await();
System.out.println("MethodA end ThreadName=" + Thread.currentThread().getName() + " " + System.currentTimeMillis());
} catch (InterruptedException e) {
e.printStackTrace();
} finally {
lock.unlock();
}
}
public void methodB() {
lock.lock();
try {
System.out.println("MethodB begin ThreadName=" + Thread.currentThread().getName() + " " + System.currentTimeMillis());
conditionB.await();
System.out.println("MethodB end ThreadName=" + Thread.currentThread().getName() + " " + System.currentTimeMillis());
} catch (InterruptedException e) {
e.printStackTrace();
} finally {
lock.unlock();
}
}
public void signalA() {
lock.lock();
conditionA.signal();
lock.unlock();
}
public void signalA_All() {
lock.lock();
conditionA.signalAll();
lock.unlock();
}
public void signalB() {
lock.lock();
conditionB.signal();
lock.unlock();
}
public void signalB_All() {
lock.lock();
conditionB.signalAll();
lock.unlock();
}
}
class ThreadA extends Thread {
private MyService service;
ThreadA(MyService service) {
this.service = service;
}
@Override
public void run() {
service.methodA();
}
}
class ThreadB extends Thread {
private MyService service;
ThreadB(MyService service) {
this.service = service;
}
@Override
public void run() {
service.methodB();
}
}
public class Test {
public static void main(String[] args) throws InterruptedException {
MyService service = new MyService();
ThreadA threadA = new ThreadA(service);
threadA.setName("A");
ThreadB threadB = new ThreadB(service);
threadB.setName("B");
threadA.start();
threadB.start();
Thread.sleep(1000);
service.signalA();
Thread.sleep(1000);
service.signalB();
// ThreadA[] threadAs = new ThreadA[10];
// for (int i=0;i<5;i++){
// threadAs[i] = new ThreadA(service);
// }
// ThreadB[] threadBs = new ThreadB[10];
// for (int i=0;i<5;i++){
// threadBs[i] = new ThreadB(service);
// }
//
// for (int i=0;i<5;i++){
// threadAs[i].start();
// threadBs[i].start();
// }
//
// Thread.sleep(1000);
// service.signalA_All();
// Thread.sleep(1000);
// service.signalB_All();
}
}
- 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
- 96
- 97
- 98
- 99
- 100
- 101
- 102
- 103
- 104
- 105
- 106
- 107
- 108
- 109
- 110
- 111
- 112
- 113
- 114
- 115
- 116
- 117
- 118
- 119
- 120
- 121
- 122
- 123
测试结果1：
MethodA begin ThreadName=A 1476800025028
MethodB begin ThreadName=B 1476800025029
MethodA end ThreadName=A 1476800026028
MethodB end ThreadName=B 1476800027028this
修改代码为：spa
public static void main(String[] args) throws InterruptedException {
MyService service = new MyService();
// ThreadA threadA = new ThreadA(service);
// threadA.setName("A");
//
// ThreadB threadB = new ThreadB(service);
// threadB.setName("B");
// threadA.start();
// threadB.start();
//
// Thread.sleep(1000);
// service.signalA();
// Thread.sleep(1000);
// service.signalB();
ThreadA[] threadAs = new ThreadA[10];
for (int i=0;i<5;i++){
threadAs[i] = new ThreadA(service);
}
ThreadB[] threadBs = new ThreadB[10];
for (int i=0;i<5;i++){
threadBs[i] = new ThreadB(service);
}
for (int i=0;i<5;i++){
threadAs[i].start();
threadBs[i].start();
}
Thread.sleep(1000);
service.signalA_All();
Thread.sleep(1000);
service.signalB_All();
}
- 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
结果为：
MethodA begin ThreadName=Thread-0 1476800227416
MethodB begin ThreadName=Thread-7 1476800227417
MethodB begin ThreadName=Thread-5 1476800227417
MethodA begin ThreadName=Thread-3 1476800227418
MethodA begin ThreadName=Thread-1 1476800227418
MethodA begin ThreadName=Thread-4 1476800227418
MethodB begin ThreadName=Thread-6 1476800227418
MethodA begin ThreadName=Thread-2 1476800227418
MethodB begin ThreadName=Thread-8 1476800227418
MethodB begin ThreadName=Thread-9 1476800227418
MethodA end ThreadName=Thread-0 1476800228419
MethodA end ThreadName=Thread-3 1476800228419
MethodA end ThreadName=Thread-1 1476800228419
MethodA end ThreadName=Thread-4 1476800228420
MethodA end ThreadName=Thread-2 1476800228420
MethodB end ThreadName=Thread-7 1476800229419
MethodB end ThreadName=Thread-5 1476800229419
MethodB end ThreadName=Thread-6 1476800229419
MethodB end ThreadName=Thread-8 1476800229419
MethodB end ThreadName=Thread-9 1476800229419.net
四、公平所与非公平锁
公平锁是指线程获（getting）取锁的顺序和线程锁定（got）的顺序相同，线程
Lock的一些方法说明
A） getHoldCount()
获取当前锁定（got）的个数
B）getQueueLength()
获取当前正在等待获取（getting）锁的线程数（Threads）
C）getWaitQueueLength(Condition)
返回等待（await）与此锁定（got）的Condition相关的个数code
版权声明：本文为博主原创文章，未经博主容许不得转载。 http://blog.csdn.net/jihaitaowangyi/article/details/52852693对象
- 1. java中Lock类的使用
- 2. Java Lock的使用
- 3. Lock的使用
- 4. java 中的lock锁
- 5. Java同步Lock,Condition使用
- 6. Lock锁的使用
- 7. Java多线程之Lock的使用（一）
- 8. Java中的Lock与synchronized
- 9. Java中的锁 Lock和synchronized
- 10. Java中的锁——Lock和synchronized
- 更多相关文章...
- • 在Java程序中使用Redis - Redis教程
- • Redis在Java Web中的应用 - Redis教程
- • C# 中 foreach 遍历的用法
- • Java Agent入门实战（一）-Instrumentation介绍与使用
-
每一个你不满意的现在，都有一个你没有努力的曾经。
- 1. No provider available from registry 127.0.0.1:2181 for service com.ddbuy.ser 解决方法
- 2. Qt5.7以上调用虚拟键盘(支持中文)，以及源码修改(可拖动，水平缩放)
- 3. 软件测试面试- 购物车功能测试用例设计
- 4. ElasticSearch（概念篇）：你知道的, 为了搜索…
- 5. redux理解
- 6. gitee创建第一个项目
- 7. 支持向量机之硬间隔（一步步推导，通俗易懂）
- 8. Mysql 异步复制延迟的原因及解决方案
- 9. 如何在运行SEPM配置向导时将不可认的复杂数据库密码改为简单密码
- 10. windows系统下tftp服务器使用