当前位置: 首页 > news >正文

Java多线程之Lock的使用(一)

Java多线程中,可以使用synchronized关键字实现线程之间同步互斥,JDK1.5中新增加了ReentrantLock类也可以达到同样的效果,并且更加强大。

如何使用

class MyService {
   private var lock: Lock = ReentrantLock()
   fun testMethod() {
       lock.lock() //获取锁
       for (i in 1..5) {
           println("ThreadName is ${Thread.currentThread().name} $i")
       }
       lock.unlock()   //释放锁
   }
}复制代码

如代码所示,调用ReentrantLock对象的lock()方法获取锁,调用unlock()方法释放锁。

调用lock.lock()代码的线程就持有了“对象监视器”,其他线程就只有等待锁被释放时再次争抢。效果和synchronized关键字一样,线程之间执行的顺序时随机的。

使用Condition实现等待/通知

关键字synchronizedwait()notify()/notifyAll()方法结合可以实现等待/通知模式,类ReentrantLock也可以实现同样的功能,但需要借助于Condition对象。

Condition类是JDK1.5中出现的技术,使用它有更好的灵活性,比如可以实现多路通知功能,也就是在一个Lock对象里面创建多个Condition(即对象监视器)实例,线程对象可以注册在指定的Condition中,从而可以有选择的进行线程通知。

在使用notify()方法进行通知的时候,被通知的线程是由JVM随机选择的。使用ReentrantLock结合Condition是可以实现“选择性通知”的。

synchronized相当于整个Lock对象中只有一个单一的Condition对象,所有线程都注册在它一个对象上。

实现代码如下:

class MyService {

    private var lock: Lock = ReentrantLock()

    private var condition: Condition = lock.newCondition()

    fun await() {
        try {
            lock.lock()
            println("await时间为: ${System.currentTimeMillis()}")
            condition.await()
        } catch(e: InterruptedException) {
            e.printStackTrace()
        } finally {
            lock.unlock()
        }
    }

    fun signal() {
        try {
            lock.lock()
            println("signal时间为:${System.currentTimeMillis()}")
            condition.signal()
        } finally {
            lock.unlock()
        }
    }
}复制代码

Object类中的wait()方法相当于Condition类中的await()方法,Object类中的notify相当于Condition中的signal()

使用多个Condition实现通知部分线程

实现代码如下:

class MyService {

    private var lock: Lock = ReentrantLock()

    private var conditionA: Condition = lock.newCondition()
    private var conditionB: Condition = lock.newCondition()

    fun awaitA() {
        try {
            lock.lock()
            println("begin awaitA时间为:${System.currentTimeMillis()} ThreadName = ${Thread.currentThread().name}")
            conditionA.await()
            println("end awaitA时间为:${System.currentTimeMillis()} ThreadName = ${Thread.currentThread().name}")
        } catch(e: InterruptedException) {
            e.printStackTrace()
        } finally {
            lock.unlock()
        }
    }

    fun awaitB() {
        try {
            lock.lock()
            println("begin awaitB时间为:${System.currentTimeMillis()} ThreadName = ${Thread.currentThread().name}")
            conditionB.await()
            println("end awaitB时间为:${System.currentTimeMillis()} ThreadName = ${Thread.currentThread().name}")
        } catch(e: InterruptedException) {
            e.printStackTrace()
        } finally {
            lock.unlock()
        }
    }

    fun signalAll_A() {
        try {
            lock.lock()
            println("signalAll_A时间为:${System.currentTimeMillis()} ThreadName = ${Thread.currentThread().name}")
            conditionA.signalAll()
        } finally {
            lock.unlock()
        }
    }

    fun signalAll_B() {
        try {
            lock.lock()
            println("signalAll_B时间为:${System.currentTimeMillis()} ThreadName = ${Thread.currentThread().name}")
            conditionB.signalAll()
        } finally {
            lock.unlock()
        }
    }
}复制代码

公平锁与非公平锁

锁Lock分为“公平锁”和“非公平锁”,公平锁表示线程获取锁的顺序是按照线程加锁的顺序来分配的,即先来先得的FIFO顺序。而非公平锁就是一种获取锁的抢占机制,是随机获得锁的。

  • 创建公平锁:

    var lock: Lock = ReentrantLock(true)复制代码

    or

    var lock: Lock = ReentrantLock()复制代码
  • 创建非公平锁:

    var lock: Lock = ReentrantLock(false)复制代码

ReentrantLock一些常用的方法

  • getHolderCount():int - 查询当前线程保持此锁定的个数

  • getQueueLength():int - 获取正在等待获取此锁定的线程估计数

    比如有5个线程,一个线程首先执行await()方法,那么调用getQueueLength()方法的返回值是4,说明4个线程同时等待lock的释放。

  • getWaitQueueLength(Condition):int - 返回等待与此锁定相关的给定条件Condition的线程估计数

    比如有5个线程,每个线程都执行了同一个Condition对象的await()方法,则调用getWaitQueueLength()方法时返回5

  • hasQueuedThread(Thread):boolean - 查询指定的线程是否正在等待获取此锁定

  • hasQueuedThreads():boolean - 查询是否有线程正在等待获取此锁定

  • hasWaiters(Condition):boolean - 查询是否有线程正在等待与此锁定有关的Condition条件

  • isFair():boolean - 判断是不是公平锁

  • isHeldByCurrentThread():boolean - 查询当前线程是否保持锁定

  • isLocked():boolean - 查询此锁定是否由任意线程保持

  • lockInterruptibly():void - 如果当前线程未被中断,则获取锁定,如果已经被中断则出现异常

  • tryLock():boolean - 仅在调用时锁定未被另一个线程保持的情况下,才获取该锁定

  • tryLock(long,TimeUnit):boolean - 如果锁定在给定等待时间内没有被另一个线程保持,且当前线程未被中断,则获取该锁定

  • awaitUnintterruptibly():void - 进入无法被打断的等待状态

相关文章:

  • vue项目 移动端 实现购物车功能
  • 火柴棒等式(2008年NOIP全国联赛提高组)
  • 如何用几何画板动态演示电饭锅工作原理
  • git 撤回 (git版本回退处理)
  • 好用的开发工具
  • 前端 重写 toFixed 方法并封装(不采用银行家算法返回正常数字类型)
  • Oracle死锁
  • 项目中new Promise和async、await中的使用,以及promise.all在项目中的实际应用
  • Android开发学习——ListView+BaseAdapter的使用
  • react 项目商城中,显示或者隐藏组件(锚点)
  • Java 线程池
  • react this.setState接收参数 。写成Promise形式。以及async/await和Promise的区别
  • python基本数据类型的问题
  • 前端 js 实现拆分table 列表数组为 单个新数组()
  • 学习正则表达式的优秀文章
  • JavaScript-如何实现克隆(clone)函数
  • @jsonView过滤属性
  • extjs4学习之配置
  • iOS帅气加载动画、通知视图、红包助手、引导页、导航栏、朋友圈、小游戏等效果源码...
  • JavaScript DOM 10 - 滚动
  • JavaScript 是如何工作的:WebRTC 和对等网络的机制!
  • JAVA多线程机制解析-volatilesynchronized
  • Java小白进阶笔记(3)-初级面向对象
  • js对象的深浅拷贝
  • Js实现点击查看全文(类似今日头条、知乎日报效果)
  • k8s如何管理Pod
  • Leetcode 27 Remove Element
  • React组件设计模式(一)
  • Selenium实战教程系列(二)---元素定位
  • Theano - 导数
  • 分类模型——Logistics Regression
  • 函数式编程与面向对象编程[4]:Scala的类型关联Type Alias
  • 回流、重绘及其优化
  • 简单基于spring的redis配置(单机和集群模式)
  • 经典排序算法及其 Java 实现
  • 类orAPI - 收藏集 - 掘金
  • 模型微调
  • 实习面试笔记
  • 听说你叫Java(二)–Servlet请求
  • 通过获取异步加载JS文件进度实现一个canvas环形loading图
  • 小而合理的前端理论:rscss和rsjs
  • 云栖大讲堂Java基础入门(三)- 阿里巴巴Java开发手册介绍
  • d²y/dx²; 偏导数问题 请问f1 f2是什么意思
  • mysql面试题分组并合并列
  • Prometheus VS InfluxDB
  • (4) PIVOT 和 UPIVOT 的使用
  • (arch)linux 转换文件编码格式
  • (libusb) usb口自动刷新
  • (NSDate) 时间 (time )比较
  • (Redis使用系列) Springboot 在redis中使用BloomFilter布隆过滤器机制 六
  • (zhuan) 一些RL的文献(及笔记)
  • (超详细)语音信号处理之特征提取
  • (二)PySpark3:SparkSQL编程
  • (二十三)Flask之高频面试点
  • (分布式缓存)Redis哨兵