三、Lock锁 (重点)
传统 Synchronized 相当于排队,队列
耦合性: 判断代码模块构成质量的属性,不影响已有功能,但影响未来拓展
耦合性越强,模块之间的联系越紧密,但独立性越差
Java编程追求的一条原则:高内聚 低耦合!
Lock 接口
实现类:
- ReentrantLock 可重入锁 常用
- ReentranReadWritetLock.ReadLock 读锁
- ReentranReadWritetLock.WriteLock 写锁
公平锁 vs 非公平锁
公平锁: 绝对公平 可以先来后到
非公平锁:不公平 ,可以插队(默认非公平锁)CPU调度 耗时少的线程优先
Lock 三部曲:
-
- Lock lock = new ReentrantLock();
-
- lock.lock();
-
- finally => lock.unlock();
package com.liu.demo01;
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;
public class SafeTicketDemo02 {
public static void main(String[] args) {
// 并发: 多线程操作同一个资源 把资源类丢入线程
Ticket02 ticket = new Ticket02();
// 函数式接口 FunctionalInterface jdk1.8 lambda表达式
// (参数) -> {代码逻辑}
new Thread(() -> {
for (int i = 0; i < 40; i++) ticket.sale();
}, "A").start();
new Thread(() -> {
for (int i = 0; i < 40; i++) ticket.sale();
}, "B").start();
new Thread(() -> {
for (int i = 0; i < 40; i++) ticket.sale();
}, "C").start();
}
}
//资源类 OOP 避免和线程耦合 降低耦合性 耦合性
class Ticket02 {
// 属性 、方法
private int nums = 50;
// lock
Lock lock = new ReentrantLock();
// 卖票方式
public void sale() {
lock.lock(); // 加锁
try {
//核心业务逻辑代码
if (nums > 0) {
System.out.println(Thread.currentThread().getName() + "卖出了第" + nums-- + "张票!" + ",剩余" + nums + "张票");
}
} finally {
lock.unlock(); // 解锁
}
}
}