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

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

时间:2023-08-07 10:01:22浏览次数:36  
标签:面试官 通讯 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://blog.51cto.com/vipstone/6991055

相关文章

  • 进程/线程模型
    进程/线程模型 进程模型 (一)多道程序设计 (Multiprogramming)允许多个程序同时进入内存并运行,其目的是为了提高系统效率。   并发环境与并发程序  并发环境:一段时间间隔内,单处理器上有两个或两个以上的程序同时处于开始运行但尚未结束的状态,并......
  • 线程
    程序、进程、线程程序:为完成某些特定任务,用某种语言编写的一组指令的集合,代码进程:程序的一次执行过程,正在运行的一个程序【这是一个动态过程,产生,存在,完成某些功能,消亡】线程:由进程创建的,是进程的一个实体,一个进程可以拥有多个线程【举个例子:一个正在读书并同时听音乐的人正在努力学......
  • 为什么不建议或不能用Executor去创建线程池?
    答:会存在内存溢出的风险。因为Executors中的核心方法,默认创建线程池的最大线程数是Integer.MAX_VALUE即int类型的最大值2^32-1,最大线程数允许这么多,几乎相当于不限制线程数,而这样的后果就是,如果瞬间请求量非常大,如果达到这个上限,没有任何服务器能够继续工作,肯定会抛出OOM异常。Ex......
  • linux修改线程数
    vim/etc/security/limits.d/90-nproc.conf查看核心线程数量ulimit-u......
  • 进程与线程
        ......
  • 第二章进程和线程
    2.1任务在操作系统层面,任务常常时代表进程的,比如windows是典型的多任务操作系统,指系统中可以同时运行多个进程。在CPU手册中,很多时候是使用"任务"来代之线程的,比如著名的多任务状态段(TaskStateSegmentTSS).就是用来记录每个线程的状态。CPU一级的任务很多时候相当于进......
  • 对线程join()方法的理解
    java线程的join()方法的理解thread.join()把指定的线程加入到当前线程,可以将两个交替执行的线程和并为顺序执行的线程。简单说就是同步。例1:比如在线程B中调用了线程A的join方法,直到线程A执行完毕后,才会继续执行线程B。例2:再比如我们做查询操作,总任务需要返回三个查询列......
  • Java多线程-龟兔赛跑
    Java多线程-龟兔赛跑packagecom.alibaba;publicclassTestThread003implementsRunnable{privateStringwinner;@Overridepublicvoidrun(){for(inti=0;i<=100;i++){booleanflag=getWinner(i);if(flag){......
  • 深入理解线程与进程:概念、特点与区别,附带代码演示
    当今计算机系统中,线程(Thread)和进程(Process)是并发编程中的关键概念。它们对于提高程序的效率和性能至关重要。本篇博客将详细介绍线程和进程的概念、特点以及它们之间的区别,同时通过代码演示来加深理解。1.线程1.1概念线程是操作系统能够进行运算调度的最小单位。一个进程可以包含......
  • 多线程访问数据库报错
    在用flask实现http服务器的时候,只需要指定路由和访问方法,前端的访问就可以获取到,然后触发后端的响应函数,如果后端响应函数用公用的sqlconnection的时候,可能会导致数据库连接冲突报错,报错内容如下:AttributeError:'NoneType'objecthasnoattribute'read' 参考这篇博客的解......