对于并发工作,你需要某种方式来防止两个任务访问相同的资源,至少在关键阶段不能出现这种冲突情况。防止这种冲突的方法就是当资源被一个任务使用时,在其上加锁。在前面的文章--synchronized学习中,我们学习了Java中内建的同步机制synchronized的基本用法,在本文中,我们来学习Java中另一种锁ReentrantLock。

ReentrantLock介绍

  ReentrantLock,通常译为再入锁,是Java 5中新加入的锁实现,它与synchronized基本语义相同。再入锁通过代码直接调用lock()方法获取,代码书写更加灵活。与此同时,ReentrantLock提供了很多实用的方法,能够实现很多synchronized无法做到的细节控制,比如可以控制fairness,也就是公平性,或者利用定义条件等。但是,编码中也需要注意,必须要明确调用unlock()方法释放锁,不然就会一直持有该锁。

  我们先看一个简单例子体验一下:

public class ReLockTest {private Lock lock = new ReentrantLock();public int shareState;public void add() {shareState ++ ;}public void printState() {System.out.println("shareState-->" + shareState);
    }public static void main(String[] args) throws Exception{ReLockTest reLockTest = new ReLockTest();Thread t1 = new Thread(()->{for(int i = 0; i<10000 ; i++)reLockTest.add();});Thread t2 = new Thread(()->{for(int i = 0; i<10000 ; i++)reLockTest.add();});t1.start();t2.start();t1.join();t2.join();Thread.sleep(2000);reLockTest.printState();}
}

/** 输出结果 *  shareState-->14012 */

  我们看到输出结果小于20000,这就是线程不安全,我们加上同步之后再看结果:

public class ReLockTest {private Lock lock = new ReentrantLock();public int shareState;public void add() {lock.lock();try {shareState ++ ;}catch(Exception e) {e.printStackTrace();}finally {lock.unlock();}}public void printState() {System.out.println("shareState-->" + shareState);
    }public static void main(String[] args) throws Exception{ReLockTest reLockTest = new ReLockTest();Thread t1 = new Thread(()->{for(int i = 0; i<10000 ; i++)reLockTest.add();});Thread t2 = new Thread(()->{for(int i = 0; i<10000 ; i++)reLockTest.add();});t1.start();t2.start();t1.join();t2.join();Thread.sleep(2000);reLockTest.printState();}
}
/** 输出结果 *  shareState-->20000 */

  

  我们看到在将自增操作上锁之后,输出结果就达到预期了。这就是ReentrantLock的基本用法,为了保证锁释放,每个lock()动作都对应一个try-catch-finally,这可以说是一个惯用法:

ReentrantLock lock = new ReentrantLock();
lock.lock();
try {// do something
} finally {lock.unlock();
}

ReentrantLock用法

  ReentrantLock相比synchronized,虽然所需的代码比synchronized关键字要多,但也是因为可以像普通对象一样使用,所以可以利用其提供的各种便利方法,进行精细的同步操作,甚至是synchronized难以表达的用例,如:

带超时的获取锁尝试

  通过tryLock(long timeout, TimeUnit unit)方法实现,这是一个具有超时参数的尝试申请锁的方法,阻塞时间不会超过给定的值;如果成功则返回true。

可以指定公平性

  在创建ReentrantLock对象时往构造器中传入true即指定创建公平锁,这里所谓的公平是指在竞争场景中,当公平性为真时,会倾向于将锁赋予等待时间最久的线程。公平性是减少线程“饥饿”(个别线程长期等待锁,但始终无法获取)情况的发生的一个办法。

  如果使用synchronized,我们根本无法进行公平性的选择,其永远是不公平的,这也是主流操作系统线程调度的选择。通用场景中,公平性未必有想象中的那么重要,Java默认的调度策略很少会导致“饥饿”发生。与此同时,若要保证公平性则会引入额外开销,自然会导致一定的吞吐量下将。所以,只有当程序确实有公平性需要的时候,才有必要指定它。

可以响应中断请求

  通过lockInterruptibly()获得锁,但是会不确定地发生阻塞。如果线程被中断,抛出一个InterruptedException异常。

可以创建条件变量,将复杂晦涩的同步操作转变为直观可控的对象行为

  如果说ReentrantLock是synchronized的替代选择,Conition则是将wait、notify、notifyAll等操作转化为相应的对象,将复杂而晦涩的同步操作转变为直观可控的对象行为。

  可以通过Condition上调用await()来挂起一个任务,当外部条件发生变化,你可以通过调用signal()来通知这个任务,从而唤醒一个任务,或者调用signAll()来唤醒所有在这个Condition上被其自身挂起的任务,这是Condition最常见的用法。一个典型的应用场景就是标准类库中的ArrayBlockingQueue,下面我们结合部分其源码来分析一下:

  首先,在构造函数中初始化lock,在从lock中创建两个条件变量Condition分别是notEmpty和notFull。

/** Main lock guarding all access */
final ReentrantLock lock;/** Condition for waiting takes */
private final Condition notEmpty;/** Condition for waiting puts */
private final Condition notFull;public ArrayBlockingQueue(int capacity, boolean fair) {if (capacity <= 0)throw new IllegalArgumentException();this.items = new Object[capacity];lock = new ReentrantLock(fair);notEmpty = lock.newCondition();notFull =  lock.newCondition();
}

  然后在take方法中,判断和等待条件满足:

public E take() throws InterruptedException {final ReentrantLock lock = this.lock;lock.lockInterruptibly();try {while (count == 0)notEmpty.await();return dequeue();} finally {lock.unlock();}
}

  在take方法中,如果队列为空,ArrayBlockingQueue的本义是获取对象的线程会阻塞,等待入队的发生,而不是直接返回,代码中是通过调用Condition的await方法来实现的,而当有元素入队之后又是如何触发被阻塞的take操作的呢?我们看看enqueue:

private void enqueue(E x) {// assert lock.getHoldCount() == 1;// assert items[putIndex] == null;final Object[] items = this.items;items[putIndex] = x;if (++putIndex == items.length)putIndex = 0;count++;notEmpty.signal();  // 通知等待的线程
}

  最后一行代码中就是通知等待的线程,这行执行结束后,被take阻塞的线程就会继续执行了。

  通过signal/await的组合,完成了条件判断和通知等待线程,非常顺畅就完成了状态流转。signal和await成对调用非常重要,不然假设只有await动作,线程会一直等待直到被打断(interrupt)。

ReentrantLock与Synchronized

  使用synchronized关键字时,需要写的代码量更少,而ReentrantLock的使用往往和try-catch-finally一起配套使用,代码量增加了。

  从性能角度,synchronized早期的实现比较低效,对比ReentrantLock,大多数场景性能都相差较大。但是在Java 6中对其进行了非常多的改进(可以参考synchronized底层实现学习),在高竞争情况下,ReentrantLock仍然有一定优势。

  我们知道synchronized获取的锁是monitor对象,而ReentrantLock获取的锁是什么呢,是否也是同一把锁呢?下文中,我们会深入源码去探究ReentrantLock获取锁的实现细节。

转载于:https://www.cnblogs.com/volcano-liu/p/10262183.html

ReentrantLock学习相关推荐

  1. JAVA——以ReentrantLock为例学习重入锁以及公平性问题

    关注微信公众号:CodingTechWork,一起学习交流进步. 引言   重入锁,顾名思义在于这个重字.开发过程中,我们在用到锁时,可能会用于递归的方法上加锁,此时,那同一个方法对象去重复加锁,是怎 ...

  2. Java并发学习笔记:ReentrantLock

    锁的获取主要是这两个函数,当然还有 lockInterruptibly( ) 和 tryLock(long timeout, TimeUnit unit) 这种响应中断和带时间限制的函数,不过和普通的 ...

  3. 并发编程(入门) 多线程学习 手写ReentrantLock

    本文学习资料和灵感来自网络,感谢享学课堂13号技师.开课吧小师妹.汪文君老师.<Java并发编程实战>[Brian Goetz] 一:概述 随着java技术的成熟和工作年限的增长,现在出去 ...

  4. 【多线程学习笔记】sychronized关键字底层原理、sychronized与ReentrantLock、volatile和synchronized

    文章目录 sychronized释义 synchronized关键字最主要的三种使用方式: synchronized底层原理: 同步代码块: 同步方法 当前类的class对象作为锁 锁升级 Synch ...

  5. Java基础学习总结(154)——Synchronized与Volatile、Synchronized与ReentrantLock概念及区别

    一.Synchronized与Volatile的区别 首先需要理解线程安全的两个方面:执行控制和内存可见.执行控制的目的是控制代码执行(顺序)及是否可以并发执行.内存可见控制的是线程执行结果在内存中对 ...

  6. java condition_死磕 java同步系列之ReentrantLock源码解析(二)

    (手机横屏看源码更方便) 问题 (1)条件锁是什么? (2)条件锁适用于什么场景? (3)条件锁的await()是在其它线程signal()的时候唤醒的吗? 简介 条件锁,是指在获取锁之后发现当前业务 ...

  7. Java架构师笔记-你必须掌握学习Java需要掌握哪些技能

    闲来无事,师长一向不(没)喜(有)欢(钱)凑热闹,倒不如趁着这时候复盘复盘.而写这篇文章的目的是想总结一下自己这么多年来使用java的一些心得体会,希望可以给大家一些经验,能让大家更好学习和使用Jav ...

  8. Java 学习内容总结

    最近对Core Java基础做了一些学习.有自己的见解,也有别人的总结,供大家参考. 1 实现多线程的方式有几种? 其实这个问题并不难,只是在这里做一个总结.一共有三种. 实现Runnable接口,并 ...

  9. Java多线程高并发学习笔记(一)——ThreadRunnable

    进程与线程 首先来看百度百科关于进程的介绍: 进程是一个具有独立功能的程序关于某个数据集合的一次运行活动.它可以申请和拥有系统资源,是一个动态的概念,是一个活动的实体.它不只是程序的代码,还包括当前的 ...

最新文章

  1. Django快速分页
  2. boost::adaptors相关的测试程序
  3. python原始web与django框架 mvc模式开发
  4. DOS系统功能调用表(INT 21H)
  5. JQuery学习使用笔记 -- JQuery插件开发
  6. TVS 管性能及选型总结
  7. Android 如何调用系统默认浏览器访问
  8. 智能家居助手后台系统原型/智慧家居后台管理系统/应用分析/页面分析/设备分析/用户管理/运营管理/权限管理/系统设置/问题反馈/商城管理/消息管理/用户画像/公告管理/账号画像/留存用户/数据埋点
  9. Python求1~300之间所有的完数
  10. HDU6266 - Hakase and Nano 狄利克雷卷积
  11. CDC::Arc 汉化参数明说及举例
  12. 如何建语料库_语料库-如何建设语料?如何建设语料库 爱问知识人
  13. Java物联网平台后端架构构思设计
  14. IoT产品安全基线(一)硬件安全
  15. 新年喜报!10人通过RHCA、60人通过RHCE!
  16. java 基础 api,Java基础——常用API
  17. 无线降噪耳机推荐,热销火爆的四款降噪耳机推荐
  18. linux的gz文件怎么解压缩,linux gz 解压缩
  19. 金蝶KIS标准版会计期间超过三期。。。
  20. 若依分离版在windows上部署(1)

热门文章

  1. alloca函数的风险_alloca的函数范围中的goto是否有效?
  2. 1071svm函数 r语言_R语言机器学习之核心包e1071 - 数据分析
  3. html无损转换pdf,Pdf2html :高保真PDF至HTML转换
  4. LeetCode MySQL 1821. 寻找今年具有正收入的客户
  5. LeetCode 1765. 地图中的最高点(BFS)
  6. java 主方法 this_java main 方法怎么创建
  7. pythonmain是什么意思_Python中if __name__ == __main__详细解释
  8. i12蓝牙耳机使用说明书图片_配置强悍、适用于开车、运动的蓝牙耳机Xisem西圣 Ares使用体验...
  9. 电商网站(Django框架)—— 大纲内容与基本功能分析
  10. putty连接linux上传python,通过PuTTY用于SSH的Python脚本