线程间的通信

文章目录



在这里插入图片描述

  • 线程间的通讯技术就是通过等待和唤醒机制,来实现多个线程协同操作完成某一项任务,例如经典的生产者和消费者案例。等待唤醒机制其实就是让线程进入等待状态或者让线程从等待状态中唤醒,需要用到两种方法,如下:

  • 等待方法 :

    • void wait() 让线程进入无限等待。
    • void wait(long timeout) 让线程进入计时等待
    • 以上两个方法调用会导致当前线程释放掉锁资源
  • 唤醒方法 :

    • void notify() 唤醒在此对象监视器(锁对象)上等待的单个线程。
    • void notifyAll() 唤醒在此对象监视器上等待的所有线程。
    • 以上两个方法调用不会导致当前线程释放掉锁资源
  • 注意

    • 等待和唤醒的方法,都要使用锁对象调用(需要在同步代码块中调用)
    • 等待和唤醒方法应该使用相同的锁对象调用

/*
1 线程进入无限等待
注意:进入无限等待需要使用锁在同步代码中调用wait方法
*/

/*1 线程进入无限等待注意:进入无限等待需要使用锁在同步代码中调用wait方法*/
public class Test1 {public static void main(String[] args) {Object obj = new Object(); // 作为锁对象new Thread(new Runnable() {@Overridepublic void run() {synchronized (obj) {System.out.println("线程开始执行");System.out.println("线程进入无线等待....");try {obj.wait(); // 进入无线等待状态 , 并释放锁} catch (InterruptedException e) {e.printStackTrace();}System.out.println("无线等待被唤醒....");}}}).start();}
}

/*
线程进入无限等待后被唤醒
注意:等待和唤醒是两个或多个线程之间实现的。进入无限等待的线程是不会自动唤醒,只能通过其他线程来唤醒。
*/

/*线程进入无限等待后被唤醒注意:等待和唤醒是两个或多个线程之间实现的。进入无限等待的线程是不会自动唤醒,只能通过其他线程来唤醒。*/
public class Test2 {public static void main(String[] args) {Object obj = new Object(); // 作为锁对象new Thread(new Runnable() {@Overridepublic void run() {synchronized (obj) {System.out.println("线程开始执行");System.out.println("线程进入无线等待....");try {obj.wait(); // 进入无线等待状态 , 并释放锁} catch (InterruptedException e) {e.printStackTrace();}System.out.println("无线等待被唤醒....");}}}).start();new Thread(new Runnable() {@Overridepublic void run() {try {Thread.sleep(3000);} catch (InterruptedException e) {e.printStackTrace();}synchronized (obj) {obj.notify();// 随机唤醒此监视器中等待的线程 , 不会释放锁System.out.println("唤醒后 , 5秒钟后释放锁");try {Thread.sleep(5000);} catch (InterruptedException e) {e.printStackTrace();}}// 释放锁}}).start();}
}

/*
3 线程进入计时等待并唤醒
注意:进入计时等待的线程,时间结束前可以被其他线程唤醒。时间结束后会自动唤醒
*/

/*3 线程进入计时等待并唤醒注意:进入计时等待的线程,时间结束前可以被其他线程唤醒。时间结束后会自动唤醒*/
public class Test3 {public static void main(String[] args) {new Thread(new Runnable() {@Overridepublic void run() {synchronized (Test3.class) {System.out.println("获取到锁 , 开始执行");try {System.out.println("进入计时等待...3秒");Test3.class.wait(3000);} catch (InterruptedException e) {e.printStackTrace();}System.out.println("自动唤醒.");}}}).start();}
}

生产者和消费者案例

/*
生产者步骤:
1,判断桌子上是否有汉堡包
如果有就等待,如果没有才生产。
2,把汉堡包放在桌子上。
3,叫醒等待的消费者开吃
*/

import sun.security.krb5.internal.crypto.Des;/*生产者步骤:1,判断桌子上是否有汉堡包如果有就等待,如果没有才生产。2,把汉堡包放在桌子上。3,叫醒等待的消费者开吃*/
public class Cooker implements Runnable {@Overridepublic void run() {while (true) {synchronized (Desk.lock) {if (Desk.count == 0) {break;} else {if (Desk.flag) {// 桌子上有食物try {Desk.lock.wait();} catch (InterruptedException e) {e.printStackTrace();}} else {// 桌子上没有食物System.out.println("厨师生产了一个汉堡包...");Desk.flag = true;Desk.lock.notify();}}}}}
}

/*
消费者步骤:
1,判断桌子上是否有汉堡包。
2,如果没有就等待。
3,如果有就开吃
4,吃完之后,桌子上的汉堡包就没有了
叫醒等待的生产者继续生产
汉堡包的总数量减一
*/

import sun.security.krb5.internal.crypto.Des;/*消费者步骤:1,判断桌子上是否有汉堡包。2,如果没有就等待。3,如果有就开吃4,吃完之后,桌子上的汉堡包就没有了叫醒等待的生产者继续生产汉堡包的总数量减一*/
public class Foodie implements Runnable {@Overridepublic void run() {while (true) {synchronized (Desk.lock) {if (Desk.count == 0) {break;} else {if (Desk.flag) {// 桌子上有食物System.out.println("吃货吃了一个汉堡包...");Desk.count--; // 汉堡包的数量减少一个Desk.flag = false;// 桌子上的食物被吃掉 , 值为falseDesk.lock.notify();} else {// 桌子上没有食物try {Desk.lock.wait();} catch (InterruptedException e) {e.printStackTrace();}}}}}}
}
public class Test {public static void main(String[] args) {new Thread(new Foodie()).start();new Thread(new Cooker()).start();}
}

在这里插入图片描述



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

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

相关文章

Java中的内存数据库与缓存技术

Java中的内存数据库与缓存技术 大家好,我是免费搭建查券返利机器人省钱赚佣金就用微赚淘客系统3.0的小编,也是冬天不穿秋裤,天冷也要风度的程序猿! 1. 内存数据库的概念与优势 1.1 什么是内存数据库? 内存数据库是…

python写的工具代码总结

目录 python画图&处理图片python增大图片的大小(比如将几百K的照片增加到几mb)解决python画图无法显示中文的问题python画折线图 & 一张图上三条折线 & 设置折线marker & chatgpt画折线图的提示词python将png格式的图片转换为jpg格式的图…

红蓝对抗下的内网横向移动渗透技术详解

一、利用Windows计划任务横向移动 Windows计划任务是一个非常实用的功能,可以帮助我们自动完成一些重复性的任务。比如,我们可以设定一个计划任务来自动备份文件、更新软件、执行脚本等,本文主要介绍了如何利用Windows计划任务进行横向渗透。 &#xf…

列举操作redis set的命令

Redis中的Redis中的Set是一种无序的Set是一种无序的、不包含重复元素的字符串集合。、不包含重复元素的字符串集合。操作Redis Set的命令非常丰富,下面列举了一些常用的命令: **S操作Redis Set的命令非常丰富,下面列举了一些常用的命令&#…

C#委托事件的实现

1、事件 在C#中事件是一种特殊的委托类型,用于在对象之间提供一种基于观察者模式的通知机制。 1.1、事件的发送方定义了一个委托,委托类型的声明包含了事件的签名,即事件处理器方法的签名。 1.2、事件的订阅者可以通过运算符来注册事件处理器…

Python基础小知识问答系列-过滤列表元素

1. 问题: 如何根据单一条件过滤列表的元素? 如何根据复杂条件过滤列表的元素? 2. 解决方式: 可以使用推导式生成器,进行单一条件的列表元素过滤,尤其是列表内容较多时; 也可以使用filter函数进行列…

快速排序c++java代码实现

快速排序的思想 &#xff08;基于分治法&#xff09;: 每次选一个基准元素x&#xff0c;通过一次遍历将排序表划分为独立的两部分a[l,k-1],a[k1,r]; 其中左边的元素<x,右边的1元素>x,然后递归下去&#xff0c;直到每个块的大小为1 ; c #include<bits/stdc.h> …

Linux Static Keys和jump label机制

文章目录 前言一、asm goto二、API使用2.1 低版本API2.2 高版本API 三、jump label四、源码分析4.1 数据结构4.2 static_key_false4.3 jump_label_init4.4 __jump_label_transform4.5 static_key_slow_inc/dec 五、__jump_table节5.1 内核5.2 内核模块 六、修改内存代码6.1 x86…

24西安电子科技大学数学与统计学院—考研录取情况

24西安电子科技大学—数学与统计学院—考研录取统计 01、数学与统计学院各个方向 02、24数学与统计学院近三年复试分数线对比 数统院24年院线相对于23年院线增加高达30分&#xff0c;确实增长浮动比较高&#xff0c;接近30分的水平&#xff0c;因此大家更需要好好去努力&#x…

GTest和Catch2单元测试学习(附Cmake测试代码库)

kevin_CTest CTest 单元测试学习 Gitee库&#xff1a; https://gitee.com/bigearrabbit/kevin_ctest.git 示例多是从网页文章上摘取的&#xff0c;大部分记录在下面&#xff0c;或者源码内。供学习参考。 CTest 学习Catch2 框架 单个文档的测试架构&#xff0c;使用方便&am…

FastGPT 报错:undefined 该令牌无权使用模型:gpt-3.5-turbo (request id: xxx)

目录 一、FastGPT 报错 二、解决方法 一、FastGPT 报错 进行对话时 FastGPT 报错如下所示。 [Error] 2024-07-01 09:25:23 sse error: undefined 该令牌无权使用模型:gpt-3.5-turbo (request id: xxxxx) {message: 403 该令牌无权使用模型:gpt-3.5-turbo (request id: x…

人机交互中信息之间的距离

在人机交互中&#xff0c;信息之间的距离可以从多个角度来理解和描述&#xff1a; 1、物理距离 &#xff1a;这指的是用户与交互设备&#xff08;例如电脑、手机、智能设备&#xff09;之间的物理空间距离。随着移动设备的普及和技术的发展&#xff0c;用户可以在不同的物理位置…

vue3中svg图标的封装与使用

组件封装&#xff1a; <template><svg :class"svgClass" :style"{ width: size px, height: size px, color: color, verticalAlign:deviationem}" aria-hidden"true"><use :xlink:href"#icon-${name}" /></s…

scss学习总结

摘录更改至 scss: map:merge 和 each $attribute, $value in $variables 研究 Element-plus 源码时&#xff0c;有以下一段代码&#xff1a; // path: element-plus/packages/theme-chalk/src/button.scss include b(button) {include set-component-css-var(button, $butto…

RISC-V的历史与设计理念

指令集是什么&#xff1f; 如果把软件比作螺丝钉&#xff0c;硬件比作螺母&#xff0c;那么指令集架构就是螺丝钉与螺母的蓝图。我们需要根据蓝图设计可以匹配的螺丝钉与螺母。——包云岗老师 RISC-V的起源 以往比较流行的指令集&#xff1a;ARM&#xff0c;MIPS&#xff0c;X…

FreeRTOS的任务间通信

文章目录 4 FreeRTOS任务间通信4.1 队列4.1.1 队列的使用4.1.2 队列的创建&#xff0c;删除&#xff0c;复位4.1.3 队列的发送&#xff0c;接收&#xff0c;查询 4.2 邮箱&#xff08;mailbox&#xff09;4.2.1 任务中读写邮箱4.2.2 中断中读写邮箱 4.3 队列集4.3.1 队列集的创…

【哈希表】【字符串】个人练习-Leetcode-1814. Count Nice Pairs in an Array

题目链接&#xff1a;https://leetcode.cn/problems/count-nice-pairs-in-an-array/description/ 题目大意&#xff1a;给出一个数列nums[]&#xff0c;求nice对 ( i , j ) (i, j) (i,j)对数。nice对满足0 < i < j < nums.length和nums[i] rev(nums[j]) nums[j] r…

Vue打包文件dist放在SpringBoot项目下运行(正确实现全过程)

项目开发中&#xff0c;一般我们都会使用SpringBootVue进行前后端开发。 在部署时&#xff0c;会后端启动一个服务&#xff0c;再启动一个nginx&#xff0c;nginx中配置前端打包文件dist进行项目访问。 实际上&#xff0c;我们也可以把打包好的dist目录放在SpringBoot项目下进…

【Android面试八股文】Android 有哪些存储数据的方式?

在Android平台上,有多种方式可以存储数据,每种方式都适合不同类型的数据和使用场景。以下是主要的存储数据方式: SharedPreferences(轻量级数据存储): SharedPreferences是用于存储简单键值对数据的最简单方法,适合存储用户偏好设置、配置信息等。数据以XML文件形式存储…

Os-hackNos

下载地址 https://download.vulnhub.com/hacknos/Os-hackNos-1.ova 环境配置如果出现&#xff0c;扫描不到IP的情况&#xff0c;可以尝试vulnhub靶机检测不到IP地址解决办法_vulnhub靶机扫描不到ip-CSDN博客 信息收集 确定靶机地址&#xff1a; 探测到存活主机192.168.111.…