多线程基础:线程通信内容补充
多线程基础:线程通信内容补充
文章目录
- 多线程基础:线程通信内容补充
- 前言
- 一、wait(), notify(), notifyAll()
- 二、join()
- 三、Lock 和 Condition
- 四、并发集合和原子变量
- 1、并发集合
- 2、原子变量
- 总结
前言
前文内容中讲了线程通信的内容,但是不够完善,所以这边文章是针对那部分的内容的一个补充说明。
在Java中,线程之间的通信主要有几种方式,包括使用共享变量、wait()/notify()/notifyAll()方法、join()方法、Lock和Condition接口,以及并发集合和原子变量等。
一、wait(), notify(), notifyAll()
这些方法属于Object类,用于在同步块或同步方法中实现线程间的通信。
- wait(): 使当前线程等待,直到其他线程调用此对象的notify()或notifyAll()方法。
- notify(): 唤醒在此对象监视器上等待的单个线程。
- notifyAll(): 唤醒在此对象监视器上等待的所有线程。
public class WaitNotifyExample { private static final Object lock = new Object(); private static boolean ready = false; public static void main(String[] args) { Thread t1 = new Thread(() -> { synchronized (lock) { while (!ready) { try { lock.wait(); } catch (InterruptedException e) { e.printStackTrace(); } } System.out.println("Thread 1 is running"); } }); Thread t2 = new Thread(() -> { try { Thread.sleep(1000); } catch (InterruptedException e) { e.printStackTrace(); } synchronized (lock) { ready = true; lock.notifyAll(); } }); t1.start(); t2.start(); }
}
在这个例子中,线程1先获取到lock锁,然后开始循环,在第一次循环就调用了wait()方法,使线程进入等待状态,也就释放了锁,cpu时间片切到线程2,线程2获取到锁之后,讲ready设置为true同时唤醒其他所有线程,线程1进行运行状态,重新进行遍历判断,此时判断内容为false,所以线程1执行结束。
二、join()
join()方法是Thread类的一个方法,它使当前执行线程等待,直到调用join()方法的线程执行完毕。
public class JoinExample { public static void main(String[] args) throws InterruptedException { Thread t1 = new Thread(() -> { for (int i = 0; i < 5; i++) { System.out.println("Thread 1: " + i); try { Thread.sleep(500); } catch (InterruptedException e) { e.printStackTrace(); } } }); t1.start(); t1.join(); // 等待t1线程执行完毕 for (int i = 0; i < 5; i++) { System.out.println("Main thread: " + i); } }
}
在这个例子中,主线程会等待线程t1执行完毕后再继续执行。
三、Lock 和 Condition
Lock接口及其实现(如ReentrantLock)以及Condition接口提供了比synchronized和wait()/notify()更灵活和强大的线程同步机制。
import java.util.concurrent.locks.Condition;
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock; public class LockConditionExample { private final Lock lock = new ReentrantLock(); private final Condition condition = lock.newCondition(); private boolean ready = false; public void waitForSignal() throws InterruptedException { lock.lock(); try { while (!ready) { condition.await(); // 等待信号 } System.out.println("Received signal"); } finally { lock.unlock(); } } public void signal() { lock.lock(); try { ready = true; condition.signalAll(); // 发送信号 } finally { lock.unlock(); } } public static void main(String[] args) throws InterruptedException { LockConditionExample example = new LockConditionExample(); Thread t1 = new Thread(example::waitForSignal); t1.start(); Thread.sleep(1000); // 让t1先开始执行并等待 example.signal(); // 发送信号给t1 }
}
在这个例子中,waitForSignal方法中的线程会等待signal方法发送信号。
四、并发集合和原子变量
1、并发集合
Java的java.util.concurrent包提供了许多线程安全的集合类,如ConcurrentHashMap、CopyOnWriteArrayList等。这些集合内部实现了必要的同步机制,使得多个线程可以安全地并发访问它们。
import java.util.concurrent.ConcurrentHashMap; public class ConcurrentHashMapExample { private static final ConcurrentHashMap<String, Integer> map = new ConcurrentHashMap<>(); public static void main(String[] args) { Thread t1 = new Thread(() -> { map.put("key1", 1); System.out.println("Thread 1 put key1: " + map.get("key1")); }); Thread t2 = new Thread(() -> { map.put("key2", 2); System.out.println("Thread 2 put key2: " + map.get("key2")); }); t1.start(); t2.start(); }
}
在这个例子中,两个线程可以并发地向ConcurrentHashMap中添加元素,而无需添加额外的同步锁。
2、原子变量
原子变量类(如AtomicInteger、AtomicLong、AtomicBoolean等)提供了在并发编程中原子地更新变量的方法。原子操作是不可中断的,即在多线程环境下,当一个线程在执行原子操作时,其他线程无法访问该变量,从而保证了线程安全。
import java.util.concurrent.atomic.AtomicInteger; public class AtomicIntegerExample { private static final AtomicInteger counter = new AtomicInteger(0); public static void main(String[] args) throws InterruptedException { Thread t1 = new Thread(() -> { for (int i = 0; i < 5; i++) { counter.incrementAndGet(); // 原子地增加计数器的值 System.out.println("Thread 1 counter: " + counter.get()); } }); Thread t2 = new Thread(() -> { for (int i = 0; i < 5; i++) { counter.incrementAndGet(); // 原子地增加计数器的值 System.out.println("Thread 2 counter: " + counter.get()); } }); t1.start(); t2.start(); t1.join(); t2.join(); System.out.println("Final counter value: " + counter.get()); }
}
在这个例子中,两个线程都尝试原子地增加同一个AtomicInteger的值,无需额外的同步。
总结
- wait()/notify()/notifyAll()是基于对象监视器的传统线程通信方式,需要配合synchronized关键字使用。
- join()用于让一个线程等待另一个线程完成其执行。
- Lock和Condition提供了更灵活和强大的线程同步机制,能够更精细地控制线程间的通信和协作。
- 并发集合和原子变量简化了多线程编程中的同步问题,使得开发者能够更轻松地编写线程安全的代码。
在选择使用哪种线程通信方式时,需要根据具体的场景和需求来决定。例如,对于简单的等待/通知场景,wait()/notify()可能足够;对于需要更精细控制的场景,Lock和Condition可能更合适;而对于只需要原子更新变量的场景,原子变量类则是最简单的选择。
相关文章:
多线程基础:线程通信内容补充
多线程基础:线程通信内容补充 文章目录 多线程基础:线程通信内容补充前言一、wait(), notify(), notifyAll()二、join()三、Lock 和 Condition四、并发集合和原子变量1、并发集合2、原子变量 总结 前言 前文内容中讲了线程通信的内容,但是不…...
使用Jenkins打包时执行失败,但手动执行没有问题如ERR_ELECTRON_BUILDER_CANNOT_EXECUTE
具体错误信息如: Error output: Plugin not found, cannot call UAC::_ Error in macro _UAC_MakeLL_Cmp on macroline 2 Error in macro _UAC_IsInnerInstance on macroline 1 Error in macro _If on macroline 9 Error in macro FUNCTION_INSTALL_MODE_PAGE_FUNC…...
OpenCV图像滤波、边缘检测
OpenCV图像滤波 一、引言 在数字图像处理中,滤波是一种重要的技术,用于消除图像中的噪声、改善图像质量或提取特定信息。OpenCV(开源计算机视觉库)提供了丰富的滤波函数,可以方便地对图像进行各种滤波操作。本文将介…...
前端项目在本地localhost可以调取到拍照或麦克风等设备,但是在局域网内IP+端口号访问项目时访问不到设备
前端项目在本地localhost可以调取到拍照或麦克风等设备,但是在局域网内IP端口号访问项目时访问不到设备,调取navigation.mediaDevices时本科可以获取到mediaDevices列表,局域网内ip端口访问时获取不到mediaDevices。 原因: 存在…...
flutter生成二维码并截图保存到图库
引入库:flutter_screenutil、image_gallery_saver、qr_flutter弹窗布局 import dart:async; import dart:typed_data; import package/generated/l10n.dart; import package:jade/configs/PathConfig.dart; import package:jade/utils/ImageWaterMarkUtil.dart; im…...
EasyExcel Converter实现java对象和excel单元格转换
在EasyExcel中,Converter接口用于定义如何在Java对象和Excel单元格之间进行转换。 也就是说EasyExcel可以根据数据库中的值来填充Excel中对应的文本内容。 比如数据库1,2,3可以填充到excel中:男,女,其他 使用easyExcel的之前&a…...
stamac Ethernet DTS配置
目录 Demo 配置 compatible reg interrupts & interrupt-names phy-mode phy-handle Snps,reset-gpio...
Svg Flow Editor 原生svg流程图编辑器(四)
系列文章 Svg Flow Editor 原生svg流程图编辑器(一) Svg Flow Editor 原生svg流程图编辑器(二) Svg Flow Editor 原生svg流程图编辑器(三) Svg Flow Editor 原生svg流程图编辑器(四…...
Verilog语法之assign语句学习
assign语法主要是对组合逻辑的变量进行赋值的,就是把一个变量赋值给另一个变量,被复制的变量必须是wire类型的参数。 从仿真结果可以看出,data_in变量的值赋值给了data_out,assign语法就是赋值没有任何延迟,data_in是什么值&#…...
Cocos2dx-lua ScrollView[三]高级篇
一.概述 本文缩写说明:sv ScrollView, cell代表ScrollView的一个子节点 本文介绍sv的一种封装类库,来实现快速创建sv,有如下几个优点: 1.item的位置通过参数控制,提高开发效率 2.免去了调用sv的API,提…...
后端之卡尔曼滤波
后端之卡尔曼滤波 前言 在很久之前,人们刚结束信息传递只能靠信件的时代,通信技术蓬勃发展,无线通信和有线通信走进家家户户,而著名的贝尔实验室就在这个过程做了很多影响深远的研究。为了满足不同电路和系统对信号的需求&#…...
Docker 夺命连环 15 问
目录 什么是Docker? Docker的应用场景有哪些? Docker的优点有哪些? Docker与虚拟机的区别是什么? Docker的三大核心是什么? 如何快速安装Docker? 如何修改Docker的存储位置? Docker镜像常…...
2024最新版克魔助手抓包教程(9) - 克魔助手 IOS 数据抓包
引言 在移动应用程序的开发中,了解应用程序的网络通信是至关重要的。数据抓包是一种很好的方法,可以让我们分析应用程序的网络请求和响应,了解应用程序的网络操作情况。克魔助手是一款非常强大的抓包工具,可以帮助我们在 Android …...
Spring Boot 防止XSS攻击
XSS 跨站脚本工具(cross 斯特scripting),为不和层叠样式表(cascading style sheets,CSS)的缩写混淆,故将跨站脚本攻击缩写为XSS。恶意攻击者往web页面里插入恶意ScriptScript代码,当用户浏览该页…...
aidl文件生成Java、C++[android]、C++[ndk]、Rust接口
目录 前言一、Java二、C[android]三、C[ndk]四、Rust接口 前言 在 Android 开发中,AIDL 文件通常会被自动编译,生成对应语言的接口文件。对于应用层 Java 开发者来说,使用 AIDL 和 Binder 封装的接口可以让他们更加专注于应用逻辑࿰…...
多源统一视频融合可视指挥调度平台VMS/smarteye系统概述
系统功能 1. 集成了视频监控典型的常用功能,包括录像(本地录像、云端录像(录像计划、下载计划-无线导出)、远程检索回放)、实时预览(PTZ云台操控、轮播、多屏操控等)、地图-轨迹回放、语音对讲…...
PyTorch简介:与TensorFlow的比较
PyTorch简介:与TensorFlow的比较 一、PyTorch框架概述 PyTorch是一个开源的机器学习库,广泛用于计算机视觉和自然语言处理。由Facebook的人工智能研究团队开发,它以其灵活性和动态计算图而闻名。 主要特点 动态计算图:PyTorch…...
虚拟机-从头配置Ubuntu18.04(包括anaconda,cuda,cudnn,pycharm,ros,vscode)
最好先安装anaconda后cuda和cudnn,因为配置环境的时候可能conda会覆盖cuda的路径(不确定这种说法对不对,这里只是给大家的建议) 准备工作: 1.Ubuntu18.04,x86_64,amd64 虚拟机下载和虚拟机Ubu…...
uniApp使用XR-Frame创建3D场景(8)粒子系统
上篇文章讲述了如何将XR-Frame作为子组件集成到uniApp中使用 本片我们详细讲解一下xr-frame的粒子系统 先看源码 <xr-scene render-system"alpha:true" bind:ready"handleReady"> <xr-node visible"{{sec8}}"><xr-asset-load t…...
【JMeter入门】—— JMeter介绍
1、什么是JMeter Apache JMeter是Apache组织开发的基于Java的压力测试工具,用于对软件做压力测试。它最初被设计用于Web应用测试,但后来扩展到其他测试领域。 (Apache JMeter是100%纯JAVA桌面应用程序)Apache JMeter可以用于对静…...
CTF show Web 红包题第六弹
提示 1.不是SQL注入 2.需要找关键源码 思路 进入页面发现是一个登录框,很难让人不联想到SQL注入,但提示都说了不是SQL注入,所以就不往这方面想了 先查看一下网页源码,发现一段JavaScript代码,有一个关键类ctfs…...
逻辑回归:给不确定性划界的分类大师
想象你是一名医生。面对患者的检查报告(肿瘤大小、血液指标),你需要做出一个**决定性判断**:恶性还是良性?这种“非黑即白”的抉择,正是**逻辑回归(Logistic Regression)** 的战场&a…...
python/java环境配置
环境变量放一起 python: 1.首先下载Python Python下载地址:Download Python | Python.org downloads ---windows -- 64 2.安装Python 下面两个,然后自定义,全选 可以把前4个选上 3.环境配置 1)搜高级系统设置 2…...
令牌桶 滑动窗口->限流 分布式信号量->限并发的原理 lua脚本分析介绍
文章目录 前言限流限制并发的实际理解限流令牌桶代码实现结果分析令牌桶lua的模拟实现原理总结: 滑动窗口代码实现结果分析lua脚本原理解析 限并发分布式信号量代码实现结果分析lua脚本实现原理 双注解去实现限流 并发结果分析: 实际业务去理解体会统一注…...
WordPress插件:AI多语言写作与智能配图、免费AI模型、SEO文章生成
厌倦手动写WordPress文章?AI自动生成,效率提升10倍! 支持多语言、自动配图、定时发布,让内容创作更轻松! AI内容生成 → 不想每天写文章?AI一键生成高质量内容!多语言支持 → 跨境电商必备&am…...
Axios请求超时重发机制
Axios 超时重新请求实现方案 在 Axios 中实现超时重新请求可以通过以下几种方式: 1. 使用拦截器实现自动重试 import axios from axios;// 创建axios实例 const instance axios.create();// 设置超时时间 instance.defaults.timeout 5000;// 最大重试次数 cons…...
大学生职业发展与就业创业指导教学评价
这里是引用 作为软工2203/2204班的学生,我们非常感谢您在《大学生职业发展与就业创业指导》课程中的悉心教导。这门课程对我们即将面临实习和就业的工科学生来说至关重要,而您认真负责的教学态度,让课程的每一部分都充满了实用价值。 尤其让我…...
使用 SymPy 进行向量和矩阵的高级操作
在科学计算和工程领域,向量和矩阵操作是解决问题的核心技能之一。Python 的 SymPy 库提供了强大的符号计算功能,能够高效地处理向量和矩阵的各种操作。本文将深入探讨如何使用 SymPy 进行向量和矩阵的创建、合并以及维度拓展等操作,并通过具体…...
rnn判断string中第一次出现a的下标
# coding:utf8 import torch import torch.nn as nn import numpy as np import random import json""" 基于pytorch的网络编写 实现一个RNN网络完成多分类任务 判断字符 a 第一次出现在字符串中的位置 """class TorchModel(nn.Module):def __in…...
【从零开始学习JVM | 第四篇】类加载器和双亲委派机制(高频面试题)
前言: 双亲委派机制对于面试这块来说非常重要,在实际开发中也是经常遇见需要打破双亲委派的需求,今天我们一起来探索一下什么是双亲委派机制,在此之前我们先介绍一下类的加载器。 目录 编辑 前言: 类加载器 1. …...
