目录
一、乐观锁和悲观锁
悲观锁(Pessimistic Locking)具有强烈的独占和排他特性。它指的是对数据被外界修改持保守态度。因此,在整个执行过程中,将处于锁定状态。所以,悲观锁是一种悲观思想,它总认为最坏的情况可能会出现,它认为数据很可能会被其他人所修改,所以悲观锁在持有数据的时候总会把资源 或者 数据 锁住,这样其他线程想要请求这个资源的时候就会阻塞,直到等到悲观锁把资源释放为止。Java中的Synchronized 和 ReentrantLock 是一种悲观锁思想的实现,因为Synchronzied 和ReetrantLock 不管是否持有资源,它都会尝试去加锁。
乐观锁(Optimistic Locking ) 相对悲观锁而言,乐观锁机制采取了更加宽松的加锁机制。乐观锁的思想与悲观锁的思想相反,它总认为资源和数据不会被别人所修改,所以读取不会上锁,但是乐观锁在进行写入操作的时候会判断当前数据是否被修改过。Java中的StampedLock和 AtomicInteger 是一种乐观锁思想的实现。
二、ReadWriteLock
- 只允许一个线程写入(其他线程既不能写入也不能读取)
- 没有写入时,多个线程允许同时读(提高性能)
- 用 ReadwriteLock 实现这个功能十分容易。创建一个 ReadwriteLock 实例,然后分别获取读锁和写锁:
// 读写互斥
public class Counter {
private final ReadWriteLock lock = new ReentrantReadWriteLock();
private final Lock readLock = lock.readLock();
private final Lock writeLock = lock.writeLock();
private int[] counts = new int[10];
public void inc(int index){
writeLock.lock();
try{
counts[index]+=1;
}finally{
writeLock.unlock();
}
}
public int[] get(){
readLock.lock();
try {
return Arrays.copyOf(counts,counts.length);
}finally{
readLock.unlock();
}
}
}
把读写操作分别用读锁和写锁来加锁,在读取时,多个线程可以同时获得读锁,这样就大大提高了并发读的执行效率。
如果我们深入分析 ReadwriteLock,会发现它有个潜在的问题:如果有线程正在读,写线程需要等待读线程释放锁后才能获取写锁,即读的过程中不允许写。
三、StampedLock
Java 8进一步提升并发执行效率,引入了新的读写锁:StampedLock。
StampedLock和 ReadwriteLock 相比,改进之处在于:读的过程中也允许获取写锁写入!这样一来,我们读的数据就可能不一致,需要一点额外的代码来判断读的过程中是否有写入。所以,这种读锁是一种乐观锁。
public class Point {
private final StampedLock stampedLock = new StampedLock();
private double x;
private double y;
// 写
public void move(double deltaX, double deltaY) {
long stamp = stampedLock.writeLock(); // 获取写锁
try{
x += deltaX;
y += deltaY;
}finally{
stampedLock.unlockWrite(stamp); // 释放写锁
}
}
// 读
public double distanceFromOrigin() {
// 获取读锁(乐观锁)
long stamp = stampedLock.tryOptimisticRead();
double currentX = x;
double currentY = y;
// 检查乐观锁的版本号(stamp)是否一致
if (!stampedLock.validate(stamp)){
// 获取读锁(悲观锁)
stamp = stampedLock.tryReadLock();
//重新获取
try{
currentX=x;
currentY=y;
}finally{
stampedLock.unlockRead(stamp); // 释放悲观读锁
}
}
return Math.sqrt(currentX * currentX + currentY * currentY);
}
}
和 ReadwriteLock 相比,写入的加锁是完全一样的,不同的是读取。注意到首先我们通过 tryoptimisticRead()获取一个乐观读锁,并返回版本号。接着进行读取,读取完成后,我们通过 validate()去验证版本号,如果在读取过程中没有写入,版本号不变,验证成功,我们就可以放心地继续后续操作。如果在读取过程中有写入,版本号会发生变化,验证将失败。在失败的时候,我们再通过 readLock()获取悲观读锁再次读取。由于写入的概率不高,程序在绝大部分情况下可以通过乐观读锁获取数据,极少数情况下使用悲观读锁获取数据。
所以,StampedLock 把读锁细分为乐观读和悲观读,能进一步提升并发效率。但这也是有代价的:一是代码更加复杂,二是 StampedLock 是不可重入锁,不能在一个线程中反复获取同一个锁。
四、Semaphore
通过各种锁的实现,我们会发现锁的目的是保护一种受限资源,保证同一时刻只有一个线程能访问(ReentrantLock),或者只有一个线程能写入(ReadWriteLock)。
还有一种受限资源,它需要保证同一时刻最多有 N个线程能访问,比如同一时刻最多创
建 100 个数据库连接,最多允许10个用户下载等。
这种限制数量的锁,可以用 Lock 数组来实现,但是非常麻烦。类似需求常见更适合 sema
phore 信号量。 semaphore 本质上就是一个信号计数器,用于限制同一时间的最大访问数量。
例如,最多允许3个线程同时访问:
public class AccessLimitControl {
// 任意时刻只允许最多3个线程获取许可
final Semaphore semaphore = new Semaphore(3);
public void access() throws InterruptedException {
// 超过数量的其他线程等待
semaphore.acquire();
// 2秒内获取许可
if (semaphore.tryAcquire(2, TimeUnit.SECONDS))
try{
System.out.println(UUID.randomUUID().toString());
}finally{
semaphore.release();
}
}
}
使用 semaphore 先调用 acquire()获取,然后通过 try ...finally 保证在 finally中释放。调用acquire()可能会进入等待,直到满足条件为止。也可以使用 tryAcquire()指定等待时间。
五、死锁
多个线程在运行的过程中,都需要获取对方线程所持有的锁(资源),导致处于长期无限等待的状态。
例如:
// 死锁
public class Test {
public static void main(String[] args) {
DeadLock deadLock = new DeadLock();
Thread t1 = new Thread(()->{
try {
deadLock.add();
} catch (InterruptedException e) {
e.printStackTrace();
}
});
Thread t2 = new Thread(()->{
deadLock.dec();
});
t1.start();
t2.start();
}
}
// 死锁现象
class DeadLock{
private static Object lockA = new Object();
private static Object lockB = new Object();
public void add() throws InterruptedException {
synchronized (lockA){ // 获得locakA的锁
Thread.sleep(1000); // 休眠,不释放锁
synchronized(lockB){ // 获得locakB的锁
System.out.println("执行add");
} // 释放locakB的锁
} // 释放locakA的锁
}
public void dec(){
synchronized(lockB){ // 获得locakB的锁
synchronized(lockA){ // 获得locakA的锁
System.out.println("执行dec");
} // 释放locakA的锁
} // 释放locakB的锁
}
}
在获取多个锁的时候,不同线程获取多个不同对象的锁可能导致死锁。对于上述代码,线程1和线程2如果分别执行 add()和 dec()方法时:
线程1:进入 add(),获得 lockA;
线程2:进入 dec(),获得lockB;
随后:
线程1:准备获得 lockB,失败,等待中;
线程2:准备获得 lockA,失败,等待中。
此时,两个线程各自持有不同的锁,然后各自试图获取对方手里的锁,造成了双方无限等
待下去,这就是死锁。
死锁发生后,没有任何机制能解除死锁,只能强制结束VM 进程。
五、死锁的条件
产生死锁有四个必要条件:
1. 资源互斥:对所分配的资源进行排它性控制,锁在同一时刻只能被一个线程使用;
2. 不可剥夺:线程已获得的资源在未使用完之前,不能被剥夺,只能等待占有者自行释放锁;
3. 请求等待:当线程因请求资源而阻塞时,对已获得的资源保持不放;
4. 循环等待:线程之间的相互等待。
六、如何发现死锁
1. 通过 jps 命令,显示本地所有 JVM进程,查找当前 JVM 进程的进程号。
2. 通过 jstack 命令,显示当前 JVM 虚拟机的栈信息,查找产生死锁的线程。
3. 通过jconsole命令,利用终端进入JConsole查看线程活动。
JConsole
是一种 Java
监控和管理控制台工具,可以用于监视 Java
虚拟机(JVM)的性能和资源利用情况。它提供了一种图形化界面,可以实时查看 JVM
的运行状态、内存使用情况、线程活动、垃圾回收等信息,以及执行一些管理操作。
查看死锁:
七、如何避免死锁
1. 每次只占用不超过1个锁。
2. 按照相同的顺序申请锁。
3. 使用信号量。