Java 5 之后,Java在内置关键字sychronized的基础上又增加了一个新的处理锁的方式,Lock类。

由于在Java线程间通信:volatile与sychronized中,我们已经详细的了解了synchronized,所以我们现在主要介绍一下Lock,以及将Lock与synchronized进行一下对比。

1. synchronized的缺陷

synchronized修饰的代码只有获取锁的线程才能够执行,其他线程只能等待该线程释放锁。一个线程释放锁的情况有以下方式:

  • 获取锁的线程完成了synchronized修饰的代码块的执行。
  • 线程执行时发生异常,JVM自动释放锁。

我们在Java多线程的生命周期,实现与调度中谈过,锁会因为等待I/O,sleep()方法等原因被阻塞而不释放锁,此时如果线程还处于用synchronized修饰的代码区域里,那么其他线程只能等待,这样就影响了效率。因此Java提供了Lock来实现另一个机制,即不让线程无限期的等待下去。

思考一个情景,当多线程读写文件时,读操作和写操作会发生冲突,写操作和写操作会发生冲突,但读操作和读操作不会有冲突。如果使用synchronized来修饰的话,就很可能造成多个读操作无法同时进行的可能(如果只用synchronized修饰写方法,那么可能造成读写冲突,如果同时修饰了读写方法,则会有读读干扰)。此时就需要用到Lock,换言之Lock比synchronized提供了更多的功能。

使用Lock需要注意以下两点:

  • Lock不是语言内置的,synchronized是Java关键字,为内置特性,Lock是一个类,通过这个类可以实现同步访问。
  • 采用synchronized时我们不需要手动去控制加锁和释放,系统会自动控制。而使用Lock类,我们需要手动的加锁和释放,不主动释放可能会造成死锁。实际上Lock类的使用某种意义上讲要比synchronized更加直观。

2. Lock类接口设计

Lock类本身是一个接口,其方法如下:

public interface Lock {void lock();void lockInterruptibly() throws InterruptedException;boolean tryLock();boolean tryLock(long time, TimeUnit unit) throws InterruptedException;void unlock();Condition newCondition();
}

下面依次讲解一下其中各个方法。

  • lock() 方法使用最多,作用是用于获取锁,如果锁已经被其他线程获得,则等待。
    通常情况下,lock使用以下方式去获取锁:
Lock lock = ...;
lock.lock();
try{//处理任务
}catch(Exception ex){}finally{lock.unlock();   //释放锁
}
  • lockInterruptibly() 和lock()的区别是lockInterruptibly()锁定的线程处于等待状态时,允许线程的打断操作,线程使用Thread.interrupt()打断该线程后会直接返回并抛出一个InterruptException();lock()方法锁定对象时如果在等待时检测到线程使用Thread.interrupt(),仍然会继续尝试获取锁,失败则继续休眠,只是在成功获取锁之后在把当前线程置为interrupt状态。也就使说,当两个线程同时通过lockInterruptibly()想获取某个锁时,假若此时线程A获取到了锁,而线程B只有在等待,那么对线程B调用threadB.interrupt()方法能够中断线程B的等待过程。
    因此,lockInterruptibly()方法必须实现catch(InterruptException e)代码块。常见使用方式如下:
public void method() throws InterruptedException {lock.lockInterruptibly();try {  //.....}finally {lock.unlock();}
}
  • tryLock() 和lock()最大的不同是具有返回值,或者说,它不去等待锁。如果它成功获取锁,那么返回true;如果它无法成功获取锁,则返回false。
    通常情况下,tryLock使用方式如下:
Lock lock = ...;
if(lock.tryLock()) {try{//处理任务}catch(Exception ex){}finally{lock.unlock();   //释放锁}
}else {//如果不能获取锁,则直接做其他事情
}
  • tryLock(long time, TimeUnit unit) 则是介于二者之间,用户设定一个等待时间,如果在这个时间内获取到了锁,则返回true,否则返回false结束。
  • unlock() 从上面的代码里我们也看到,unlock()一般放在异常处理操作的finally字符控制的代码块中。我们要记得Lock和sychronized的区别,防止产生死锁。
  • newCondition() 该方法我们放到后面讲。

3. ReentrantLock可重入锁

3.1. ReentrantLock概述

ReentrantLock译为“可重入锁”,我们在Java多线程:synchronized的可重入性中已经明白了什么是可重入以及理解了synchronized的可重入性。ReentrantLock是唯一实现Lock接口的类。

3.2. ReentrantLock使用

考虑到以下情景,一个仅出售双人票的演唱会进行门票出售,有三个售票口同时进行售票,买票需要100ms时间,每张票出票需要100ms时间。该如何设计这个情景?

package com.cielo.LockTest;import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;import static java.lang.Thread.sleep;/*** Created by 63289 on 2017/4/10.*/
class SoldTicket implements Runnable {Lock lock = new ReentrantLock();//使用可重入锁private volatile Integer ticket;//保证从主内存获取SoldTicket(Integer ticket) {this.ticket = ticket;//提供票数}private void sold() {lock.lock();//锁定操作放在try代码块外try {if (ticket <= 0) return;//当ticket==2时可能有多个线程进入sold方法,一个线程运行后另外两个线程需要退出。sleep(200);//买票0.1s,出票0.1s--ticket;System.out.println("The first ticket is sold by "+Thread.currentThread().getId()+", "+ticket+" tickets leave.");//获取线程id来识别出票站。sleep(100);//出票0.1s--ticket;System.out.println("The second ticket is sold by "+Thread.currentThread().getId()+", "+ticket+" tickets leave.");} catch (InterruptedException e) {e.printStackTrace();} finally {lock.unlock();}}@Overridepublic void run() {while (ticket > 0) {sold();}}
}public class LockTest {public static void main(String[] args) {SoldTicket soldTicket = new SoldTicket(20);new Thread(soldTicket).start();new Thread(soldTicket).start();new Thread(soldTicket).start();}
}

上面这段代码结果如下:

The first ticket is sold by 11, 19 tickets leave.
The second ticket is sold by 11, 18 tickets leave.
The first ticket is sold by 13, 17 tickets leave.
The second ticket is sold by 13, 16 tickets leave.
The first ticket is sold by 13, 15 tickets leave.
The second ticket is sold by 13, 14 tickets leave.
The first ticket is sold by 12, 13 tickets leave.
The second ticket is sold by 12, 12 tickets leave.
The first ticket is sold by 11, 11 tickets leave.
The second ticket is sold by 11, 10 tickets leave.
The first ticket is sold by 11, 9 tickets leave.
The second ticket is sold by 11, 8 tickets leave.
The first ticket is sold by 13, 7 tickets leave.
The second ticket is sold by 13, 6 tickets leave.
The first ticket is sold by 13, 5 tickets leave.
The second ticket is sold by 13, 4 tickets leave.
The first ticket is sold by 13, 3 tickets leave.
The second ticket is sold by 13, 2 tickets leave.
The first ticket is sold by 13, 1 tickets leave.
The second ticket is sold by 13, 0 tickets leave.

如果我们不对售票操作进行锁定,则会有以下几个问题:

  • 出售第一张票后其他机器出了另一张票,导致票没有成对卖。
  • 已经无票后仍有机器出票造成混乱。

显然,本题的情景用synchronized也可以很容易的实现,实际上Lock有别于synchronized的主要点是lockInterruptibly()和tryLock()这两个可以对锁进行控制的方法。

4. ReadWriteLock读写锁

4.1. ReadWriteLock接口

回到开头synchronized缺陷的介绍,实际上,Lock接口的重要衍生接口ReadWriteLock即是解决这一问题。ReadWriteLock定义很简单,仅有两个接口:

public interface ReadWriteLock {/*** Returns the lock used for reading.** @return the lock used for reading.*/Lock readLock();/*** Returns the lock used for writing.** @return the lock used for writing.*/Lock writeLock();
}

即是它只提供了readLock()和writeLock()两个操作,这两个操作均返回一个Lock类的实例。两个操作一个获取读锁,一个获取写锁,将读写分开进行操作。ReadWriteLock将读写的锁分开,可以让多个读操作并行,这就大大提高了效率。使用ReadWriteLock时,用读锁去控制读操作,写锁控制写操作,进而实现了一个可以在如下的大量读少量写且读者优先的情景运行的锁。

4.2. ReentrantReadWriteLock可重入读写锁

ReentrantReadWriteLock是ReadWriteLock的唯一实例。同时提供了很多操作方法。ReentratReadWriteLock接口实现的读锁写锁进入有如下要求:

4.2.1. 线程进入读锁的要求

  • 没有其他线程的写锁。
  • 没有锁请求 或 调用写请求的线程正是该线程。

4.2.2. 线程进入写锁的要求

  • 没有其他线程的读锁。
  • 没有其他线程的写锁。

4.2.3. 读写锁使用示例

private SomeClass someClass;//资源
private final ReadWriteLock readWriteLock = new ReentrantReadWriteLock();//创建锁
private final Lock readLock = readWriteLock.readLock();//读锁
private final Lock writeLock = readWriteLock.writeLock();//写锁
//读方法
readLock.lock();
try {result = someClass.someMethod();
} catch (Exception e) {e.printStackTrace();
} finally {readLock.unlock();
}
//写方法,产生新的SomeClass实例tempSomeClass
writeLock.lock();
try{this.someClass = tempSomeClass;//更新
}catch (Exception e) {e.printStackTrace();
} finally{writeLock.unlock();
}

5. 公平锁

公平锁即当多个线程等待的一个资源的锁释放时,线程不是随机的获取资源而是等待时间最久的线程获取资源(FIFO)。Java中,synchronized是一个非公平锁,无法保证锁的获取顺序。ReentrantLock和ReentrantReadWriteLock默认也是非公平锁,但可以设置成公平锁。我们前面的实例中初始化ReentrantLock和ReentrantReadWriteLock时都是无参数的。实际上,它们提供一个默认的boolean变量fair,为true则为公平锁,为false则为非公平锁,默认为false。因此,当我们想将其实现为公平锁时,仅需要初始化时赋值true。即:

    Lock lock = new ReentrantLock(true);

考虑前面卖票的实例,如果改为公平锁(尽管这和情景无关),则结果输出非常整齐如下:

The first ticket is sold by 11, 19 tickets leave.
The second ticket is sold by 11, 18 tickets leave.
The first ticket is sold by 12, 17 tickets leave.
The second ticket is sold by 12, 16 tickets leave.
The first ticket is sold by 13, 15 tickets leave.
The second ticket is sold by 13, 14 tickets leave.
The first ticket is sold by 11, 13 tickets leave.
The second ticket is sold by 11, 12 tickets leave.
The first ticket is sold by 12, 11 tickets leave.
The second ticket is sold by 12, 10 tickets leave.
The first ticket is sold by 13, 9 tickets leave.
The second ticket is sold by 13, 8 tickets leave.
The first ticket is sold by 11, 7 tickets leave.
The second ticket is sold by 11, 6 tickets leave.
The first ticket is sold by 12, 5 tickets leave.
The second ticket is sold by 12, 4 tickets leave.
The first ticket is sold by 13, 3 tickets leave.
The second ticket is sold by 13, 2 tickets leave.
The first ticket is sold by 11, 1 tickets leave.
The second ticket is sold by 11, 0 tickets leave.

6. Lock和synchronized的选择

  • synchronized是内置语言实现的关键字,Lock是为了实现更高级锁功能而提供的接口。
  • Lock实现了tryLock等接口,线程可以不用一直等待。
  • synchronized发生异常时自动释放占有的锁,Lock需要在finally块中手动释放锁。因此从安全性角度讲,既可以用Lock又可以用synchronized时(即不需要锁的更高级功能时)使用synchronized更保险。
  • Lock可以通过lockInterruptibly()接口实现可中断锁。
  • 由于Lock提供了时间限制同步,可被打断同步等机制,线程激烈竞争时Lock的性能远优于synchronized,即有大量线程时推荐使用Lock。在竞争不激烈时,由于synchronized的编译器优化更好,性能更佳。
  • ReentrantReadWriteLock实现了封装好的读写锁用于大量读少量写读者优先情景解决了synchronized读写情景难以实现问题。

7. 参考文章

Java并发编程:Lock

lock和lockInterruptibly

说说ReentrantReadWriteLock

转载于:https://www.cnblogs.com/cielosun/p/6662201.html

Java多线程:线程间通信之Lock相关推荐

  1. Java 如何线程间通信,面试被问哭。。。

    Java 如何线程间通信,曾经小编面试被问哭的一道题.. 正常情况下,每个子线程完成各自的任务就可以结束了.不过有的时候,我们希望多个线程协同工作来完成某个任务,这时就涉及到了线程间通信了. 本文涉及 ...

  2. 多线程-线程间通信-多生产者多消费者示例

    1.多线程-线程间通信-多生产者多消费者问题 多生产者和多消费者.等待唤醒机制. 产生了两个问题: 1.出现了多次连续生产,未消费,或者一个商品被消费多次. 解决:必须要--------每一个被唤醒的 ...

  3. Java并发——线程间通信与同步技术

    传统的线程间通信与同步技术为Object上的wait().notify().notifyAll()等方法,Java在显示锁上增加了Condition对象,该对象也可以实现线程间通信与同步.本文会介绍有 ...

  4. Java多线程(Thread)间通信和共享数据

    多线程间如何通信和共享数据,肯定好多小伙伴都不知道, 或者很久之前知道,现在已经忘却,现在我和大家一起复习一下. 一.线程间通信 1.线程间通信:A执行完,B才执行 /*** 线程间通信:A执行完,B ...

  5. java实现线程间通信的四种方式

    synchronized同步 public class MyObject { synchronized public void methodA() { //do something.... } syn ...

  6. Java多线程:线程间通信之volatile与sychronized

    由前文Java内存模型我们熟悉了Java的内存工作模式和线程间的交互规范,本篇从应用层面讲解Java线程间通信. Java为线程间通信提供了三个相关的关键字volatile, synchronized ...

  7. 抖音最后一面,问我Java 是如何实现线程间通信的?

    线程之间到底使用什么沟通的呢?如何把数值变化传递给其他子线程? 来源:blog.csdn.net/lanxian837820149/article/details/101479004 MarkerHu ...

  8. Java多线程编程-(5)-使用Lock对象实现同步以及线程间通信

    前几篇: Java多线程编程-(1)-线程安全和锁Synchronized概念 Java多线程编程-(2)-可重入锁以及Synchronized的其他基本特性 Java多线程编程-(3)-线程本地Th ...

  9. Java基础学习——多线程(线程间通信-生产者消费者代码示例)

    JDK 1.5提供了多线程升级方案 将同步synchronized替换成了显示的Lock操作.可以实现唤醒.冻结指定的线程. Lock接口 Lock 实现提供了比使用 synchronized 方法和 ...

最新文章

  1. 将jar包部署在docker上,将jar包打成镜像,使用docker部署jar包
  2. java oracle数据库高效分页查询_oracle高效分页查询总结
  3. thinkphp mysql json数据类型_ThinkPHP:JSON字段类型的使用(ORM)
  4. Lotus Notes应用经验谈
  5. oracle时间类型转化成java对象_Oracle数据库date类型与Java中Date的联系与转化
  6. python 打开txt_在python中从txt文件打开链接
  7. Java中this与super的区别
  8. idea数据库反向生成实体类_IntelliJ IDEA 的数据库管理工具实在太方便了
  9. selenium python实例录制运行_WEB自动化测试工具selenium录制器使用笔记
  10. c语言八数码A星算法代码解析,八数码问题c语言a星算法详细实验报告含代码解析...
  11. php连接mysql数据没反应_php无法连接mysql数据库的正确解决方法
  12. centos7 快速安装 mariadb(mysql)
  13. 马尾物联网企业主导或参与制定修订各级标准达60项
  14. Java本地缓存技术选型(Guava Cache、Caffeine、Encache)
  15. 【408考研笔记】操作系统完整知识点
  16. 一张帖搞定同学们入学黑马前所有难题
  17. HDU2825 Wireless Password【AC自动机 + DP】
  18. python处理考勤数据_python连接中控考勤机分析数据
  19. 【Vegas原创】“光驱无法访问,函数不正确”解决方法
  20. Scrum立会报告+燃尽图(十月二十八日总第十九次)

热门文章

  1. docker 镜像上传至hub时报错,提示:denied: requested access to the resource is denied
  2. eclipse部分快捷操作
  3. Eclipse Tomcat调试timeout超时怎么办
  4. 技术部门 Leader 与团队那些事
  5. CentOS安装Mysql8
  6. 操作系统(八)进程状态的转换以及进程组织方式
  7. 【动态规划】分组背包
  8. php 访问 memcache,memcache+php实现页面访问的加速
  9. windows 7 网卡物理地址修改方法
  10. 如何快速切换静态和动态ip