线程是如何通讯的?【Object Conditon LockSupport】

2024-01-06 21:04

本文主要是介绍线程是如何通讯的?【Object Conditon LockSupport】,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

线程是如何通讯的?

    • 一、Object 类下的 wait()、notify() 和 notifyAll) 方法方法说明:
    • 二、Condition 类下的 await()、signal() 和 signalAll() 方法方法说明:
    • 三、LockSupport 下的 park() 和 unpark() 方法

线程等待和通知机制就是线程通讯的主要手段
在 Java 中,线程通讯的实现方法主要有以下几种:

  1. Object 类下的 wait()、notify() 和 notifyAll() 方法
  2. Condition 类下的 await()、 signal() 和 signalAll() 方法
  3. LockSupport 类下的 park()和 unpark() 方法

一、Object 类下的 wait()、notify() 和 notifyAll) 方法方法说明:

  1. wait(): 让当前线程处于等待状态,并释放当前拥有的锁
  2. notify(): 随机唤醒等待该锁的其他线程,重新获取锁,并执行后续的流程,只能唤醒一个线程
  3. notifyAll(): 唤醒所有等待该锁的线程(锁只有一把,虽然所有线程被唤醒,但所有线程需要排队执行)。
class ObjectCommunicate {public static void main(String[] args) throws InterruptedException {Object lock = new Object();// 创建线程并执行new Thread(() -> {System.out.println("线程1: 开始执行");synchronized (lock) {try {System.out.println("线程1: 进入等待");lock.wait();System.out.println("线程1: 继续执行");Thread.sleep(300);} catch (InterruptedException e) {throw new RuntimeException(e);}System.out.println("线程1: 执行完成");}}).start();Thread.sleep(1090);synchronized (lock) {// 唤醒线程System.out.println("执行 notifyAl1()");lock.notifyAll();}}
}

二、Condition 类下的 await()、signal() 和 signalAll() 方法方法说明:

  1. await(): 对应 Object 的 wait() 方法,线程等待;
  2. signal(): 对应 Object 的 notify() 方法,随机唤醒一个线程
  3. signalAll(): 对应 Object 的 notifyAll() 方法,唤醒所有线程。
class ConditionCommunicate {public static void main(String[] args) {Lock lock = new ReentrantLock();Condition condition = lock.newCondition();Condition condition2 = lock.newCondition();lock.lock();try {condition.await();condition.signal();} catch (InterruptedException e) {throw new RuntimeException(e);} finally {lock.unlock();}}
}

三、LockSupport 下的 park() 和 unpark() 方法

方法说明:

  1. LockSupport.park(): 休眠当前线程
  2. LockSupport.unpark(线程对象): 唤醒某一个指定的线程

PS: LockSupport 无需配锁 (synchronized 或 Lock) 一起使用。

class LockSupportCommunicate {public static void main(String[] args) {Thread t1 = new Thread(() -> {LockSupport.park();System.out.println("线程1");},"线程1");t1.start();Thread t2 = new Thread(() -> {try {Thread.sleep(1000);} catch (InterruptedException e) {throw new RuntimeException(e);}System.out.println("唤醒线程1");LockSupport.unpark(t1);},"线程2");t2.start();}
}

为什么一个线程等待和唤醒的功能需要这么多的实现呢?

  1. LockSupport 必要性: 前两种方法 notify 方法以及 signal 方法都是随机唤醒,如果存在多个等待线程的话,可能会唤醒不应该唤醒的线程,因此有 LockSupport 类下的 park 和 unpark 方法指定唤醒线程是非常有必要的
  2. Condition 必要性: Condition 相比于 Object 类的 wait 和 notify/notifyAll 方法,前者可以创建多个等待集:防止生产者唤醒生产者,让生产者只能唤醒消费者 这样才好

Condition 能实现的功能,Obiect 却不能实现,这就是 Condition 类存在的必要性。那问题来了,为什么还有会 Object 的 wait 和 notify 方法呢?因为 Object 类诞生的比较早,也就是说 Condition 和 Locksupport 都是 JDK 后期版本才出现的功能,所以就有了现在这么多线程唤醒和等待的方法了。

这篇关于线程是如何通讯的?【Object Conditon LockSupport】的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/577601

相关文章

Spring Boot3虚拟线程的使用步骤详解

《SpringBoot3虚拟线程的使用步骤详解》虚拟线程是Java19中引入的一个新特性,旨在通过简化线程管理来提升应用程序的并发性能,:本文主要介绍SpringBoot3虚拟线程的使用步骤,... 目录问题根源分析解决方案验证验证实验实验1:未启用keep-alive实验2:启用keep-alive扩展建

Java终止正在运行的线程的三种方法

《Java终止正在运行的线程的三种方法》停止一个线程意味着在任务处理完任务之前停掉正在做的操作,也就是放弃当前的操作,停止一个线程可以用Thread.stop()方法,但最好不要用它,本文给大家介绍了... 目录前言1. 停止不了的线程2. 判断线程是否停止状态3. 能停止的线程–异常法4. 在沉睡中停止5

如何使用C#串口通讯实现数据的发送和接收

《如何使用C#串口通讯实现数据的发送和接收》本文详细介绍了如何使用C#实现基于串口通讯的数据发送和接收,通过SerialPort类,我们可以轻松实现串口通讯,并结合事件机制实现数据的传递和处理,感兴趣... 目录1. 概述2. 关键技术点2.1 SerialPort类2.2 异步接收数据2.3 数据解析2.

Java捕获ThreadPoolExecutor内部线程异常的四种方法

《Java捕获ThreadPoolExecutor内部线程异常的四种方法》这篇文章主要为大家详细介绍了Java捕获ThreadPoolExecutor内部线程异常的四种方法,文中的示例代码讲解详细,感... 目录方案 1方案 2方案 3方案 4结论方案 1使用 execute + try-catch 记录

Spring Boot 中正确地在异步线程中使用 HttpServletRequest的方法

《SpringBoot中正确地在异步线程中使用HttpServletRequest的方法》文章讨论了在SpringBoot中如何在异步线程中正确使用HttpServletRequest的问题,... 目录前言一、问题的来源:为什么异步线程中无法访问 HttpServletRequest?1. 请求上下文与线

在 Spring Boot 中使用异步线程时的 HttpServletRequest 复用问题记录

《在SpringBoot中使用异步线程时的HttpServletRequest复用问题记录》文章讨论了在SpringBoot中使用异步线程时,由于HttpServletRequest复用导致... 目录一、问题描述:异步线程操作导致请求复用时 Cookie 解析失败1. 场景背景2. 问题根源二、问题详细分

Java多线程父线程向子线程传值问题及解决

《Java多线程父线程向子线程传值问题及解决》文章总结了5种解决父子之间数据传递困扰的解决方案,包括ThreadLocal+TaskDecorator、UserUtils、CustomTaskDeco... 目录1 背景2 ThreadLocal+TaskDecorator3 RequestContextH

java父子线程之间实现共享传递数据

《java父子线程之间实现共享传递数据》本文介绍了Java中父子线程间共享传递数据的几种方法,包括ThreadLocal变量、并发集合和内存队列或消息队列,并提醒注意并发安全问题... 目录通过 ThreadLocal 变量共享数据通过并发集合共享数据通过内存队列或消息队列共享数据注意并发安全问题总结在 J

异步线程traceId如何实现传递

《异步线程traceId如何实现传递》文章介绍了如何在异步请求中传递traceId,通过重写ThreadPoolTaskExecutor的方法和实现TaskDecorator接口来增强线程池,确保异步... 目录前言重写ThreadPoolTaskExecutor中方法线程池增强总结前言在日常问题排查中,

Java中Object类的常用方法小结

《Java中Object类的常用方法小结》JavaObject类是所有类的父类,位于java.lang包中,本文为大家整理了一些Object类的常用方法,感兴趣的小伙伴可以跟随小编一起学习一下... 目录1. public boolean equals(Object obj)2. public int ha