java干货 线程间通信

文章目录

    • 一、线程间通信
      • 1.1 为什么要处理线程间通信?
      • 1.2 什么是等待唤醒机制?
    • 二、等待唤醒机制使用
      • 2.1 等待唤醒机制用到的方法
        • 2.1.1 wait
        • 2.1.2 notify
      • 2.2 线程通信代码实践
        • 2.2.1 重要说明
        • 2.2.2 代码

一、线程间通信

1.1 为什么要处理线程间通信?

  • 在默认情况下,cpu是默认切换线程来执行的,当我们需要多个线程共同来完成一个任务,希望他们按照一定的规律执行,那么就需要他们进行通信协调,以达到我们的目的
  • 其次,对于共享变量的访问,我们通常加上synchronized,存在锁的竞争,我们也可以使用等待唤醒机制,协调线程对变量的访问,保证数据的一致性

1.2 什么是等待唤醒机制?

说到线程,我们常提到线程之间的竞争,如多线程下锁的竞争。好比在公司里你和同事在晋升时的竞争,但是多数情况下,还是你们合作共同完成一些任务。也就是一个线程进行了一定操作后,进入等待状态(waiting),等待其他线程完成任务后将他唤醒(notify)。还有就是当需要等待多个线程时,可以使用notifyAll(),将等待中的线程全部唤醒

二、等待唤醒机制使用

2.1 等待唤醒机制用到的方法

2.1.1 wait
  • wait() 使当前线程进入等待状态,直到被其他线程使用 notify() 或 notifyAll() 唤醒,无限期等待,直到被唤醒。使用场景: 当线程需要等待某个条件变化时使用,无需考虑超时。
public final void wait() throws InterruptedException {wait(0L);}
  • wait(long timeoutMillis),本质上调用的还是这个native 方法
 public final native void wait(long timeoutMillis);
  • wait(long timeoutMillis, int nanos) 可以被其他线程调用 notify() 或 notifyAll() 来唤醒,也可以在超时后自动唤醒。
public final void wait(long timeoutMillis, int nanos) throws InterruptedException {if (timeoutMillis < 0) {throw new IllegalArgumentException("timeoutMillis value is negative");}if (nanos < 0 || nanos > 999999) {throw new IllegalArgumentException("nanosecond timeout value out of range");}if (nanos > 0 && timeoutMillis < Long.MAX_VALUE) {timeoutMillis++;}wait(timeoutMillis);}
2.1.2 notify
  • notify 是 Object 类的方法,任何对象都可以调用它。notify 方法用于唤醒一个在该对象的监视器上等待的线程。
  • notify() 适用于只需要唤醒一个等待线程的情况,如果有多个线程等待,随机唤醒一个
public final native void notify();
  • notifyAll() 唤醒对象监视器上所有等待的线程
public final native void notifyAll();

2.2 线程通信代码实践

2.2.1 重要说明
  • 等待和通知唤醒必须放在同步代码块
    是为了确保线程在进入等待状态和被唤醒时,对共享资源的访问是受控和一致的。这种机制保证了线程间的协调和通信是安全的,避免了竞争条件和数据不一致的问题。同步块保证了在任意时刻只有一个线程可以执行同步代码块中的代码,从而确保了线程间通信的正确性和一致性。
    举个例子,张三、李四、王五共同完成一个任务,要求张三先做,再到李四、最后王五,那么三个人就是三个线程,一个人在做任务的时候,其他人是不能动的。张三做完了,把执行权交给李四,并通知李四,李四执行完了,通知王五。
  • 调用wait,那么当前线程也就释放了锁,即交出执行权,线程进入WAITING 状态
  • wait 和 notify 必须由同一个锁对象调用。一个锁对象可以唤醒 由同一个锁对象调用wait 后的线程
  • wait 和 notify 是属于 Object 类的,锁对象可以是任意对象,其他类默认都是继承了Object类的
2.2.2 代码
  • 客人来了,张三洗菜、李四切菜、王五炒菜
public class Demo10 {private static final Object lock = new Object(); // 锁对象private static boolean vegetablesWashed = false; // 是否已经洗菜完成private static boolean vegetablesCut = false; // 是否已经切菜完成public static void main(String[] args) {new Thread(new Runnable() {@Overridepublic void run() {synchronized (lock){while (!vegetablesCut){try {System.out.println("王五等待李四切菜...");lock.wait(); // 李四没有切完菜,继续等} catch (InterruptedException e) {Thread.currentThread().interrupt();}}System.out.println("》》》》王五开始炒菜《《《《");try {Thread.sleep(1200);  // 模拟炒菜过程System.out.println("》》》王五炒菜完成《《《");lock.notifyAll();} catch (InterruptedException e) {e.printStackTrace();}}}},"王五线程").start();new Thread(new Runnable() {@Overridepublic void run() {synchronized (lock){while (!vegetablesWashed){try {System.out.println("李四等待张三洗菜...");lock.wait(); // 张三没有切完菜,继续等} catch (InterruptedException e) {Thread.currentThread().interrupt();}}System.out.println("======李四开始切菜======");try {Thread.sleep(1600);  // 模拟切菜过程vegetablesCut = true;System.out.println("===李四切完菜了===");lock.notifyAll(); // 通知王五炒菜} catch (InterruptedException e) {Thread.currentThread().interrupt();}}}},"李四线程").start();new Thread(new Runnable() {@Overridepublic void run() {synchronized (lock){System.out.println("----张三开始洗菜----");try {Thread.sleep(1500);  // 模拟洗菜过程vegetablesWashed = true;System.out.println("---张三洗完菜了---");lock.notifyAll();} catch (InterruptedException e) {e.printStackTrace();}}}},"张三线程").start();}
}
王五等待李四切菜...
李四等待张三洗菜...
----张三开始洗菜----
---张三洗完菜了---
王五等待李四切菜...
======李四开始切菜======
===李四切完菜了===
》》》》王五开始炒菜《《《《
》》》王五炒菜完成《《《

分析:上一个人未完成,那么下一个人就继续等待。一个人完成了,要通知所有人,每个人根据自己的顺序,接到通知后,看是否要做,不做任务就继续等待。保证了张三先洗完菜,李四再开始切菜,李四切完菜,王五再炒菜的顺序

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

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

相关文章

windows系统使用nvidia-smi命令办法

参考&#xff1a; https://blog.csdn.net/Castlehe/article/details/114978005 老版本的cuda&#xff0c;nvidia-sim.exe这个软件是位于&#xff1a;C:\Program Files\NVIDIA Corporation\NVSMI 新版本的cuda&#xff08;比如cuda11.0&#xff09;&#xff0c;nvidia-sim.exe这…

springBoot高校宿舍交电费系统-计算机毕业设计源码031552

摘 要 科技进步的飞速发展引起人们日常生活的巨大变化&#xff0c;电子信息技术的飞速发展使得电子信息技术的各个领域的应用水平得到普及和应用。信息时代的到来已成为不可阻挡的时尚潮流&#xff0c;人类发展的历史正进入一个新时代。在现实运用中&#xff0c;应用软件的工作…

忘记 iPhone 密码:如果忘记密码,如何解锁 iPhone

为了提高个人数据的安全性&#xff0c;用户通常会为不同的帐户和设备创建不同的复杂密码。虽然较新的 iPhone 型号具有生物识别和面部解锁功能&#xff0c;但这些功能并不总是有效 - 如果您忘记了 iPhone 的密码&#xff0c;您可能会遇到麻烦。 iPhone 用户和 Android 用户一样…

MYSQL 四、mysql进阶 4(索引的数据结构)

一、为什么使用索引 以及 索引的优缺点 1.为什么使用索引 索引是存储引擎用于快速找到数据记录的一种数据结构&#xff0c;就好比一本教科书的目录部分&#xff0c;通过目录中找到对应文章的页码&#xff0c;便可快速定位到需要的文章。Mysql中也是一样的道理&#xff0c;进行数…

2024-06-19 高等数学(统计学和概率论-高等工科数学)

学习数学时&#xff0c;有效的笔记方法可以帮助你更好地理解和记忆概念、公式和解题技巧。下面是一个数学笔记的基本模本&#xff0c;你可以根据自己的需求进行调整&#xff1a; 1. **标题**&#xff1a;写上日期和课程名称&#xff0c;例如“2024-06-19 高等数学”。 2. **课…

PyFlink

PyFlink教程 官方文档链接 PyFlink官方文档 概述 PyFlink是Apache Flink的Python API&#xff0c;允许用户使用Python编写数据处理程序。Flink是一种用于处理无界和有界数据流的分布式流处理框架。PyFlink可以帮助用户轻松地在Flink集群上运行Python数据流处理任务。 架构…

办公人必备宝藏网站,提升工作效率!

对于每个办公人来说&#xff0c;如何在繁杂的工作中保持高效&#xff0c;是每位职场人士追求的目标。其中&#xff0c;高效的工具和资源可以极大地提升我们的工作效率。下面小编就来和大家分享一些办公人必备的宝藏网站&#xff0c;提升大家的工作效率。 1. 办公人导航 办公人…

反激开关电源变压器设计2

实际计算 已知 Vin&#xff1a;AC176-264V Vo&#xff1a;5V Io2A Vmax264V*根号2373V PoVo*Io10W η0.8 PinPo/η12.5W DCM变压器&#xff0c;在开关电源的整个输入电压范围内满载工作时都工作在断续模式 CCM变压器&#xff0c;在开关电源的整个输入电压范围内满载工作时都工…

小程序开发的技术难点

小程序开发是一项技术难度较高的工作&#xff0c;需要开发者具备多方面的知识和技能&#xff0c;小程序开发的技术难点主要体现在以下几个方面。北京木奇移动技术有限公司&#xff0c;专业的软件外包开发公司&#xff0c;欢迎交流合作。 1. 多端兼容 小程序需要在微信、支付宝…

渗透测试基础(五) 获取WiFi密码

1. 前提条件 需要无线网卡&#xff0c;kali无法识别电脑自带的网卡。 2. 实验步骤&#xff1a; 2.1 查看网卡 命令&#xff1a;airmon-ng 2.2 启动网卡监听模式 命令airmon-ng start wlan0 检查下是否处于监听模型&#xff1a;ifconfig查看一下&#xff0c;如果网卡名加…

ARM64汇编0C - inlinehook

本文是ARM64汇编系列的完结篇&#xff0c;主要利用前面学过的知识做一个小实验 完整系列博客地址&#xff1a;https://www.lyldalek.top/article/arm 这里只讨论 ARM64 下的 inlinehook&#xff0c;做一个简单的demo&#xff0c;只是抛砖引玉&#xff0c;有兴趣了解更多细节的可…

android 13 root

一&#xff1a;修改系统文件 需要修改一些系统文件&#xff0c;以允许adbd进程在root用户下运行&#xff0c;并关闭Verity检查。我们需要修改以下文件&#xff1a; 1.frameworks/base/core/jni/com_android_internal_os_Zygote.cpp 这个文件负责创建应用程序进程&#xff0c…

HTML(13)——显示模式

目录 显示模式 块级元素 行内元素 行内块元素 转换显示模式 显示模式&#xff1a;标签的显示方式 作用&#xff1a;布局网页时&#xff0c;根据标签的显示模式选择合适的标签摆放内容 显示模式 块级元素 独占一行宽度默认为父级的100%添加宽高属性生效 行内元素 …

WordPress主题 酱茄免费主题

酱茄free主题由酱茄开发的一款免费开源的WordPress主题&#xff0c;主题专为WordPress博客、资讯、自媒体网站而设计&#xff0c;遵循GPL V2.0开源协议发布。 运行环境 酱茄Free主题当前版本&#xff1a;2020.11.25 V1.0.0 支持WordPress版本&#xff1a;5.4 兼容Chrome、Fire…

word复制技巧二则

1 纵向复制 按下Alt键&#xff0c;按下鼠标左键拖动&#xff0c;选中要纵向复制的内容&#xff0c;如下图&#xff0c; 再粘贴即可&#xff1b; 2 整页复制 在页的任意位置单击&#xff0c;然后按CtrlA&#xff0c;这会选中整页&#xff1b;然后再复制粘贴即可&#xff1b;

合并github未合并的PR

问题描述 有时候你急需某个PR解决问题&#xff0c;但是官方可能还未合并这个PR&#xff0c;你想合并到自己的分支。 解决方案 方案一&#xff1a;直接用别人的PR仓库 可以在具体的PR详情页面&#xff0c;查看别人的源仓库&#xff0c;将原仓库下载下来编译使用。 方案二&a…

Linux的dev/ 和 sys/ 和 proc/ 目录

linux精神&#xff1a; 一切设备皆文件。 设备被抽象成文件 1、 /dev : 该目录放的设备文件&#xff0c;是应用程序和内核的交互文件&#xff0c;应用程序对这些文件的读写控制可以直接访问到实际的设备 应用程序通过mknod创建的文件&#xff0c;如果底层驱动对mknod的设备号…

更换域名流程记录

华为云的服务器&#xff0c;阿里云购买的域名。 1.购买域名 2.在域名服务商绑定服务器ip&#xff08;以阿里云为例&#xff09; 控制台->域名控制台->域名列表->点击域名->域名解析->添加记录 记录类型填A , 主机记录“”或“www”&#xff0c;记录值填服务器i…

通俗易懂的ChatGPT原理简介

一、引言 随着人工智能的发展&#xff0c;聊天机器人已经成为我们生活中的常见工具。而在众多聊天机器人中&#xff0c;ChatGPT 无疑是最受关注的一个。ChatGPT 是由 OpenAI 开发的一种基于生成式预训练模型&#xff08;GPT&#xff09;的大型语言模型。本文将通俗易懂地介绍 …

最新暑假带刷规划:50天吃透660+880!

现在只刷一本题集根本不够 去做做24年的考研真题卷就什么都明白了&#xff0c;24年的卷子就是典型的知识点多&#xff0c;杂&#xff0c;计算量大。 而现在市面上的任何一本题集&#xff0c;都无法做到包含所有的知识点&#xff0c;毕竟版面有限&#xff01; 所以&#xff0…