线程是如何通讯的?【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

相关文章

Springboot的ThreadPoolTaskScheduler线程池轻松搞定15分钟不操作自动取消订单

《Springboot的ThreadPoolTaskScheduler线程池轻松搞定15分钟不操作自动取消订单》:本文主要介绍Springboot的ThreadPoolTaskScheduler线... 目录ThreadPoolTaskScheduler线程池实现15分钟不操作自动取消订单概要1,创建订单后

C语言线程池的常见实现方式详解

《C语言线程池的常见实现方式详解》本文介绍了如何使用C语言实现一个基本的线程池,线程池的实现包括工作线程、任务队列、任务调度、线程池的初始化、任务添加、销毁等步骤,感兴趣的朋友跟随小编一起看看吧... 目录1. 线程池的基本结构2. 线程池的实现步骤3. 线程池的核心数据结构4. 线程池的详细实现4.1 初

深入探讨Java 中的 Object 类详解(一切类的根基)

《深入探讨Java中的Object类详解(一切类的根基)》本文详细介绍了Java中的Object类,作为所有类的根类,其重要性不言而喻,文章涵盖了Object类的主要方法,如toString()... 目录1. Object 类的基本概念1.1 Object 类的定义2. Object 类的主要方法3. O

Java子线程无法获取Attributes的解决方法(最新推荐)

《Java子线程无法获取Attributes的解决方法(最新推荐)》在Java多线程编程中,子线程无法直接获取主线程设置的Attributes是一个常见问题,本文探讨了这一问题的原因,并提供了两种解决... 目录一、问题原因二、解决方案1. 直接传递数据2. 使用ThreadLocal(适用于线程独立数据)

Java Websocket实例【服务端与客户端实现全双工通讯】

Java Websocket实例【服务端与客户端实现全双工通讯】 现很多网站为了实现即时通讯,所用的技术都是轮询(polling)。轮询是在特定的的时间间隔(如每1秒),由浏览器对服务器发 出HTTP request,然后由服务器返回最新的数据给客服端的浏览器。这种传统的HTTP request 的模式带来很明显的缺点 – 浏 览器需要不断的向服务器发出请求,然而HTTP

线程的四种操作

所属专栏:Java学习        1. 线程的开启 start和run的区别: run:描述了线程要执行的任务,也可以称为线程的入口 start:调用系统函数,真正的在系统内核中创建线程(创建PCB,加入到链表中),此处的start会根据不同的系统,分别调用不同的api,创建好之后的线程,再单独去执行run(所以说,start的本质是调用系统api,系统的api

java线程深度解析(六)——线程池技术

http://blog.csdn.net/Daybreak1209/article/details/51382604 一种最为简单的线程创建和回收的方法: [html]  view plain copy new Thread(new Runnable(){                @Override               public voi

java线程深度解析(五)——并发模型(生产者-消费者)

http://blog.csdn.net/Daybreak1209/article/details/51378055 三、生产者-消费者模式     在经典的多线程模式中,生产者-消费者为多线程间协作提供了良好的解决方案。基本原理是两类线程,即若干个生产者和若干个消费者,生产者负责提交用户请求任务(到内存缓冲区),消费者线程负责处理任务(从内存缓冲区中取任务进行处理),两类线程之

java线程深度解析(四)——并发模型(Master-Worker)

http://blog.csdn.net/daybreak1209/article/details/51372929 二、Master-worker ——分而治之      Master-worker常用的并行模式之一,核心思想是由两个进程协作工作,master负责接收和分配任务,worker负责处理任务,并把处理结果返回给Master进程,由Master进行汇总,返回给客

java线程深度解析(二)——线程互斥技术与线程间通信

http://blog.csdn.net/daybreak1209/article/details/51307679      在java多线程——线程同步问题中,对于多线程下程序启动时出现的线程安全问题的背景和初步解决方案已经有了详细的介绍。本文将再度深入解析对线程代码块和方法的同步控制和多线程间通信的实例。 一、再现多线程下安全问题 先看开启两条线程,分别按序打印字符串的