ReentrantLock的阻塞性、可中断性

news2024/11/15 20:33:05

结论:

  • lock() 如果没有获取到锁,会一直阻塞并尝试获取锁,直到获取到锁。
  • lock() 获取到锁之前,其他线程不可以中断该线程。因为线程Thread如线程t2的interrupt方法,想要中断线程,但不会真的中断,只会把t2的中断标志改变,所以线程t2还会继续运行。
  • lockInterruptibly() 获取到锁之前,其他线程可以中断该线程。因为对interrupt标志进行了处理

 

lock()阻塞获取锁。如果获取不到锁,会一直阻塞,直到获取到锁

代码:

    static void main(String[] args) {
        ReentrantLock reentrantLock = new ReentrantLock();
        // t1先获取锁
        Thread t1 = new Thread(()->{
            try {
                reentrantLock.lock();
                System.out.println("t1获取到锁");
                try {
                    Thread.sleep(3000);
                } catch (InterruptedException e) {
                    System.out.println("t1报错");
                    throw new RuntimeException(e);
                }
            } finally {
                reentrantLock.unlock();
            }

            System.out.println("11释放锁");
        });
        System.out.println("t1 name :"+t1.getName());
        t1.start();
        // 测试重点。t2后获取锁。测试lock、lockInterruptibly方法
        Thread t2 = new Thread(()->{
            try {
                // 确保t先执行性
                Thread.sleep(1000);
            } catch (InterruptedException e) {
                System.out.println("t2报错");
                throw new RuntimeException(e);
            }
            try {
                long l = System.currentTimeMillis();
                reentrantLock.lock();
                long l1 = System.currentTimeMillis();
                System.out.println("t2等待获取锁的时间"+(l1-l));
            } finally {
                reentrantLock.unlock();
            }
        });
        System.out.println("t2 name :"+t2.getName());
        t2.start();
}

结果:

697a090a5bb245e8b31063117b27c9e3.png

 

lockInterruptibly()。获取锁前该线程可以被中断。

代码:在上面代码的基础上,lock换成lockInterruptibly,加了个t3线程(对t2进行中断操作)

    static void main(String[] args) {
        ReentrantLock reentrantLock = new ReentrantLock();
        // t1先获取锁
        Thread t1 = new Thread(()->{
            try {
                reentrantLock.lock();
                System.out.println("t1获取到锁");
                try {
                    Thread.sleep(3000);
                } catch (InterruptedException e) {
                    System.out.println("t1报错");
                    throw new RuntimeException(e);
                }
            } finally {
                reentrantLock.unlock();
            }

            System.out.println("11释放锁");
        });
        System.out.println("t1 name :"+t1.getName());
        t1.start();

        // 测试重点。t2后获取锁。测试lock、lockInterruptibly方法
        Thread t2 = new Thread(()->{
            try {
                // 确保t先执行性
                Thread.sleep(1000);
            } catch (InterruptedException e) {
                System.out.println("t2报错");
                throw new RuntimeException(e);
            }
            try {
                long l = System.currentTimeMillis();
                // reentrantLock.lock();
                reentrantLock.lockInterruptibly();
                long l1 = System.currentTimeMillis();
                System.out.println("t2等待获取锁的时间"+(l1-l));
            } catch (InterruptedException e) {
                System.out.println("t2获取锁失败,t2需要中断,t2要退出啦");
                throw new RuntimeException(e);
            } finally {
                reentrantLock.unlock();
            }
        });
        System.out.println("t2 name :"+t2.getName());
        t2.start();

        // 用来中断t2的
        Thread t3 = new Thread(()->{
            try {
                Thread.sleep(2000);
            } catch (Exception e) {
                System.out.println("t3报错");
                throw new RuntimeException(e);
            }
            t2.interrupt();
            System.out.println("t3中断t2了");
        });
        System.out.println("t3 name :"+t3.getName());
        t3.start();
    }

结果:3d4e52105f6149bd81ca7094c64d2019.png

 

如果t2没用lockInterruptibly(),而是用lock()。t3中断t2是中断不了的,因为interrupt方法只是打个标记,不会真的去中断方法。lock()针对这种打标记没做处理,所以t2会继续运行

结果如下:

e6fb2ae29fdc4113b9fe524ff938d44d.png

 

 

 

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.coloradmin.cn/o/1982151.html

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈,一经查实,立即删除!

相关文章

如何把uniapp 项目发布成Andriod App的流程

1:点击HBuilderX 状态栏左侧的未登录按钮,弹出登录的对话框。 2: 在弹出的登录的对话框中, 填写账号和密码之后, 点击登录即可。 3: 打开项目根目录中的 mainfest.json 配置文件, 在基础配置的面板中, 获取uniapp 的应…

Redis2-Redis常见命令

目录 Redis数据结构介绍 Redis通用命令 KEYS DEL EXISTS EXPIRE String类型 Key的层级格式 Hash类型 List类型 Set类型 SortedSet类型 Redis数据结构介绍 Redis是一个key-value的数据库,key一般是String数据库,value的类型多种多样 可以通过…

SQL回顾

一、知识点回顾 1、数据库的分类。 ①关系型数据库。(磁盘、持久化) 例:MySQL(搭配php、java)。 ②非关系型数据库。(暂存、存在内存中) 例:sql server(搭配.net&…

四、图片生成视频

具体步骤 1、安装插件(VideoHelperSuite) 2、创建工作流 2.1 双击搜索svd 2.2 添加节点 2.3 选择clip视觉长按拖住生成checkpoint加载器 2.4 选择vae对应连接 2.4 选择图像添加加载图像节点 2.4 选择正面条件 选择k采样器节点新增 2.5 进行节点间的连接(模型 …

基于开源FFmpeg和SDL2.0的音视频解码播放和存储系统的实现

目录 1、FFMPEG简介 2、SDL简介 3、视频播放器原理 4、FFMPEG多媒体编解码库 4.1、FFMPEG库 4.2、数据类型 4.3、解码 4.3.1、接口函数 4.3.2、解码流程 4.4、存储(推送) 4.4.1、接口函数 4.4.2、存储流程 5、SDL库介绍 5.1、数据结构 5.…

西部菱斑响尾蛇教你基础IO

快学&#xff0c;再不学普洱就要超过你们了 在C阶段进行的文件操作有哪些呢&#xff1f; #include<stdio.h> #include<string.h>int main() {FILE* fp fopen("myfile", "w");if (!fp){printf("fopen error!\n");}const char* msg …

大模型系列:大模型tokenizer分词编码算法BPE理论简述和实践

关键词&#xff1a;大语言模型&#xff0c;分词&#xff0c;BPE&#xff0c;BBPE 前言 token是大模型处理和生成语言文本的基本单位&#xff0c;在之前介绍的Bert和GPT-2中&#xff0c;都是简单地将中文文本切分为单个汉字字符作为token&#xff0c;而目前LLaMA&#xff0c;Cha…

云原生高级必备基础

一.文件管理 相对路径和绝对路径 touch 创建文件 mkdir 创建目录 -p多级创建 rm 删除 -i 删除前逐一询问确认。 -f 即使原档案属性设为唯读&#xff0c;亦直接删除&#xff0c;无需逐一确认。 -r 将目录及以下之档案亦逐一删除。 cp 复制 -p -r mv 移动 cp和mv的区别 …

8月4号分析:CSGO市场行情如何,给几个操作建议

很多粉丝让我聊聊对近期CSGO饰品市场的看法&#xff0c;那今天就简单聊聊&#xff01; 最近的CSGO市场&#xff0c;从在线人数就可以看出来&#xff0c;这段时间是实打实的流失了很多玩家&#xff0c;就目前这个情况&#xff0c;120万的在线人数里面&#xff0c;至少还有10多万…

sql注入之无列名注入

目录 一、基础知识 二、平替information_schema库 三、无列名注入 3.1 正常无列名查询&#xff1a; 3.2 子查询&#xff1a; 3.3 实战 一、基础知识 我们在注入的过程中很多时候利用的就是information_schema这个库获取 table_schema table_name, column_name这些数据库内…

一键转换语言,五款强大文件翻译软件推荐!

在当今的职场环境中&#xff0c;跨语言沟通已成为常态。无论是与国际客户洽谈业务&#xff0c;还是处理海外项目报告&#xff0c;精准高效的文件翻译能力都是每位职场人士的必备技能。今天&#xff0c;我们就来盘点几款职场人士必备的文件翻译工具。 福昕在线翻译&#xff1a;…

PXE批量安装——————rhel7

实验前准备 什么是PXE&#xff1f; PXE是一种基于网络的启动技术&#xff0c;它集成了在计算机的BIOS或UEFI中&#xff0c;允许计算机从网络服务器下载并启动操作系统或其他软件。 应用场景 无盘工作站&#xff1a;在教育和科研机构中&#xff0c;无盘工作站通过PXE启动操作…

字符串切割split

let obj {} let str "aa占比:17.48%,aa计费占比:0.00%" let arr str.split(,) // [aa占比:17.48%,aa计费占比:0.00%] arr.forEach(item > { let [key,value] item.split(:) obj[key] value }) console.log(obj) //{aa占比: 17.48%, aa计费占比: 0.00%} con…

Markdown文本编辑器:Typora for Mac/win 中文版

Markdown 是一种轻量级的标记语言&#xff0c;它允许用户使用易读易写的纯文本格式编写文档。Typora 支持且仅支持 Markdown 语法的文本编辑&#xff0c;生成的文档后缀名为 .md。 这款软件的特点包括&#xff1a; 实时预览&#xff1a;Typora 的一个显著特点是实时预览&#x…

lombok安装成功但是找不到方法

2024.1.1版本的IDE的插件安装了默认的lombok&#xff08;如图1&#xff09;&#xff0c;pom文件中也引入了lombok的依赖&#xff0c;在实体类写了Data的注解&#xff0c;当调用实体类的get和set方法运行时&#xff0c;报错找不到相应的方法&#xff0c;但是在调用get、set方法的…

Java实现全局异常统一处理

Java实现全局异常统一处理 【一】介绍【二】为什么要使用全局异常处理【三】案例实现【1】GlobalException【2】GlobalExceptionHandler【3】使用 【一】介绍 全局异常处理器是一种在应用程序中几种处理异常的机制&#xff0c;它允许在应用程序的任何地方抛出异常时&#xff0…

2024年6月scratch图形化编程等级考试一级真题

202406 scratch编程等级考试一级真题 选择题&#xff08;共25题&#xff0c;每题2分&#xff0c;共50分&#xff09; 1、音乐Video Game1的时长将近8秒&#xff0c;点击一次角色&#xff0c;下列哪个程序不能完整地播放音乐两次 A、 B、 C、 D、 答案&#xff1a;D 考点分…

CasaOS系统小主机Docker部署memos结合内网穿透打造私有云笔记

文章目录 前言1. 使用Docker部署memos2. 注册账号与简单操作演示3. 安装cpolar内网穿透4. 创建公网地址5. 创建固定公网地址 前言 本文主要介绍如何在CasaOS轻NAS系统设备中使用Docker本地部署开源云笔记服务memos&#xff0c;并结合cpolar内网穿透工具配置公网地址&#xff0…

STL-queue容器适配器

目录 一、queue 1.1 使用 1.2 模拟实现 二、priority_queue 2.1 使用 2.2 仿函数 2.2.1 概念 2.2.2 使用 2.3 模拟实现 一、queue 1.1 使用 具体解释详见官方文档&#xff1a;queue - C Reference (cplusplus.com) queue就是数据结构中的队列&#xff1a;数据结构之…

体系结构论文导读(三十四):Design of Reliable DNN Accelerator with Un-reliable ReRAM

文章核心 这篇文章主要讨论了一种在不可靠的ReRAM&#xff08;阻变存储器&#xff09;设备上设计可靠的深度神经网络&#xff08;DNN&#xff09;加速器的方法。文章提出了两种关键技术来解决ReRAM固有的不可靠性问题&#xff1a;动态定点&#xff08;DFP&#xff09;数据表示…