多线程(JUC, ReentrantLock, 原子类, 线程池, 信号量 Semaphore, CountDownLatch)

JUC

Java.util.concurrent 包, 存放了并发编程相关的组件, 目的是更好的支持高并发任务 (多线程只是实现并发编程的一种具体方式 …)


ReentrantLock

可重入互斥锁, 和 synchronized 定位类似, 用来实现互斥效果, 保证线程安全.

  • synchronized 对对象加锁, 保护临界资源
  • ReentreatLock 使用 lock 方法和 unlock 方法,加锁对象是 ReentrantLock 的实例

在这里插入图片描述

核心方法

  • lock(): 加锁, 获取不到锁就死等
  • trylock(超时时间):尝试加锁, 如果获取不到锁, 等待一段时间后就放弃加锁
  • unlock(): 解锁

ReentrantLock 使用

由于 reentreatLock 需要手动释放, 因此推荐 try finally 的写法

public class ReentreatLockDemo {public static void main(String[] args) {ReentrantLock reentrantLock = new ReentrantLock();
//        reentrantLock.lock();boolean ok = reentrantLock.tryLock();try {if(ok) {// do} else {// undo}} finally {reentrantLock.unlock();}}
}

ReentrantLock 和 synchronized 比较

  1. synchronized 是关键字, 是 JVM 内部实现的
    ReentrantLock 是标准库的一个类, 在 JVM 外实现 (基于 Java 实现)
  1. synchronized 是非公平锁
    ReentrantLock 默认是非公平锁, 但是提供了公平锁版本的实现
    ReentrantLock reentrantLock = new ReentrantLock(true);
  1. ReentrantLock 提供更灵活的加锁方式:
    ReentrantLock reentrantLock = new ReentrantLock(true);
    reentrantLock.tryLock();
  1. ReentrantLock 提供更强大, 更方便的等待通知机制
    synchronized 搭配 wait() notify()使用, notify() 是随机唤醒等待队列的线程
    ReentrantLock 搭配 Condition 类. 可以唤醒指定的线程

原子类

原子类内部用的是 CAS 实现, 更高效的解决了线程安全问题
原子类提供了线程安全的自增自减等操作


原子类有以下几种 :
在这里插入图片描述


原子类的常见方法 (以 AtomicInteger 为例)

在这里插入图片描述

public class Main {public static void main(String[] args) {AtomicInteger atomicInteger = new AtomicInteger();Scanner scanner = new Scanner(System.in);int x = scanner.nextInt();atomicInteger.getAndIncrement();// i++;atomicInteger.incrementAndGet();// ++i;atomicInteger.getAndDecrement();// i--;atomicInteger.decrementAndGet();// --i;atomicInteger.addAndGet(x);     // i+=x;atomicInteger.get();            // x}
}

线程池

之前写过, 挂个链接这里不再复制粘贴了 — https://editor.csdn.net/md/?articleId=136715895


信号量 Semaphore

信号量表示 "可用资源的个数" .本质上是一个计数器

Semaphore 提供了 P,V 操作
P 操作: 申请一个可用资源, 计数器 - 1
V 操作: 释放一个可用资源, 计数器 + 1

当可用资源个数为 0 时, 再进行 P 操作, 就会出现阻塞等待清空 (资源为零, 无法继续消耗了), 直到有线程让信号量大于零, 才会唤醒该阻塞的线程

锁 可可以视为计数器为 1 的信号量, 二元信号量

  • 锁是信号量的一种特殊情况
  • 信号量是锁的一般表达

总结: 信号量的表达含义范围更广


Semaphore 的简单使用
在这里插入图片描述


代码示例

public class Main {public static void main(String[] args) {// 参数是可用资源的个数(信号量的初始值)Semaphore semaphore = new Semaphore(4);for (int i=0;i<20;i++) {Thread t = new Thread(() -> {try {System.out.println("申请资源");semaphore.acquire();System.out.println("持有资源");Thread.sleep(1000);System.out.println("释放资源");semaphore.release();} catch (InterruptedException e) {e.printStackTrace();}});t.start();}}
}

运行结果
在这里插入图片描述

有兴趣可以仔细看看运行结果, 同一时刻最多只有 4个线程能够持有锁, 这就是信号量的存在意义


CountDownLatch

同时等待 N 个任务执行结束 (和 join() 功能类似)


在这里插入图片描述

核心API

  • await(): 阻塞等待线程, 直至任务全部完成
  • getCount(): 获取剩余未完成任务个数
  • countDown(): 未完成任务个数 -1

代码示例

public class CountDownLatchDemo {public static void main(String[] args) throws InterruptedException {// 参数代表需要等待的任务数量CountDownLatch countDownLatch = new CountDownLatch(5);for (int i = 0; i < 5; i++) {Thread t = new Thread(() -> {System.out.println("完成一个任务");// countDown() 方法, 代表完成一个任务countDownLatch.countDown();});t.start();Thread.sleep(1000);}// await()方法, 用于阻塞线程// 直至 countDownLatch 内任务全部完成, 才会往下继续走countDownLatch.await();System.out.println("任务全部完成");}
}

运行结果
在这里插入图片描述

运行过代码会发现, 每间隔一秒输出一次 “完成一个任务”, 5秒之后输出 “任务全部完成”

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

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

相关文章

Head First Design Patterns -适配器模式与外观模式

适配器模式 什么是适配器模式 适配器模式&#xff0c;将一个类的接口转换成客户期望的另一个接口。适配器让原本接口不兼容的类可以合作。 类图 代码 利用Enumeration来适配Iterator&#xff0c;外部只需要调用这个适配器&#xff0c;即可以像调用Iterator那样&#xff0c;…

vue3中使用cesium

vue3中使用cesium Cesium是一个开源的JavaScript库&#xff0c;专门用于创建3D地球和2D地图的Web应用程序。它提供了丰富的功能和工具&#xff0c;使得开发人员能够轻松地构建出高质量的地理空间可视化应用。 1. 安装cesium包 npm install cesium2. 复制node_modules中的Ces…

简单方便的录屏软件kazam

Kazam 是一个简单的屏幕录制程序&#xff0c;它将捕获屏幕内容并录制一个视频文件&#xff0c;该文件可以由任何支持 VP8/WebM 视频格式的视频播放器播放。 GitHub - henrywoo/kazam: Kazam - Linux Desktop Screen Recorder and Broadcaster 安装 Linux下安装 sudo apt in…

flutter 单列选择器

引入 flutter_pickers: ^2.1.9 import package:flutter_pickers/pickers.dart; import package:flutter_pickers/style/default_style.dart; import package:flutter_pickers/style/picker_style.dart;List<String> _numberList [99,98,97,96,95,94,93,92,91,90,89,88,…

pstree 进程树

pstree -aup a是所有all u是用户user p是pid进程号

排序算法:归并排序(非递归)

文章目录 一、非递归思路二、代码演示 先赞后看&#xff0c;养成习惯&#xff01;&#xff01;&#xff01;^ _ ^<3 ❤️ ❤️ ❤️ 码字不易&#xff0c;大家的支持就是我坚持下去的动力。点赞后不要忘了关注我哦&#xff01; 所属专栏:排序算法 一、非递归思路 步骤如下&…

Linux 一点查询资料

Linux 一点查询资料 Linux101 Linux入门教程 鸟哥的Linux私房菜 Harley Hahn’s Guide to Unix and Linux 文件管理 - cd, pwd, mkdir, rmdir, ls, cp, rm, mv, tar 文件检索 - cat, more, less, head, tail, file, find 输入输出控制 - 重定向, 管道, tee, xargs 文本处理 -…

他转行软件测试,一周已经拿了3个offer了,软件测试面试...

目录&#xff1a;导读 前言一、Python编程入门到精通二、接口自动化项目实战三、Web自动化项目实战四、App自动化项目实战五、一线大厂简历六、测试开发DevOps体系七、常用自动化测试工具八、JMeter性能测试九、总结&#xff08;尾部小惊喜&#xff09; 前言 自我介绍 自我介…

Linux系统资源管理

Linux系统资源命令 在Linux中查看系统资源常用命令有哪些 在Linux中&#xff0c;系统资源是指计算机硬件、软件和网络设备等可以利用的一切物质和能量。Linux中的系统资源包括&#xff1a; CPU&#xff08;中央处理器&#xff09;&#xff1a;用于处理计算机中的指令和数据的…

蓝桥练习题总结(一)字母图形、完美的代价、01串、序列求和

目录 一、字母图形 二、完美的代价 三、01字串 四、序列求和 一、字母图形 问题描述 利用字母可以组成一些美丽的图形&#xff0c;下面给出了一个例子&#xff1a; ABCDEFG BABCDEF CBABCDE DCBABCD EDCBABC 这是一个5行7列的图形&#xff0c;请找出这个图形的规律&#xff…

Vscode中关于Java的一些问题

前言 在使用Vscode的时候&#xff0c;总是会有这么一种感觉&#xff1a;有时得这样&#xff0c;有时得那样&#xff0c;这让我甚是困惑&#xff0c;于是写下来这篇解答文章 为什么java文件有时候会有class文件&#xff0c;有时候没有 在编写Java代码时&#xff0c;我会有一种…

2024年千万不要错过的创业项目,绝对可以改变你的生活!

现在的年轻人都比较喜欢创业&#xff0c;主要是因为这几年大环境不好。 钱不好挣了&#xff0c;打工挣的辛苦费无法满足日常的生活需求。 不仅要忍受无休止的加班&#xff0c;还要随时担心自己会不会被辞退。 所以创业就成了很多人想要改变现状最好的方法了。 其实很多人想…

Thinkphp+workman+redis实现多进程异步任务处理

前言 PHP本身并不直接支持多线程编程&#xff0c;因为PHP的设计初衷是作为一个脚本语言&#xff0c;主要面向的是Web开发。不过我们可以使用一些扩展和库来实现多进程的功能&#xff0c;提高系统性能&#xff0c;比如workerman和swoole。通过多进程异步执行任务。 安装workman…

Java-常见面试题收集(三)

八 集合 1 List,Set,Map 是否继承自 Collection 接口 List,Set 接口继承于 Collection 接口   Map 没有继承于 Collection 接口 2 List,Set,Map 三者的区别 ① List、Set 都是继承自 Collection 接口&#xff0c;Map 则不是 ② List 特点&#xff1a;元素有放入顺序&#x…

【C#】Conventions(惯例)最佳实践和准则

在C#中,Conventions(惯例)是指编写代码时的一套最佳实践和准则。这些惯例旨在提高代码的可读性、一致性和可维护性。虽然这些惯例不是语言的强制规则,但遵循它们可以使你的代码更加清晰和专业。 以下是一些常见的C#编码惯例: 命名约定: 使用有意义的、描述性的名称。类名和公…

P8711 [蓝桥杯 2020 省 B1] 整除序列 存疑解决篇 Python

[蓝桥杯 2020 省 B1] 整除序列 题目描述 有一个序列&#xff0c;序列的第一个数是 n n n&#xff0c;后面的每个数是前一个数整除 2 2 2&#xff0c;请输出这个序列中值为正数的项。 输入格式 输入一行包含一个整数 n n n。 输出格式 输出一行&#xff0c;包含多个整数…

Zinx框架的高级用法

一、使用框架提供的实用类 zinx框架已经提供了常用的IO通道类-TCP。 阅读Tcp相关类的使用文档&#xff0c;将之前的3个案例用TCP的方式实现。 步骤&#xff1a; 创建Tcp数据通道类继承ZinxTcpData&#xff0c;重写GetInputNextStage函数&#xff0c;内容跟之前标准输入通道类…

Mysql2-sql语句

一、MySQL数据库表操作 MySQL表的基本概念 在windows中有个程序叫做excel. 而Excel文件中存在了如sheet1、sheet2、sheet3的表, 所有的sheet都存储在这个Excel文件中, 在某个sheet中有相应的数据. 回到数据库和表的关系上来说, 这个Excel文件就是一个数据库, 所有的sheet就是…

基于SpringBoot和Vue的大学生租房系统的设计与实现

今天要和大家聊的是一款今天要和大家聊的是一款基于SpringBoot和Vue的大学生租房系统的设计与实现。 &#xff01;&#xff01;&#xff01; 有需要的小伙伴可以通过文章末尾名片咨询我哦&#xff01;&#xff01;&#xff01; &#x1f495;&#x1f495;作者&#xff1a;李同…

【C++】弥补C语言的不足(②有默认参数的函数)

&#x1f33b;缺省参数 我们先来看一个简单地例子&#xff0c;对于在函数的定义中三个形参都给定默认值&#xff1a; #include <iostream> using namespace std; void fun(int a 10, int b 20, int c 30) {cout << "a " << a << endl;…