线程(Thread)的三种等待唤醒机制详解

news2025/1/21 7:39:57

1、为什么需要线程的等待和唤醒

线程的等待唤醒机制是一种经典的“生产者和消费者”模型。例如食品加工厂,食品加工人员和原料补给人员,在有充足原料时,补给人员是在等待,等到原料不够时,食品加工人员通知补给人员(唤醒)。在我们开发诸如此类需求的时候两个线程之间协调等待和唤醒还是很有必要的。那咱们看看都有那些方式实现线程等待和唤醒机制。

2、线程等待和唤醒机制方式 

实现线程等待和唤醒机制主要有3中方式分别是:

  • 使用 Object 中的 wait() 方法让线程等待,使用 Object 中的 notify() 方法唤醒线程
  • 使用 JUC 包中 Condition 的 await() 方法让线程等待,使用 signal() 方法唤醒线程
  • 使用LockSupport类的park()方法让线程等待,使用unpark()方法唤醒线程。 

 那这三种方式具体怎么使用,都有那些优缺点呢?我们通过实例代码演示。

3、线程等待和唤醒机制实例

3.1、使用 Object 中的 wait() 方法让线程等待,使用 Object 中的 notify() 方法唤醒线程

代码:

package com.lc.test02;

import java.util.concurrent.TimeUnit;

/**
 * @author liuchao
 * @date 2023/4/8
 */
public class ThreadWaitOne {
    /**
     * 注意:必须使用同一把锁
     */
    static Object lock = new Object();

    public static void main(String[] args) {

        /**
         * 线程1
         */
        Thread t1 = new Thread(() -> {
            synchronized (lock) {
                System.out.println("进入" + Thread.currentThread().getName());
                try {
                    lock.wait();
                } catch (InterruptedException e) {
                    Thread.currentThread().interrupt();
                }
                System.out.println(Thread.currentThread().getName() + "被唤醒");
            }
        }, "t1");

        t1.start();

        try {
            TimeUnit.MILLISECONDS.sleep(200);
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
        }

        /**
         * 线程2
         */
        Thread t2 = new Thread(() -> {
            synchronized (lock) {
                System.out.println("进入" + Thread.currentThread().getName());
                lock.notify();
                System.out.println("唤醒通知已发");
            }
        }, "t2");

        t2.start();
    }
}

效果:

进入t1
进入t2
唤醒通知已发
t1被唤醒 

总结:此种方式必须使用同一把锁并且必须包含在synchronized代码块中,如果未使用synchronized包裹,则会报错。

Exception in thread "t1" java.lang.IllegalMonitorStateException
    at java.lang.Object.wait(Native Method)
    at java.lang.Object.wait(Object.java:502)
    at com.lc.test02.ThreadWaitOne.lambda$main$0(ThreadWaitOne.java:24)
    at java.lang.Thread.run(Thread.java:750)

并且wait方法的调用必须要在notify/notifyAll的调用之前,否则线程将永远不会被唤醒。 

3.2、使用 JUC 包中 Condition 的 await() 方法让线程等待,使用 signal() 方法唤醒线程

代码:

package com.lc.test02;

import java.util.concurrent.TimeUnit;
import java.util.concurrent.locks.Condition;
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;

/**
 * @author liuchao
 * @date 2023/4/8
 */
public class ThreadWaitTwo {
    /**
     * 必须是同一把锁
     */
    static Lock lock = new ReentrantLock();
    static Condition condition = lock.newCondition();

    public static void main(String[] args) {

        /**
         * 线程1
         */
        Thread t1 = new Thread(() -> {
            lock.lock();
            try {
                System.out.println("进入" + Thread.currentThread().getName());
                condition.await();
            } catch (InterruptedException e) {
                Thread.currentThread().interrupt();
            } finally {
                lock.unlock();
            }
            System.out.println(Thread.currentThread().getName() + "被唤醒");
        }, "t1");

        t1.start();

        try {
            TimeUnit.MILLISECONDS.sleep(200);
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
        }

        /**
         * 线程2
         */
        Thread t2 = new Thread(() -> {
            lock.lock();
            try {
                System.out.println("进入" + Thread.currentThread().getName());
                condition.signal();
                System.out.println("唤醒通知已发");
            } finally {
                lock.unlock();
            }
        }, "t2");

        t2.start();
    }
}

效果:

进入t1
进入t2
唤醒通知已发
t1被唤醒 

总结:使用此中方式必须配合lock,代码必须被lock包裹,否则将报错

Exception in thread "t1" java.lang.IllegalMonitorStateException
    at java.util.concurrent.locks.ReentrantLock$Sync.tryRelease(ReentrantLock.java:151)
    at java.util.concurrent.locks.AbstractQueuedSynchronizer.release(AbstractQueuedSynchronizer.java:1261)
    at java.util.concurrent.locks.AbstractQueuedSynchronizer.fullyRelease(AbstractQueuedSynchronizer.java:1723)
    at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2036)
    at com.lc.test02.ThreadWaitTwo.lambda$main$0(ThreadWaitTwo.java:28)
    at java.lang.Thread.run(Thread.java:750) 

 并且await方法的调用必须在signal/signalAll方法调用之前,否则t1也是不会被唤醒

3.3、使用LockSupport类的park()方法让线程等待,使用unpark()方法唤醒线程。  

LockSupport 类使用了一种名为 Permit (许可)的概念来做到阻塞和唤醒线程的功能,每个线程都有一个许可(permit),permit 只有两个值 1 和 0,默认是 0

  • 阻塞

        ①、park()/park(Object blocker)
        ②、permit 默认是 0,所以一开始调用 park() 方法,当前线程就会阻塞,直到别的线程将当前线程的 permit 设置为 1 时,park 方法会被唤醒,然后会将 permit 再次设置为 0 并返回。
        ③、阻塞当前线程/阻塞传入的具体线程

  • 唤醒

        ①、unpark(Thread thread)
        ②、调用 unpark(Thread thread) 方法后,就会将 thread 线程的许可 permit 设置为 1(注意多次调用 unpark 方法,不会累加,permit 值还是 1)会自动唤醒 thread 线程,即之前阻塞中的 LockSupport.park()方法会立即返回
        ③、唤醒处于阻塞状态的指定线程

代码:

package com.lc.test02;

import java.util.concurrent.TimeUnit;
import java.util.concurrent.locks.LockSupport;

/**
 * @author liuchao
 * @date 2023/4/8
 */
public class ThreadWaitThree {


    public static void main(String[] args) {

        /**
         * 线程1
         */
        Thread t1 = new Thread(() -> {
            System.out.println("进入" + Thread.currentThread().getName());
            LockSupport.park();
            System.out.println(Thread.currentThread().getName() + "被唤醒");
        }, "t1");

        t1.start();

        try {
            TimeUnit.MILLISECONDS.sleep(200);
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
        }

        /**
         * 线程2
         */
        Thread t2 = new Thread(() -> {
            System.out.println("进入" + Thread.currentThread().getName());
            LockSupport.unpark(t1);
            System.out.println("唤醒通知已发");
        }, "t2");

        t2.start();
    }
}

效果:

进入t1
进入t2
唤醒通知已发
t1被唤醒 

结论:此种方式不需要增加同步机制,天生就是无锁机制实现线程等待和唤醒,并且因为是通过许可方式来唤醒线程的,所以许可是在等待(调用park()方法)前还是后是不影响的(park和unpark调用先后顺序我关),此种方式也是我们推荐使用的方式。当然,这种方式也是有缺点的,许可最多只有一个,如果等待多次(调用多次park()方法),线程也就永远不能唤醒了。

演示线程的唤醒和unpark先调用还是后调用无关:

package com.lc.test02;

import java.util.concurrent.TimeUnit;
import java.util.concurrent.locks.LockSupport;

/**
 * @author liuchao
 * @date 2023/4/8
 */
public class ThreadWaitThree {


    public static void main(String[] args) {

        /**
         * 线程1
         */
        Thread t1 = new Thread(() -> {
            try {
                //等待300毫秒,让t2先执行
                TimeUnit.MILLISECONDS.sleep(300);
            } catch (InterruptedException e) {
                Thread.currentThread().interrupt();
            }

            System.out.println("进入" + Thread.currentThread().getName());
            LockSupport.park();
            System.out.println(Thread.currentThread().getName() + "被唤醒");
        }, "t1");

        t1.start();


        /**
         * 线程2
         */
        Thread t2 = new Thread(() -> {
            System.out.println("进入" + Thread.currentThread().getName());
            LockSupport.unpark(t1);
            System.out.println("唤醒通知已发");
        }, "t2");

        t2.start();
    }
}

效果:

进入t2
唤醒通知已发
进入t1
t1被唤醒 

演示多次调用unpark+多次调用park导致线程不能被唤醒:

package com.lc.test02;

import java.util.concurrent.TimeUnit;
import java.util.concurrent.locks.LockSupport;

/**
 * @author liuchao
 * @date 2023/4/8
 */
public class ThreadWaitThree {


    public static void main(String[] args) {

        /**
         * 线程1
         */
        Thread t1 = new Thread(() -> {
            System.out.println("进入" + Thread.currentThread().getName());
            /**
             * 调用两次park方法
             */
            LockSupport.park();
            LockSupport.park();
            System.out.println(Thread.currentThread().getName() + "被唤醒");
        }, "t1");

        t1.start();
        try {
            //等待300毫秒,让t2先执行
            TimeUnit.MILLISECONDS.sleep(300);
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
        }

        /**
         * 线程2
         */
        Thread t2 = new Thread(() -> {
            System.out.println("进入" + Thread.currentThread().getName());
            /**
             * 调用了两次park我们调用三次unpark 还是无法唤醒t1线程的
             */
            LockSupport.unpark(t1);
            LockSupport.unpark(t1);
            LockSupport.unpark(t1);
            System.out.println("唤醒通知已发");
        }, "t2");

        t2.start();
    }
}

 

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

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

相关文章

linux实时性分析

什么是实时操作系统 操作系统的实时性是指执行一个特定任务的时间是确定的和可预测的,这个任务执行时限需要考虑任何的情况,包括最恶劣的情况。或者说操作系统能够在规定的时间点内完成指定的任务操作,一旦超过这个时间点会对整个系统带来不…

【探花交友】day01—项目介绍与环境搭建

目录 1、项目介绍 1.1、功能列表 1.2、项目背景 1.3、功能概述 1.4、技术方案 1.5、技术解决方案 2、前后端分离 2.1、前后端分离的概述 2.2、YAPI介绍 3、开发工具 3.1、虚拟机配置 3.2、Android模拟器 3.3、调试工具PostMan 4、环境搭建 4.1、MYSQL数据库 4.…

【JAVA程序设计】(C00127)基于SSM+vue开发的音乐播放管理系统-有文档

基于SSMvue开发的音乐管理系统-有文档项目简介项目获取开发环境项目技术运行截图项目简介 基于ssm框架vue以及html前台的开发的音乐管理系统共分为二个角色:管理员、用户 管理员角色包含以下功能: 登录、个人中心(修改密码、个人信息修改&am…

溯源取证-内存取证 高难度篇

今天的场景依然是windows场景,只不过此次场景分为两个镜像,本次学习主要学习如何晒别钓鱼邮件、如何提取钓鱼邮件、如何修复损坏的恶意文件、如何提取DLL动态链接库文件 本次需要使用的工具: volatility_2.6_lin64_standalone readpst clams…

c++11 标准模板(STL)(std::unordered_multimap)(十三)

定义于头文件 <unordered_map> template< class Key, class T, class Hash std::hash<Key>, class KeyEqual std::equal_to<Key>, class Allocator std::allocator< std::pair<const Key, T> > > class unordered…

交互式电子沙盘数字沙盘大数据系统开发第8课

交互式电子沙盘数字沙盘大数据系统开发第8课 这次我们完成的功能为拖动一个外部的UI对象到球球上&#xff1a; private void Button_PreviewMouseMove(object sender, MouseEventArgs e) { if(e.LeftButton MouseButtonState.Pressed) DragDr…

Vue简易便签实现

Vue简易便签实现 html部分 <!DOCTYPE html> <html lang"en"> <head><meta charset"UTF-8"><meta name"viewport" content"widthdevice-width, initial-scale1.0"><meta http-equiv"X-UA-Comp…

ChatGPT这么强,你该怎么办?

总编说&#xff1a;《生命3.0》给未来选择工作的人提出的建议显得更加重要。泰格玛克认为&#xff0c;未来选择工作前需要询问三个问题&#xff1a;是否需要与人打交道&#xff0c;运用社交智慧&#xff1f;是否需要创造力&#xff0c;解决复杂问题&#xff1f;是否需要在不确定…

leetcode1306.跳跃游戏

跳跃游戏 -这里有一个非负整数数组 arr&#xff0c;你最开始位于该数组的起始下标 start 处。当你位于下标 i 处时&#xff0c;你可以跳到 i arr[i] 或者 i - arr[i]。 请你判断自己是否能够跳到对应元素值为 0 的 任一 下标处。 注意&#xff0c;不管是什么情况下&#xff…

不会吧?该不会还有企业没实现员工赋能吧!要我说,选低代码就对了!

员工作为企业的重要生产力要素&#xff0c;员工赋能一直是企业经营者重点关注的领域。 在大部分企业经营实践中&#xff0c;员工赋能由人力资源部门负责&#xff0c;赋能的主要形式是集中培训&#xff0c;其结果往往是业务繁忙时&#xff0c;人力组织难度大、业务部门参与意愿低…

深度剖析JVM三个面试常考知识点

目录 &#x1f433;今日良言:只要你足够努力,生命都会庇佑你 &#x1f407;一、JVM内存区域划分 &#x1f407;二、类加载过程 &#x1f407;三、垃圾回收机制(GC) &#x1f433;今日良言:只要你足够努力,生命都会庇佑你 &#x1f407;一、JVM内存区域划分 先来了解一下什…

MySql的sql_mode

文章目录简介查看命令配置文件设置命令配置文件常用的模式ONLY_FULL_GROUP_BYNO_AUTO_VALUE_ON_ZEROSTRICT_TRANS_TABLESNO_ZERO_IN_DATENO_ZERO_DATEERROR_FOR_DIVISION_BY_ZERONO_AUTO_CREATE_USERNO_ENGINE_SUBSTITUTIONPIPES_AS_CONCATANSI_QUOTES专栏目录请点击 简介 他是…

【通过Cpython3.9源码看看列表到底是咋回事】

列表结构 typedef struct {PyObject_VAR_HEAD/* Vector of pointers to list elements. list[0] is ob_item[0], etc. */PyObject **ob_item;/* ob_item contains space for allocated elements. The number* currently in use is ob_size.* Invariants:* 0 < ob_siz…

vulnhub DC:3.2渗透笔记

kali ip :192.168.20.130 靶机下载地址:https://www.vulnhub.com/entry/dc-32,312/ 信息收集 扫描靶机ip以及开放端口 开放了80端口访问一下 Welcome to DC-3. This time, there is only one flag, one entry point and no clues. To get the flag, youll obviously have …

【Java版oj】day29求正数数组的最小不可组成和、有假币

目录 一、求正数数组的最小不可组成和 &#xff08;1&#xff09;原题再现 &#xff08;2&#xff09;问题分析 &#xff08;3&#xff09;完整代码 二、有假币 &#xff08;1&#xff09;原题再现 &#xff08;2&#xff09;问题分析 &#xff08;3&#xff09;完整代码…

三、用户与权限管理

五、角色管理 1、角色的理解 引入角色的目的时方便管理相同权限的用户。只需要给相同权限的用户分配角色即可&#xff0c;而不需要分配具体的权限 2、创建角色 创建角色使用 CREATE ROLE 语句&#xff0c;语法如下&#xff1a; CREATE ROLE role_name[host_name] [,role_…

干货分享 | 常用车载总线CAN、CANFD、LIN、FlexRay 和 Ethernet概述

随着现代汽车的电子化程度越来越高&#xff0c;汽车总线系统也变得越来越复杂。汽车总线测试是一项重要的任务&#xff0c;它有助于确定车辆电子系统中的问题&#xff0c;并保障车辆的安全和可靠性。本文将介绍五种常见的汽车总线系统和相关的测试工具。 CAN总线 …… 控制器…

传输线的物理基础(八):用近似值和二维场计算特性阻抗

设计一个特定的目标特性阻抗实际上是调整线宽、电介质厚度和介电常数的问题。如果我们知道传输线的长度和导体周围材料的介电常数&#xff0c;并且我们可以计算出特征阻抗&#xff0c;我们就可以使用上面的关系来计算所有其他参数。 当然&#xff0c;每一种不同类型的横截面几…

kaggle竞赛 - Stable Diffusion - Image to Prompts

演绎提示&#xff0c;生成我们的“高度详细&#xff0c;锐利的焦点&#xff0c;插图&#xff0c;宏伟&#xff0c;史诗”图像的3d渲染 1.比赛目标 这个竞赛的目标不是从文本提示生成图像&#xff0c;而是创建一个模型&#xff0c;可以在给定生成图像的情况下预测文本提示&…

曲线平滑算法:三次Hermite曲线生成

目录 1.三次Hermite曲线的参数方程 2. 三次Hermite曲线的绘制 Hermite曲线是通过给定曲线的两个端点的位置矢量、以及两个端点处的切线矢量、来描述曲线的&#xff0c;如图1所示。这里先对Hermite曲线进行数学公式推导&#xff0c;然后讲述如何绘制Hermite曲线。&#xff08;这…