【JavaEE】多线程（7）

一、JUC的常见类

JUC→java.util.concurrent，放了和多线程相关的组件

1.1 Callable 接口

看以下从计算从1加到1000的代码：

public class Demo {public static int sum;public static void main(String[] args) throws InterruptedException {Thread t = new Thread(new Runnable() {@Overridepublic void run() {int result = 0;for (int i = 1; i <= 1000; i++) {result += i;}sum = result;}});t.start();t.join();System.out.println(sum);}
}

通过成员变量的方式才能得到线程中任务的最终执行结果，这样会增加代码的耦合性，当改变外部的sum，线程内的sum也要改，所以引入Callable接口

public class Demo {public static void main(String[] args) throws InterruptedException, ExecutionException {Callable<Integer> callable = new Callable<Integer>() {@Overridepublic Integer call() throws Exception {int result = 0;for (int i = 1; i <= 1000; i++) {result += i;}return result;}};FutureTask<Integer> futureTask = new FutureTask<>(callable);Thread t = new Thread(futureTask);t.start();t.join();System.out.println(futureTask.get());}
}

总结：

  1. Callable接口也用来描述一个任务，其中的call方法可以设置返回值将任务执行结果返回
  2. Runnable接口可以用来描述一个任务，但run方法的返回类型为void，无法返回任务结果
  3. callable需要经过FutureTask封装一下才能传入Thread构造方法，否则编译报错

至此创建线程有5种方式：

  1. 继承Thread
  2. 使用Runnable
  3. 使用lambda表达式
  4. 使用线程池/ThreadFactory
  5. 使用Callable接口

2.2 ReentrantLock

ReentrantLock 是可重入锁，它将加锁和解锁两个操作进行了区分，提供了加锁：lock()方法 和解锁：unlock()方法

public class Demo {public static void main(String[] args) {ReentrantLock locker = new ReentrantLock();locker.lock();locker.unlock();}
}

其实这样并不好，因为在加锁和解锁之间可能会存在很多逻辑，假如在解锁之前就通过return返回了，或者抛出了异常，这样走不到解锁，所以一般将unlock写到finally中，finally中的代码无论如何都会被执行

public class Demo {public static void main(String[] args) {ReentrantLock locker = new ReentrantLock();try {locker.lock();} finally {locker.unlock();}}
}

synchronized也是可重入锁，那ReentrantLock相比于synchronized有哪些其他价值？

  1. ReentrantLock 提供了公平锁，向ReentrantLock的构造方法里传入true，就是公平锁，ReentrantLock locker = new ReentrantLock(true);
  2. ReentrantLock提供了tryLock()操作，当尝试加锁，如果所以经被获取了，则返回操作失败，tryLock()还提供了带时间参数版本，可以等待一定时间，时间到了再返回操作失败
  3. synchronized搭配wait notify等待通知机制，ReentrantLock搭配Condition类完成等待通知，Condition可以指定线程唤醒

1.3 信号量 Semaphore

信号量就是一个计数器，描述了可用资源的个数，有两个核心操作：

  • P操作：计数器 -1，申请资源→acquire()
  • V操作：计数器 +1，释放资源→release()
public class Demo {public static void main(String[] args) throws InterruptedException {Semaphore semaphore = new Semaphore(3);semaphore.acquire();semaphore.acquire();semaphore.acquire(); //最多申请3次//semaphore.acquire(); // 这里会进行阻塞, 直到有线程执行release为止semaphore.release(); //释放一个后, 就不会阻塞了semaphore.acquire();}
}

将信号量设为1，其作用就等价于一个锁，当一个线程申请资源后，另外一个线程再申请，就会进入阻塞，直到第一个线程释放资源

public class Demo {public static int count = 0;public static void main(String[] args) throws InterruptedException {Semaphore semaphore = new Semaphore(1);Thread t1 = new Thread(() -> {try {for (int i = 0; i < 50000; i++) {semaphore.acquire();count++;semaphore.release();}} catch (InterruptedException e) {throw new RuntimeException(e);}});Thread t2 = new Thread(() -> {try {for (int i = 0; i < 50000; i++) {semaphore.acquire();count++;semaphore.release();}} catch (InterruptedException e) {throw new RuntimeException(e);}});t1.start();t2.start();t1.join();t2.join();System.out.println("count = "+ count);}
}

1.4 CountDownLatch

当我们把一个任务拆分成多个的时候，当所有的任务（线程）都执行完后将结果合并，此时就可以使用这个工具类来识别所有线程是否都执行完了

public class Demo18 {public static void main(String[] args) throws InterruptedException {CountDownLatch latch = new CountDownLatch(10); // 配合下面的countDown 和 awaitfor (int i = 0; i < 10; i++) {int id = i;Thread t = new Thread(() -> {System.out.println("线程开始 "+ id);try {Thread.sleep(3000);} catch (InterruptedException e) {throw new RuntimeException(e);}System.out.println("线程结束 "+ id);latch.countDown(); //每个线程执行完都执行一次countDown});t.start();}latch.await(); // 所有线程都执行完countDown 后再往下执行，否则这里阻塞等待System.out.println("所有线程执行结束");}
}

二、集合类的线程安全问题

Vector、Stack、HashTable这三个集合类是线程安全的，因为它们的方法都被synchronized修饰

2.1 多线程使用ArrayList

1）自己使用线程同步机制，加上synchronized或ReentrantLock

2）使用Collections.synchronizedList (new ArrayList)；synchronizedList是一个基于synchronized的List，synchronizedList的关键操作上都带有synchronized

3）使用CopyOnWriteArrayList——写时拷贝；当我们向一个容器中插入元素时，会将原容器拷贝出一份新容器，往新容器里插入元素，插入完毕后，将原容器的引用指向新容器

写时拷贝的好处：解决线程安全问题，当在修改时，许多线程也在读，通过写时拷贝的处理，让线程只能在原容器读，在新容器写，写完后，原容器的引用指向新容器

2.2 多线程使用哈希表

HashMap 本身是线程不安全的，在多线程环境下可以使用：Hashtable 或 ConcurrentHashMap

1）Hashtable

在一些关键操作上加上synchronized，这相当于直接针对Hashtable对象本身加锁

  • 多线程访问同一个Hashtable就会造成锁冲突，一个线程使用Hashtable中的关键方法时都会使其他要使用Hashtable的线程进入阻塞
  • Hashtable 一旦触发扩容，就让触发扩容的线程完成整个扩容，效率非常低，因为涉及到大量元素的拷贝

2）ConcurrentHashMap

 ConcurrentHashMap做了一些优化

1）在加锁方式上，使用"锁桶"的方式来代替一把"全局锁"，ConcurrentHashMap在哈希表中的每一个链表都加上了锁

这样当两个不同的线程操作不同的链表的时候不会产生锁冲突，这样加了锁而且链表的个数通常很多，大部分情况都不会产生锁冲突，synchronized不产生锁冲突就是个偏向锁

2）size是真个哈希表的属性，不同的线程在执行插入或删除元素时会涉及到多个线程修改同一个变量，所以采用CAS的方式修改size，避免了加锁操作

【注意】这里不要和Hashtable搞混，Hashtable是一把全局锁，一个线程像哈希表中插入元素时，其他线程都在阻塞等待，直到插入完，所以不会涉及到多个线程修改size的情况；但ConcurrentHashMap 是锁桶的方式加锁，针对每个链表加锁，所以会有多个线程同一个时间段插入的情况，那么多个线程修改size的情况就不可避免，因此这里采用CAS的方式修改size

3）ConcurrentHashMap 针对扩容操作做了特殊优化，Hashtable是在触发扩容时，直接在那个线程的put方法里完成整个扩容，而ConcurrentHashMap在扩容会搞一个新数组，这个数组的容量是扩容后的容量

接下来要把旧数组中的数据拷贝到新数组中，但并不是一次性拷贝完，而是在之后，每次有线程进行哈希表的基本操作时，都会把一部分数据从旧数组搬运到新数组

在搬运的过程中：

  • 插入：在新的数组插入
  • 删除：新旧数组都要删除
  • 查找：新就数组都要查找

🙉到此，多线程的篇章全部结束

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

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

相关文章

Linux-实用操作

Linux-实用操作

文章目录 一. 各类实用小技巧(快捷键)1. ctrl c 强制停止2. ctrl d 退出登出3. history 查看历史命令4. !命令前缀&#xff0c;自动匹配上一个命令5. ctrl r&#xff0c;搜索历史命令6. ctrl a | e&#xff0c;光标移动到命令开始或结束7. ctrl ← | →&#xff0c;左右跳…
阅读更多...
李飞飞首个“空间智能”模型发布：一张图，生成一个3D世界 | LeetTalk Daily

李飞飞首个“空间智能”模型发布：一张图，生成一个3D世界 | LeetTalk Daily

“LeetTalk Daily”&#xff0c;每日科技前沿&#xff0c;由LeetTools AI精心筛选&#xff0c;为您带来最新鲜、最具洞察力的科技新闻。 在人工智能技术迅速发展的背景下&#xff0c;李飞飞创立的世界实验室于近期发布了首个“空间智能”模型&#xff0c;这一创新成果引发了3D生…
阅读更多...
C语言程序设计P5-3【应用函数进行程序设计 | 第三节】——知识要点：函数的嵌套调用和递归调用

C语言程序设计P5-3【应用函数进行程序设计 | 第三节】——知识要点：函数的嵌套调用和递归调用

知识要点&#xff1a;函数的嵌套调用和递归调用 视频 目录 一、任务分析 二、必备知识与理论 三、任务实施 一、任务分析 本任务要求用递归法求 n!。 我们知道n!n(n-1)(n-2)……1n(n-1)!递归公式为&#xff1a; 1.上面公式分解为n!n(n-1)!&#xff0c;即将求n!的问题变为…
阅读更多...
css部分

css部分

前面我们学习了HTML&#xff0c;但是HTML仅仅只是做数据的显示&#xff0c;页面的样式比较简陋&#xff0c;用户体验度不高&#xff0c;所以需要通过CSS来完成对页面的修饰&#xff0c;CSS就是页面的装饰者&#xff0c;给页面化妆&#xff0c;让它更好看。 1 层叠样式表&#…
阅读更多...
单片机的中断系统

单片机的中断系统

作者简介 彭煜轩&#xff0c;男&#xff0c;银川科技学院计算机与人工智能学院&#xff0c;2022级计算机与科学技术8班本科生&#xff0c;单片机原理及应用课程第3组。 指导老师&#xff1a;王兴泽 电子邮件&#xff1a;1696409709qq.com 前言 本篇文章是参考《单片机原理…
阅读更多...
【技巧】Mac上如何显示键盘和鼠标操作

【技巧】Mac上如何显示键盘和鼠标操作

在制作视频教程时&#xff0c;将键盘和鼠标的操作在屏幕上显示出来&#xff0c;会帮助观众更容易地理解。 推荐Mac上两款开源的小软件。 1. KeyCastr 这款工具从2009年至今一直在更新中。 https://github.com/keycastr/keycastr 安装的话&#xff0c;可以从Github上下载最…
阅读更多...
ARM架构-Cache的底层原理

ARM架构-Cache的底层原理

在主存与处理器之间加入一个小容量的存储器保存 CPU 最近一段时间内的历史访问数据&#xff0c;将在 CPU 发起访问的时候优先提供数据快速访问&#xff0c;这个介于 CPU 与主存储器之间的小容量高速存储空间我们称之为 Cache&#xff0c;即高速缓存。Cache 作为处理器与主存之间…
阅读更多...
Flutter：商品多规格内容总结，响应式数据，高亮切换显示。

Flutter：商品多规格内容总结，响应式数据，高亮切换显示。

如图所示&#xff1a; 代码为练习时写的项目&#xff0c;写的一般&#xff0c;功能实现了&#xff0c;等以后再来优化。 自己模拟的数据结构 var data {id:1,name:精品小米等多种五谷杂粮精品小等多种五谷杂粮,logo:https://cdn.uviewui.com/uview/swiper/1.jpg,price:100.5…
阅读更多...
团队管理中如何做好目标管理

团队管理中如何做好目标管理

团队管理中的目标管理是确保团队高效运行的核心要素之一。 在目标管理中&#xff0c;清晰的目标设定、合理的资源分配、实时的跟踪与反馈机制是成功的关键。首先&#xff0c;设定SMART目标&#xff08;具体、可衡量、可达成、相关性强、时间限定&#xff09;能够有效聚焦团队的…
阅读更多...
Unity在运行状态下，当物体Mesh网格发生变化时，如何让MeshCollider碰撞体也随之实时同步变化？

Unity在运行状态下，当物体Mesh网格发生变化时，如何让MeshCollider碰撞体也随之实时同步变化？

旧版源代码地址&#xff1a;https://download.csdn.net/download/qq_41603955/90087225?spm1001.2014.3001.5501 旧版效果展示&#xff1a; 新版加上MeshCollider后的效果&#xff1a; 注意&#xff1a;在Unity中&#xff0c;当你动态地更改物体的Mesh时&#xff0c;通常期望…
阅读更多...
Blender导入下载好的fbx模型像的骨骼像针戳/像刺猬

Blender导入下载好的fbx模型像的骨骼像针戳/像刺猬

为什么我下载下来的骨骼模型和我自己绑定的模型骨骼朝向完全不一样 左边是下载的模型 右边是我自己绑定的模型 左边的模型刚刚感觉都是像针一样往外戳的&#xff0c;像刺猬一样那种。 解决方法勾选自动骨骼坐标系
阅读更多...
基于Springboot+Vue的在线答题闯关系统

基于Springboot+Vue的在线答题闯关系统

基于SpringbootVue的在线答题闯关系统 前言&#xff1a;随着在线教育的快速发展&#xff0c;传统的教育模式逐渐向互联网教育模式转型。在线答题系统作为其中的一个重要组成部分&#xff0c;能够帮助用户通过互动式的学习方式提升知识掌握度。本文基于Spring Boot和Vue.js框架&…
阅读更多...
矿区新发现，改造明星profinet转profibus协议网关也有未来

矿区新发现，改造明星profinet转profibus协议网关也有未来

profinet转profibusDP协议网关&#xff0c;在矿区的一些老设备上&#xff0c;改造升级一定会遇到profibus无法通讯的情况&#xff0c;选择一个协议模块网关是性价比的首选&#xff0c;下面介绍一下协议网关的一些指标 PROFINET 在 PROFIBUS 一侧为 PROFIBUS DP 从站&#xff0…
阅读更多...
高效查找秘密武器一：位图

高效查找秘密武器一：位图

有这样的一个问题&#xff1a; 给40亿个不重复的无符号整数&#xff0c;没排过序。给一个无符号整数&#xff0c;如何快速判断一个数是否在这40亿个数 中。 那么我们一般会想到这样做的 1.遍历&#xff0c;时间复杂度O(n) 2.排序&#xff08;N*logN&#xff09;&#xff0c…
阅读更多...
《单片机原理及接口技术》(C51编程)(第三版)------张毅刚主编

《单片机原理及接口技术》(C51编程)(第三版)------张毅刚主编

1.整体框架&#xff1a;1-22题&#xff08;17-20为编程题分别源自数中的P98,P162,P177页&#xff09; 2.简答题部分&#xff1a; 3.计算题 4.程序题/编程题
阅读更多...
Vision Transformer (ViT) 基本原理

Vision Transformer (ViT) 基本原理

Vision Transformer (ViT) 基本原理 flyfish Vision Transformer (ViT) 是一种基于 Transformer 架构的计算机视觉模型 一、ViT 的基本原理 ViT 的核心思想是将一张图像视为一组序列&#xff0c;将其嵌入到 Transformer 的输入中&#xff0c;通过自注意力机制捕获全局上下文…
阅读更多...
工业异常检测-CVPR2024-新的3D异常数据合成办法和自监督网络IMRNet

工业异常检测-CVPR2024-新的3D异常数据合成办法和自监督网络IMRNet

论文&#xff1a;https://arxiv.org/pdf/2311.14897v3.pdf 项目&#xff1a;https://github.com/chopper-233/anomaly-shapenet 这篇论文主要关注的是3D异常检测和定位&#xff0c;这是一个在工业质量检查中至关重要的任务。作者们提出了一种新的方法来合成3D异常数据&#x…
阅读更多...
三款电容麦的对比

三款电容麦的对比

纸面参数 第一款麦克风 灵敏度: -36 dB 2 dB&#xff08;0 dB1V/Pa at 1 kHz&#xff09; 灵敏度较低&#xff0c;需要更高的增益来拾取同样的音量。频率响应: 40 Hz - 18 kHz 响应范围较窄&#xff0c;尤其在高频区域。等效噪音级: ≤18 dB&#xff08;A计权&#xff09; 噪…
阅读更多...
easyexcel 导出日期格式化

easyexcel 导出日期格式化

1.旧版本 在新的版本中formate已经被打上废弃标记。那么不推荐使用这种方式。 2.推荐方式 推荐使用另外一种方式【 Converter 】代码如下&#xff0c;例如需要格式化到毫秒【yyyy-MM-dd HH:mm:ss SSS】级别 创建一个公共Converter import com.alibaba.excel.converters.Conv…
阅读更多...
PPT怎样做的更加精美

PPT怎样做的更加精美

目录 PPT怎样做的更加精美 3D的GIF图片 3维空间图​编辑 结果有明显的对比 阅读高质量文献，采用他们的图 PPT怎样做的更加精美 3D的GIF图片 3维空间图 结果有明显的对比
阅读更多...
最新文章
推荐文章

Copyright @ 2022~2023