【Java】多线程-wait/notify

news2025/1/11 7:52:18

1、wait和notify

Java的多线程中,线程的执行顺序和时间都是不定的。为了控制线程的调度顺序,前面我们引入了join()方法。

但是join()只能在线程执行完后,才能执行其他线程,有没有什么方法可以在线程执行顺序中来调度其他线程呢?

这里我们引入了wait()和notify()方法

wait()、notify()和notifyAll()都是属于Object类中的方法,任何对象都可以调用这几个方法

wait()/wait(time):让当前进程进入阻塞状态

notify()/notifyAll():唤醒当前对象上等待的对象

wait()的基本用法是

Object object = new Object();
synchronized (object){
   try {
       object.wait();
   } catch (InterruptedException e) {
       throw new RuntimeException(e);
   }
       

notify()基本用法

synchronized (object){
      object.notify();
} 

2、注意事项

(1)wait()和notify()在使用时都要加锁

在使用上述三个方法时,需要对竞争资源进行加锁,不然就会报错

并且wait()方法在使用时,线程必须获得锁对象的控制权

(2)阻塞状态

线程调用wait()方法后,线程进入阻塞状态(WAITING

阻塞状态什么也不做,不会占用CPU

 

(3) notify的调用位置

对象调用wait方法后,对象锁被释放,这时必须由其他线程来唤醒对象

如果将notify写在同一线程中,则不能唤醒当前对象

public class demo {
    public static void main(String[] args) {
        Object object = new Object();
        System.out.println("开始进程");
        synchronized (object){
            try {
                object.wait();
            } catch (InterruptedException e) {
                throw new RuntimeException(e);
            }
            object.notify();
        }
        System.out.println("结束进程");
    }
}

线程会继续阻塞 

3、wait()带参数方法和notifyAll()

 (1)wait()带参数方法

 wait(long timeout)中的参数表示线程阻塞的超时时间,如果超过这个时长,那么线程会被自动唤醒

避免无休止地等待下去

public class demo {
    public static void main(String[] args) {
        Object object = new Object();
        Thread thread1 = new Thread(()->{
            synchronized (object){
                System.out.println("线程1开始执行");
                try {
                    object.wait(1000);
                } catch (InterruptedException e) {
                    throw new RuntimeException(e);
                }
                System.out.println("线程1执行结束");
            }
        });

        Thread thread2 = new Thread(()->{
            System.out.println("线程2开始执行");
            System.out.println("线程2执行结束");
        });

        thread1.start();
        thread2.start();

    }
}

上述代码中,并没有对线程1进行唤醒操作,而是在1000ms的等待时间结束后,线程1自动唤醒,打印结果并结束线程 

(2)notifyAll() 

notify()一次唤醒一个线程,notifyAll() 一次唤醒全部线程

由于唤醒线程的过程中也要进行锁的竞争,因此notifyAll()的唤醒并不是并行执行,而是串行执行的

 · 多次notify()唤醒多个线程

public class demo {
    public static void main(String[] args) {
        Object object = new Object();

        Thread thread1 = new Thread(()->{
            synchronized (object){
                System.out.println("线程1开始执行");
                try {
                    object.wait();
                } catch (InterruptedException e) {
                    throw new RuntimeException(e);
                }
                System.out.println("线程1拿回锁");
                System.out.println("线程1执行完毕");
            }
        });

        Thread thread2 = new Thread(()->{
            synchronized (object){
                System.out.println("线程2开始执行");
                try {
                    object.wait();
                } catch (InterruptedException e) {
                    throw new RuntimeException(e);
                }
                System.out.println("线程2拿回锁");
                System.out.println("线程2执行完毕");
            }
        });

        Thread thread3 = new Thread(()->{
            try {
                Thread.sleep(2000);
            } catch (InterruptedException e) {
                throw new RuntimeException(e);
            }
            synchronized (object){
                System.out.println("线程3开始执行");
                object.notify();
                object.notify();
                System.out.println("线程释放锁");
                System.out.println("线程3执行完毕");
            }
        });

        thread1.start();
        thread2.start();
        thread3.start();
    }
}

线程3唤醒两次,使得线程1和线程2先后拿回锁

 · notifyAll() 

public class demo {
    public static void main(String[] args) {
        Object object = new Object();

        Thread thread1 = new Thread(()->{
            synchronized (object){
                System.out.println("线程1开始执行");
                try {
                    object.wait();
                } catch (InterruptedException e) {
                    throw new RuntimeException(e);
                }
                System.out.println("线程1拿回锁");
                System.out.println("线程1执行完毕");
            }
        });

        Thread thread2 = new Thread(()->{
            synchronized (object){
                System.out.println("线程2开始执行");
                try {
                    object.wait();
                } catch (InterruptedException e) {
                    throw new RuntimeException(e);
                }
                System.out.println("线程2拿回锁");
                System.out.println("线程2执行完毕");
            }
        });

        Thread thread3 = new Thread(()->{
            try {
                Thread.sleep(2000);
            } catch (InterruptedException e) {
                throw new RuntimeException(e);
            }
            synchronized (object){
                System.out.println("线程3开始执行");
                object.notifyAll();
                System.out.println("线程释放锁");
                System.out.println("线程3执行完毕");
            }
        });

        thread1.start();
        thread2.start();
        thread3.start();
    }
}

执行结果

 

3、关于锁释放的时间

在线程2唤醒 线程1后,线程2会立即释放锁吗?

我们通过一段代码来验证一下

public class demo {
    public static void main(String[] args) {
        Object object = new Object();
        Thread thread1 = new Thread(()->{
            synchronized (object){
                System.out.println("线程1开始执行");
                try {
                    object.wait();
                } catch (InterruptedException e) {
                    throw new RuntimeException(e);
                }
                System.out.println("线程1拿回锁");
                System.out.println("线程1执行结束");
            }
        });

        Thread thread2 = new Thread(()->{
            synchronized (object){
                System.out.println("线程2拿到锁");
                System.out.println("线程2开始执行");
                System.out.println("线程2释放锁");
                object.notify();
                try {
                    Thread.sleep(2000);
                } catch (InterruptedException e) {
                    throw new RuntimeException(e);
                }
                System.out.println("线程2执行结束");
            }
        });

        thread1.start();
        thread2.start();
    }
}

上述代码执行结果为:

可以看到,在线程2调用notify()唤醒线程1后,就算进行了休眠,也并没有释放锁;而是在线程2的代码全部执行完后,线程2才释放锁

所以,我们可以得出的结论是:在一个线程唤醒其他线程后,它不会立即释放锁,而是要在本线程代码执行完后才释放锁 

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

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

相关文章

代码随想录 Day50 单调栈 LeetCodeT503 下一个最大元素II T42接雨水

前言 前面我们说到了单调栈的第一题,下一个最大元素I,其实今天的两道题都是对他的变种,知道第一个单调栈的思想能够想清楚,其实这道题是很简单的 考虑好三个状态,大于等于小于,其实对于前面这些题目只要细心的小伙伴就会发现其实小于和等于的处理是一样的都是直接入栈,只有大于…

灵魂拷问std::enable_shared_from_this,揭秘实现原理

灵魂拷问std::enable_shared_from_this,揭秘实现原理 引言 在C编程中,使用智能指针是一种安全管理对象生命周期的方式。std::shared_ptr是一种允许多个指针共享对象所有权的智能指针。然而,当一个对象需要获取对自身的shared_ptr时&#xff0…

中贝转债上市价格预测

中贝转债-113678 基本信息 转债名称:中贝转债,评级:A,发行规模:5.17亿元。 正股名称:中贝通信,今日收盘价:49.2元,转股价格:32.8元。 当前转股价值 转债面值…

JavaScript中的random小案例

前言 Math对象是JavaScript的内置对象,而random是Math对象属性 Math.random()函数返回一个浮点数,伪随机数在范围从0 到小于1,也就是说,从 0(包括 0)往上,但是不包括 1&a…

Python编程技巧 – 使用字典

Python编程技巧 – 使用字典 Python Programming Skills – Using Dictionary Dictionary, 即字典,这是Python语言的一种重要的数据结构;Python字典是以键(key)值(value)对为元素,来存储数据的集合。 前文提到Python列…

春秋云境靶场CVE-2022-30887漏洞复现(任意文件上传漏洞)

文章目录 前言一、CVE-2022-30887描述和介绍二、CVE-2021-41402漏洞复现1、信息收集2、找可能可以进行任意php代码执行的地方3、漏洞利用找flag 总结 前言 此文章只用于学习和反思巩固渗透测试知识,禁止用于做非法攻击。注意靶场是可以练习的平台,不能随…

【电路笔记】-星三角变换(Star-Delta Transformation)

星三角变换(Star-Delta Transformation) 文章目录 星三角变换(Star-Delta Transformation)1、概述1.1 单相配置1.2 多相配置 2、三相连接2.1 Y配置2.2 Δ配置 3、Y-Δ 和 Δ-Y 变换3.1 Y-Δ变换3.2 Δ-Y变换3.3 应用 4、总结 本文…

使用ssh在本地环境(Windows)连接虚拟机以及其中的docker容器

配置虚拟机防火墙 防火墙的一系列操作需要root权限,默认是没有root密码的,所以首先需要设置root密码: sudo passwd root按提示完成root密码设置 切换到root账户 su root启用22端口并重启防火墙 firewall-cmd --permanent --add-port22/tc…

【zabbix监控四】zabbix之监控tomcat服务报警

一、监控tomcat服务是否正常运行 1、客户端部署 首先要在zabbix-agent客户端上安装tomcat服务,并能正常启动和关闭 1.1 客户端编写脚本 vim /opt/tomcat.sh#!/bin/bash anetstat -natp |grep 8080|awk {print $6}|grep LISTEN if [[ $a LISTEN ]];thenecho &qu…

【目标测距】雷达投影测距

文章目录 前言一、读取点云二、点云投影图片三、读取检测信息四、点云投影测距五、学习交流 前言 雷达点云投影相机。图片目标检测,通过检测框约束等等对目标赋予距离。计算消耗较大,适合离线验证操作。在线操作可以只投影雷达检测框。 一、读取点云 py…

HandBrake :MacOS专业视频转码工具

handbrake 俗称大菠萝,是一款免费开源的视频转换、压缩软件,它几乎支持目前市面上所能见到的所有视频格式,并且支持电脑硬件压缩,是一款不可多得的优秀软件 优点 ∙Windows, Linux, Mac 三平台支持 ∙开源、免费、无广告 ∙支…

SSM2

DataSource mybatis与Spring整合 事务加载业务层上面 开启事务驱动 上面都是声明式开启事务 图书管理系统 命名规范: java命名规范:驼峰命名法类:大驼峰变量,属性名.方法名:小驼峰 常量使用下划线分割:全大写,单词与单词之间下划线分割数据库命名规范:常用命名规范:下划线…

Python将原始数据集和标注文件进行数据增强(随机仿射变换),并生成随机仿射变换的数据集和标注文件

Python将原始数据集和标注文件进行数据增强(随机仿射变换),并生成随机仿射变换的数据集和标注文件 前言前提条件相关介绍实验环境生成随机仿射变换的数据集和标注文件代码实现输出结果 前言 由于本人水平有限,难免出现错漏&#x…

基于单片机K型热电偶温度采集报警系统

**单片机设计介绍, 基于单片机K型热电偶温度采集报警系统 文章目录 一 概要简介系统特点系统组成工作原理应用领域 二、功能设计设计思路 三、 软件设计原理图 五、 程序六、 文章目录 一 概要 # 基于单片机K型热电偶温度采集报警系统介绍 简介 该系统是基于单片…

Unity--互动组件(Scrollbar)||Unity--互动组件(DropDown )

此组件中的,交互,过渡,导航与文章(Unity--互动组件(Button))中的介绍如同; handle rect:(父节点矩形) 用于控件的滑动“句柄”部分的图形&#xf…

Harmony Ble 蓝牙App (一)扫描

Harmony Ble 蓝牙App (一)扫描 前言正文一、创建工程二、工程配置① 权限配置② Debug配置③ UI配置 三、扫描① 扫描接口② 扫描类 四、业务处理① Slice的生命周期② 蓝牙开关和动态权限请求 五、扫描设备六、显示设备① 自定义蓝牙类② 提供者③ 显示…

【机器学习】037_暂退法

一、实现原理 具有输入噪音的训练,等价于Tikhonov正则化 核心方法:在前向传播的过程中,计算每一内部层的同时注入噪声 从作用上来看,表面上来说是在训练过程中丢弃一些神经元 假设x是某一层神经网络层的输出,是下一…

​EMNLP 2023 findings | 生成式框架下解决输入扰动槽填充任务

©PaperWeekly 原创 作者 | 回亭风 单位 | 北京邮电大学 研究方向 | 自然语言理解 论文标题: DemoNSF: A Multi-task Demonstration-based Generative Framework for Noisy Slot Filling Task 论文链接: https://arxiv.org/abs/2310.10169 代码链接…

【Linux】套接字编程

目录 套接字 IP PORT TCP和UDP的介绍 TCP UDP 网络字节序 转换接口 UDP服务器的编写 服务器的初始化 socket bind sockaddr 结构 服务器的运行 数据的收发 业务处理 客户端的编写 运行效果 拓展 套接字 🌸首先,我们先思考一个问题…

11.4MyBatis(基础)

一.搭环境 1.创建完SSM项目,添加MySQL和MyBatis后,项目启动一定会报错,这是正常情况. 2.配置文件 properties: server.port9090 spring.datasource.urljdbc:mysql://127.0.0.1:3306/test1?characterEncodingutf8&useSSLfalse spring.datasource.usernameroot spring.d…