首页 > 其他分享 >面试官:线程是如何通讯的?

面试官:线程是如何通讯的?

时间:2023-08-03 16:22:48浏览次数:29  
标签:面试官 通讯 lock Object LockSupport 线程 唤醒 Condition

线程通信是指多个线程之间通过某种机制进行协调和交互,例如,线程等待和通知机制就是线程通讯的主要手段之一。

在 Java 中,线程等待和通知的实现手段有以下几种方式:

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

为什么一个线程等待和通知机制就需要这么多的实现方式呢?别着急,咱们先来看实现,再来说原因。

一、wait/notify/notifyAll

Object 类的方法说明:

  1. wait():让当前线程处于等待状态,并释放当前拥有的锁;
  2. notify():随机唤醒等待该锁的其他线程,重新获取锁,并执行后续的流程,只能唤醒一个线程;
  3. notifyAll():唤醒所有等待该锁的线程(锁只有一把,虽然所有线程被唤醒,但所有线程需要排队执行)。

示例代码如下:

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(3000);
        } catch (InterruptedException e) {
            throw new RuntimeException(e);
        }
        System.out.println("线程1:执行完成");
    }
}).start();

Thread.sleep(1000);
synchronized (lock) {
    // 唤醒线程
    System.out.println("执行 notifyAll()");
    lock.notifyAll();
}

二、await/signal/signalAll

Condition 类的方法说明:

  1. await():对应 Object 的 wait() 方法,线程等待;
  2. signal():对应 Object 的 notify() 方法,随机唤醒一个线程;
  3. signalAll():对应 Object 的 notifyAll() 方法,唤醒所有线程。

示例代码如下:

// 创建 Condition 对象
Lock lock = new ReentrantLock();
Condition condition = lock.newCondition(); // lock 下可创建多个 Condition
// 加锁
lock.lock();
try {
    // 业务方法......
    // 1.进入等待状态
    condition.await();
    // 2.唤醒操作
    condition.signal();
} catch (InterruptedException e) {
    e.printStackTrace();
} finally {
    lock.unlock();
}

三、park/unpark

LockSupport 类的方法说明:

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

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

示例代码如下:

public static void main(String[] args) throws InterruptedException {
    Thread t1 = new Thread(() -> {
        LockSupport.park();
        System.out.println("线程1");
    }, "线程1");
    t1.start();
    Thread t2 = new Thread(() -> {
        try {
            Thread.sleep(1000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        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 对象
private Lock lock = new ReentrantLock();
// 生产者的 Condition 对象
private Condition producerCondition = lock.newCondition();
// 本篇内容出自磊哥《Java面试突击训练营》 VX:GG_Stone
// 消费者的 Condition 对象
private Condition consumerCondition = lock.newCondition();

也就是 Condition 是 Object 等待唤醒模型的升级,Object 类可以实现的功能它都能实现,但 Condition 能实现的功能,Object 却不能实现,这就是 Condition 类存在的必要性。

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

标签:面试官,通讯,lock,Object,LockSupport,线程,唤醒,Condition
From: https://www.cnblogs.com/vipstone/p/17603642.html

相关文章

  • pytest 中添加线程
    #D:\pythonProject0726\test_case\test_one.pyimporttimedefsetup_module():print('准备测试数据')defteardown_module():print('清理测试数据')deftest_one():ex=1real=1time.sleep(3)print('1==1')assert......
  • 养鸡场损失背后,是通讯故障还是数据大危机
    近日,一场特殊的案件完成了判决,由于设备发生通信故障导致风机停止工作,进而导致1466只养殖的蛋鸡死亡,造成了巨额财产损失。最终,提供物联网终端设备的神桥公司被判处承担农场的70%的赔偿责任。虽然被答辩人未公开表示是否会继续上诉,但该判决结果在二审法院中并未获得支持,但这起案件对......
  • 8 个线程池最佳实践和坑!使用不当直接生产事故!!
    这篇文章我会简单总结一下我了解的使用线程池的时候应该注意的坑以及一些优秀的实践。拿来即用,美滋滋!内容概览:Java指南:https://java-family.cn1、正确声明线程池线程池必须手动通过 ThreadPoolExecutor 的构造函数来声明,避免使用Executors 类创建线程池,会有OOM风险。Ex......
  • 养鸡场损失背后,是通讯故障还是数据大危机
     近日,一场特殊的案件完成了判决,由于设备发生通信故障导致风机停止工作,进而导致1466只养殖的蛋鸡死亡,造成了巨额财产损失。最终,提供物联网终端设备的神桥公司被判处承担农场的70%的赔偿责任。虽然被答辩人未公开表示是否会继续上诉,但该判决结果在二审法院中并未获得支持,但这起......
  • 【Java】多线程面试题总结
    最近在看面试题,所以想用自己的理解总结一下,便于加深印象。为什么使用多线程使用多线程可以充分利用CPU,提高CPU的使用率。提高系统的运行效率,对于一些复杂或者耗时的功能,可以对其进行拆分,比如将某个任务拆分了A、B、C三个子任务,如果子任务之间没有依赖关系,那么就可以使用多线程......
  • Java面试题 P42:框架篇:Spring-Spring框架中的单例bean是线程安全的吗?Spring框架中的bea
        ......
  • 为什么有了gil锁还要互斥锁、 进程,线程和协程 、什么是鸭子类型
    目录1为什么有了gil锁还要互斥锁互斥锁保证数据安全2进程,线程和协程在哪用过3什么是鸭子类型1为什么有了gil锁还要互斥锁gil:全局解释器锁,线程要执行,必须先获得到gil锁,才能执行互斥锁:为了保证多线程并发操作数据(变量)而设置的锁,保证在加锁和释放锁之间,其他线程不能操作gi......
  • 3 Linux多线程开发
    3Linux多线程开发3.1线程概述3.1.1线程概述与进程(process)类似,线程(thread)是允许应用程序并发执行多个任务的一种机制。一个进程可以包含多个线程。同一个程序中的所有线程均会独立执行相同程序,且共享同一份全局内存区域,其中包括初始化数据段、未初始化数据段,以及堆内存段。(......
  • 【Jmeter】跨线程获取cookie值
    1、设置配置文件:apache-jmeter-5.5\bin\jmeter.properties#CookieManagerbehaviour-shouldCookiesbestoredasvariables?#DefaultisfalseCookieManager.save.cookies=true2、线程_登录:2.1、http请求右键_添加_后置处理器_正则表达式提取器 正则表达式:satoken=(......
  • 线程池怎么用?--实例讲解
    线程池使用实例先写一个配置类/***线程池配置*/@ConfigurationpublicclassThreadPoolConfig{//定义线程前缀publicstaticfinalStringNAME_PRE="test";/***ExecutorService这个对象就是线程池,可以点进去他的源码看看*@Bean,将ge......