作者 | 王磊

来源 | Java中文社群(ID:javacn666)

转载请联系授权(微信ID:GG_Stone)

JDK 1.5 之前 synchronized 的性能是比较低的,但在 JDK 1.5 中,官方推出一个重量级功能 Lock,一举改变了 Java 中锁的格局。JDK 1.5 之前当我们谈到锁时,只能使用内置锁 synchronized,但如今我们锁的实现又多了一种显式锁 Lock。

前面的文章我们已经介绍了 synchronized,详见以下列表:

《synchronized 加锁 this 和 class 的区别!》

《synchronized 优化手段之锁膨胀机制!》

《synchronized 中的 4 个优化,你知道几个?》

所以本文咱们重点来看 Lock。

Lock 简介

Lock 是一个顶级接口,它的所有方法如下图所示:

它的子类列表如下:

我们通常会使用 ReentrantLock 来定义其实例,它们之间的关联如下图所示:

PS:Sync 是同步锁的意思,FairSync 是公平锁,NonfairSync 是非公平锁。

ReentrantLock 使用

学习任何一项技能都是先从使用开始的,所以我们也不例外,咱们先来看下 ReentrantLock 的基础使用:

public class LockExample {// 创建锁对象private final ReentrantLock lock = new ReentrantLock();public void method() {// 加锁操作lock.lock();try {// 业务代码......} finally {// 释放锁lock.unlock();}}
}

ReentrantLock 在创建之后,有两个关键性的操作:

  • 加锁操作:lock()

  • 释放锁操作:unlock()

ReentrantLock 中的坑

1.ReentrantLock 默认为非公平锁

很多人会认为(尤其是新手朋友),ReentrantLock 默认的实现是公平锁,其实并非如此,ReentrantLock 默认情况下为非公平锁(这主要是出于性能方面的考虑),比如下面这段代码:

import java.util.concurrent.locks.ReentrantLock;public class LockExample {// 创建锁对象private static final ReentrantLock lock = new ReentrantLock();public static void main(String[] args) {// 定义线程任务Runnable runnable = new Runnable() {@Overridepublic void run() {// 加锁lock.lock();try {// 打印执行线程的名字System.out.println("线程:" + Thread.currentThread().getName());} finally {// 释放锁lock.unlock();}}};// 创建多个线程for (int i = 0; i < 10; i++) {new Thread(runnable).start();}}
}

以上程序的执行结果如下:

从上述执行的结果可以看出,ReentrantLock 默认情况下为非公平锁。因为线程的名称是根据创建的先后顺序递增的,所以如果是公平锁,那么线程的执行应该是有序递增的,但从上述的结果可以看出,线程的执行和打印是无序的,这说明 ReentrantLock 默认情况下为非公平锁。

想要将 ReentrantLock 设置为公平锁也很简单,只需要在创建 ReentrantLock 时,设置一个 true 的构造参数就可以了,如下代码所示:

import java.util.concurrent.locks.ReentrantLock;public class LockExample {// 创建锁对象(公平锁)private static final ReentrantLock lock = new ReentrantLock(true);public static void main(String[] args) {// 定义线程任务Runnable runnable = new Runnable() {@Overridepublic void run() {// 加锁lock.lock();try {// 打印执行线程的名字System.out.println("线程:" + Thread.currentThread().getName());} finally {// 释放锁lock.unlock();}}};// 创建多个线程for (int i = 0; i < 10; i++) {new Thread(runnable).start();}}
}

以上程序的执行结果如下:

从上述结果可以看出,当我们显式的给 ReentrantLock 设置了 true 的构造参数之后,ReentrantLock 就变成了公平锁,线程获取锁的顺序也变成有序的了。

其实从 ReentrantLock 的源码我们也可以看出它究竟是公平锁还是非公平锁,ReentrantLock 部分源码实现如下:

 public ReentrantLock() {sync = new NonfairSync();}
public ReentrantLock(boolean fair) {sync = fair ? new FairSync() : new NonfairSync();
}

从上述源码中可以看出,默认情况下 ReentrantLock 会创建一个非公平锁,如果在创建时显式的设置构造参数的值为 true 时,它就会创建一个公平锁。

2.在 finally 中释放锁

使用 ReentrantLock 时一定要记得释放锁,否则就会导致该锁一直被占用,其他使用该锁的线程则会永久的等待下去,所以我们在使用 ReentrantLock 时,一定要在 finally 中释放锁,这样就可以保证锁一定会被释放。

反例

import java.util.concurrent.locks.ReentrantLock;public class LockExample {// 创建锁对象private static final ReentrantLock lock = new ReentrantLock();public static void main(String[] args) {// 加锁操作lock.lock();System.out.println("Hello,ReentrantLock.");// 此处会报异常,导致锁不能正常释放int number = 1 / 0;// 释放锁lock.unlock();System.out.println("锁释放成功!");}
}

以上程序的执行结果如下:

从上述结果可以看出,当出现异常时锁未被正常释放,这样就会导致其他使用该锁的线程永久的处于等待状态。

正例

import java.util.concurrent.locks.ReentrantLock;public class LockExample {// 创建锁对象private static final ReentrantLock lock = new ReentrantLock();public static void main(String[] args) {// 加锁操作lock.lock();try {System.out.println("Hello,ReentrantLock.");// 此处会报异常int number = 1 / 0;} finally {// 释放锁lock.unlock();System.out.println("锁释放成功!");}}
}

以上程序的执行结果如下:

从上述结果可以看出,虽然方法中出现了异常情况,但并不影响 ReentrantLock 锁的释放操作,这样其他使用此锁的线程就可以正常获取并运行了。

3.锁不能被释放多次

lock 操作的次数和 unlock 操作的次数必须一一对应,且不能出现一个锁被释放多次的情况,因为这样就会导致程序报错。

反例

一次 lock 对应了两次 unlock 操作,导致程序报错并终止执行,示例代码如下:

import java.util.concurrent.locks.ReentrantLock;public class LockExample {// 创建锁对象private static final ReentrantLock lock = new ReentrantLock();public static void main(String[] args) {// 加锁操作lock.lock();// 第一次释放锁try {System.out.println("执行业务 1~");// 业务代码 1......} finally {// 释放锁lock.unlock();System.out.println("锁释锁");}// 第二次释放锁try {System.out.println("执行业务 2~");// 业务代码 2......} finally {// 释放锁lock.unlock();System.out.println("锁释锁");}// 最后的打印操作System.out.println("程序执行完成.");}
}

以上程序的执行结果如下:

从上述结果可以看出,执行第 2 个 unlock 时,程序报错并终止执行了,导致异常之后的代码都未正常执行。

4.lock 不要放在 try 代码内

在使用 ReentrantLock 时,需要注意不要将加锁操作放在 try 代码中,这样会导致未加锁成功就执行了释放锁的操作,从而导致程序执行异常。

反例

import java.util.concurrent.locks.ReentrantLock;public class LockExample {// 创建锁对象private static final ReentrantLock lock = new ReentrantLock();public static void main(String[] args) {try {// 此处异常int num = 1 / 0;// 加锁操作lock.lock();} finally {// 释放锁lock.unlock();System.out.println("锁释锁");}System.out.println("程序执行完成.");}
}

以上程序的执行结果如下:

从上述结果可以看出,如果将加锁操作放在 try 代码中,可能会导致两个问题:

  1. 未加锁成功就执行了释放锁的操作,从而导致了新的异常;

  2. 释放锁的异常会覆盖程序原有的异常,从而增加了排查问题的难度。

总结

本文介绍了 Java 中的显式锁 Lock 及其子类 ReentrantLock 的使用和注意事项,Lock 在 Java 中占据了锁的半壁江山,但在使用时却要注意 4 个问题:

  1. 默认情况下 ReentrantLock 为非公平锁而非公平锁;

  2. 加锁次数和释放锁次数一定要保持一致,否则会导致线程阻塞或程序异常;

  3. 加锁操作一定要放在 try 代码之前,这样可以避免未加锁成功又释放锁的异常;

  4. 释放锁一定要放在 finally 中,否则会导致线程阻塞。

文末福利

今天恰好情人节磊哥联合博文视点出版社,给大家送 3 本何海涛老师的经典书籍《剑指Offer(专项突破版):数据结构与算法名企面试题精讲》,作者从微软起步,面遍各国际大公司,且有近 20 年名企面试官经历,担任面试官面试千余次,积累大量真实试题和现场经验。

中奖规则:评论区留的第 6、16、26 位用户送出此书,免费包邮到家,下周二开奖。

当然,土豪朋友也可以通过下面连接直接购买。

本系列原创文章推荐

1.线程的故事:我的3位母亲成就了优秀的我!

2.线程池的7种创建方式,强烈推荐你用它...

3.轻量级锁一定比重量级锁快吗?

4.这样终止线程,竟然会导致服务宕机?

5.漫画:如何证明sleep不释放锁,而wait释放锁?

6.池化技术到达有多牛?看了这个对比吓我一跳!

7.求求你,别再用wait和notify了!

8.Semaphore自白:限流器用我就对了!

9.CountDownLatch:别浪,等人齐再团!

10.CyclicBarrier:人齐了,老司机就发车了!

11.Java中用户线程和守护线程区别这么大?

12.ThreadLocal不好用?那是你没用对!

13.ThreadLocal内存溢出代码演示和原因分析!

14.SimpleDateFormat线程不安全的5种解决方案!

15.synchronized 加锁 this 和 class 的区别!

16.synchronized 优化手段之锁膨胀机制!

17.synchronized 中的 4 个优化,你知道几个?

ReentrantLock 中的 4 个坑!相关推荐

  1. Javascript之旅——第四站:parseInt中要注意的坑

    Javascript之旅--第四站:parseInt中要注意的坑 原文:Javascript之旅--第四站:parseInt中要注意的坑 前些天信用卡站点要接入一个新功能,不过还真比较坑爹,asp站点 ...

  2. java await signal_【Java并发008】原理层面:ReentrantLock中 await()、signal()/signalAll()全解析...

    一.前言 上篇的文章中我们介绍了AQS源码中lock方法和unlock方法,这两个方法主要是用来解决并发中互斥的问题,这篇文章我们主要介绍AQS中用来解决线程同步问题的await方法.signal方法 ...

  3. python替代hadoop_Python连接Hadoop数据中遇到的各种坑(汇总)

    最近准备使用Python+Hadoop+Pandas进行一些深度的分析与机器学习相关工作.(当然随着学习过程的进展,现在准备使用Python+Spark+Hadoop这样一套体系来搭建后续的工作环境) ...

  4. 10个问题让你快速避开java中的jdbc常见坑

    摘要:JDBC,即Java Database Connectivity,java数据库连接.是一种用于执行SQL语句的Java API,它是Java中的数据库连接规范. 本文分享自华为云社区<1 ...

  5. 小程序中曾经遇到的坑(1)----canvas画布

    目前正在开发小程序,在开发过程中,总会遇到一些坑,而这些坑并不会有很多开发者遇到而说出来.这里先记录一条我开发过程中遇到的问题,以便后人在开发中能够更容易的解决问题!!! 首先,小程序在canvas画 ...

  6. 量化中需留意的坑之二

    之前介绍过量化策略开发过程中容易菜的坑, 量化中需留意的坑之一:https://blog.csdn.net/u011331731/article/details/88351599 本文想补充的是另一个 ...

  7. java lock unlock_【Java并发007】原理层面:ReentrantLock中lock()、unlock()全解析

    一.前言 Java线程同步两种方式,synchronized关键字和Lock锁机制,其中,AQS队列就是Lock锁实现公平加锁的底层支持. 二.AQS源码对于lock.lock()的实现 2.1 AQ ...

  8. [转载] python 列表List中index函数的坑

    参考链接: Python列表list sort() python 列表List中index函数的坑 例如 a = [1, 2, 1] 如果使用 a.index(1), 输出的只是列表中第一个出现的 1 ...

  9. @Value注解使用过程中遇到的一些坑

    笔者结合之前的一些经验教训,再结合一些资料总结了一下@Value注解使用过程中的一些注意事项. 目录 一.@Value无法读取配置文件中的参数 二.@Value出现中文乱码 三.@Value使用的一些 ...

最新文章

  1. 一口气用 Python 写了13个小游戏,摸鱼达人!
  2. Linux下父子进程的全局变量
  3. 项目实战-解决AES(java.security.InvalidKeyException: Illegal key size)
  4. 关于FillSchema与Fill
  5. Redis Client On Error: Error: connect ECONNREFUSED 192.168.xxx.105:6379 Config right?
  6. 关于一些初级ACM竞赛题目的分析和题解(三)。
  7. WEB网页监控系统的设计框架思路详解
  8. CAD单行文本数字求和
  9. 利用uDig 快速生成 GeoServer 可用的 SLD 渲染文件
  10. Neural Granger Causality for Nonlinear Time Series
  11. Virual Studio 2022 C++ CLR 中 模拟 Android Studo,Eclipse 的 LogCat
  12. 【java删除指定文件夹或者文件】
  13. Spark中组件Mllib的学习16之分布式行矩阵的四种形式
  14. python赵璐第三章课后答案_第三章 课后习题及参考答案
  15. android flash路径动画,Flash制作沿着路径的动画
  16. 发那科系统基本参数概述
  17. 【mcuclub】PM2.5粉尘浓度检测模块GP2Y10
  18. linux修复丢失的分区表
  19. 【论文简述及翻译】PSMNet:Pyramid Stereo Matching Network(CVPR 2018)
  20. 浏览器输入字无法显示选字框问题

热门文章

  1. ps导出gif颜色不对_PS基础知识(1)
  2. Consider defining a bean of type ‘java.lang.String‘ in your configuration
  3. vue内引入语音播报功能
  4. 国内远程医疗市场快速增长
  5. ISA Server 2006 部署步骤
  6. Gson的使用,对于不需要html escape的情况的处理
  7. 转: 加快Android编译速度
  8. 《几何与代数导引》例2.9
  9. 让sky Driver成为你的可见硬盘
  10. vant toast loading 倒计时_日期倒计时软件哪个好 苹果日期倒计时软件推荐