ReentrantLock 特点

相对于 synchronized 锁，它具备如下特点：

  • 可中断
  • 可设置超时时间
  • 可设置为公平锁
  • 支持多个条件变量

和 synchronized 一样都支持可重入

可重入锁：可重入就是说某个线程已经获得某个锁，可以再次获取锁而不会出现死锁。
不可重入锁：不可重入就是说某个线程已经获得某个锁，可以再次获取锁而会被自己锁挡住，出现死锁。

基本语法

lock 方法

reentrantLock.lock(); 是不可打断的锁；

  1. package top.simba1949;
  3. import java.util.concurrent.locks.ReentrantLock;
  5. /**
  6.  * @author Anthony
  7.  * @date 2020/10/26 16:48
  8.  */
  9. public class Application {
  10.     ReentrantLock reentrantLock = new ReentrantLock();
  12.     public void lockMethod(){
  13.         // 获取锁
  14.         reentrantLock.lock();
  15.         try{
  16.             // 需要加锁的代码块
  17.         }finally {
  18.             // 释放锁
  19.             reentrantLock.unlock();
  20.         }
  21.     }
  22. }

可打断的锁

  1. package top.simba1949;
  3. import java.util.concurrent.locks.ReentrantLock;
  5. /**
  6.  * @author Anthony
  7.  * @date 2020/10/24 10:01
  8.  */
  9. public class Application {
  11.     static ReentrantLock reentrantLock = new ReentrantLock();
  13.     public static void main(String[] args) throws InterruptedException {
  14.         // 设置可打断的锁
  15.         // 如果没有竞争，此方法会获取 reentrantLock 锁
  16.         // 如果有竞争会进入阻塞队列中，可以被其他线程用 interrupt 方法打断
  17.         reentrantLock.lockInterruptibly();
  18.         try{
  19.             // 需要加锁的代码块
  20.         }finally {
  21.             // 释放锁
  22.             reentrantLock.unlock();
  23.         }
  24.     }
  25. }

防止锁超时

reentrantLock.tryLock() 尝试获取，可以避免死锁；

  1. package top.simba1949;
  3. import java.util.concurrent.locks.ReentrantLock;
  5. /**
  6.  * @author Anthony
  7.  * @date 2020/10/24 10:01
  8.  */
  9. public class Application {
  11.     static ReentrantLock reentrantLock = new ReentrantLock();
  13.     public static void main(String[] args) {
  14.         // 尝试获取锁，true 为获取成功，false 表示获取不到锁
  15.         boolean bl = reentrantLock.tryLock();
  16.         if (!bl){
  17.             // 获取不到锁的处理逻辑
  18.             return;
  19.         }
  21.         try{
  22.             //需要加锁的代码块
  23.         }finally {
  24.             // 释放锁
  25.             reentrantLock.unlock();
  26.         }
  27.     }
  29. }

ReentrantLock公平锁

ReentrantLock 默认是不公平锁
公平锁：按照先入先得
公平锁会降低线程的并发度；

  1. // 构造方法传入 true ，设置为公平锁
  2. ReentrantLock reentrantLock = new ReentrantLock(true);

条件变量

  1. package top.simba1949;
  3. import java.util.concurrent.locks.Condition;
  4. import java.util.concurrent.locks.ReentrantLock;
  6. /**
  7.  * @author Anthony
  8.  * @date 2020/10/24 10:01
  9.  */
  10. public class Application {
  12.     static ReentrantLock reentrantLock = new ReentrantLock(true);
  14.     public static void main(String[] args) throws InterruptedException {
  15.         // 创建一个条件变量（休息室）
  16.         Condition condition = reentrantLock.newCondition();
  17.         reentrantLock.lock();
  19.         try{
  21.             // 进入休息室休息，await前需要获取锁，
  22.             // await执行后释放锁，进入 ConditionObject 等待
  23.             // await被线程唤醒（打断、超时）去重新竞争 lock 锁，竞争成功后，会从await后执行
  24.             condition.await();
  25.             // 唤醒一个等待的线程
  26.             condition.signal();
  28.         }finally {
  29.             // 释放锁
  30.             reentrantLock.unlock();
  31.         }
  32.     }
  33. }