java八股文面试[多线程]——线程间通信方式

多个线程在并发执行的时候，他们在CPU中是随机切换执行的，这个时候我们想多个线程一起来完成一件任务，这个时候我们就需要线程之间的通信了，多个线程一起来完成一个任务，线程通信一般有4种方式：

通过 volatile 关键字
通过 Object类的 wait/notify 方法
通过 condition 的 await/signal 方法
通过 join 的方式

现在有一个问题，两个线程分别打印字符串，但是当线程A每输出两次的时候，线程B就输出一次，如此反复10次。

通过 volatile 关键字

通过 volatile 关键字来实现这个任务，这个也是最简单的一种实现方式，大致思路 volatile 是共享内存的，两个线程共享一个标志位，当标志位更改的时候就执行不同的线程。
 

public class VolatileDemo {private static volatile boolean flag = true;  //定义一个标志位，当标志位更改的时候不同的线程被执行public static void main(String[] args) {//线程A启动new Thread(() -> {int i = 0;while(true){  //进行死循环，一直输出语句if (flag){  //对标志位的判断，符合就执行System.out.println(Thread.currentThread().getName()+" ===>" + ++i); //输出语句if (i%2==0){  //如果语句输出两次了 改变标志位flag  =false;}if (i == 10) break;  //到达十次，结束循环}}}, "A").start();new Thread(() -> {int i = 0;while(true){if (!flag){  //判断条件不一样System.out.println(Thread.currentThread().getName()+" 被唤醒啦 " + ++i);flag  = true;  //改变标志位if (i == 5) break;}}}, "B").start();}
}

我们发现我们这个位置用的while循环的，用for循环指定次数可以吗，是不可以的，因为我们只是改变了标志位，但是并没有立刻唤醒另外一个线程让他执行，虽然我打印的语句是我被唤醒了，但是实际上只是线程A处于死循环，啥子也不做，直到线程B抢到了时间片，进行对标志位的判断，然后输出语句，在进行空循环，等待A抢到时间片，如此反复，可以自己在if判断外面加一条计数语句，来验证一下结果，如果想要立刻唤醒的话，那么就是另外一种方法啦。

通过 Object类的 wait/notify 方法

对于上面的volatile关键字这个方法来说，我们的线程执行了很多次空循环，来等待另外一个线程来获取锁，这种操作无疑是十分消耗CPU的资源的，所以说为了解决这种情况，我们就需要一种机制可以实现线程之间的通信，可以唤醒其他的线程，而不是等待直到自己获取CPU的时间片，我们都知道，Object类提供了三个线程间通信的方法，wait()，notify()，notifyAll()。这三个方法必须都在同步代码块中执行的。

方法名具体操作
wait()wait()方法执行前，是必须要获得对应的锁的，当执行wait()方法后，线程就会释放掉自己所占有的锁，释放CPU，然后进入阻塞状态，直到被notify()方法唤醒。
notify()会唤醒一个处于等待该对象锁的线程，然后继续往下执行，直到执行完退出对象锁锁住的区域（synchronized修饰的代码块）后再释放锁。
notifyAll()和notify()方法差不多，只不过他是唤醒所有等待该对象锁的线程，让他们进入就绪队列，但是谁执行就看谁抢占到CPU，notify()方法也是这样，只不过是唤醒随机的一个而已

每个锁对象都有两个队列，一个是就绪队列，一个是阻塞队列。就绪队列存储了已就绪（将要竞争锁）的线程，阻塞队列存储了被阻塞的线程。当一个阻塞线程被唤醒后，才会进入就绪队列，进而等待CPU的调度；反之，当一个线程被wait后，就会进入阻塞队列，等待被唤醒。

public class WaitAndNotify {public static void main(String[] args) {Object lock = new Object();  //创建一个锁对象new Thread(() -> {for (int i = 1; i <= 10; i++) {synchronized (lock) {  //首先需要获取锁System.out.println(Thread.currentThread().getName() + " ==> " + i);if (i % 2 == 0) {lock.notify();  //唤醒线程Bif (i!=10){try {lock.wait();  //让自己等待} catch (InterruptedException e) {e.printStackTrace();}}}}}}, "A").start();new Thread(() -> {for (int i = 1; i <= 5; i++) {synchronized (lock) {lock.notify();  //我们看到，执行notify方法时，后面的代码还是执行了，并不是立刻释放资源System.out.println(Thread.currentThread().getName() + "我执行了notify方法 " + i);if (i!=5){try {lock.wait();} catch (InterruptedException e) {e.printStackTrace();}}}}}, "B").start();}
}

通过上面的代码我们发现，当执行notify方法时，我们并不会立刻释放锁资源，而是在执行完我们代码块里面的内容时才会释放掉锁资源，而wait()方法则会立刻释放掉锁资源，进入阻塞状态，这里我们有举例子，可以自己在wait()方法后面加上一个输出语句。我们进行交替通信的规则就是，执行wait(）方法，释放掉锁资源，然后执行 notify() 方法，唤醒其他的线程，在代码中，我在wait()方法上加了一个判断，如果是最后一次的话，那么我就不执行，为什么，因为我在执行wait()方法的时候，那么线程除非被唤醒，否则就会一直阻塞，这样的话我们的demo就不可以结束了，一直处于允许状态。

通过 condition 的 await/signal 方法

Condiction对象是通过lock对象来创建得(调用lock对象的newCondition()方法)，他在使用前也是需要获取锁得，其中，Lock 替代了 synchronized 方法和语句的使用，Condition 替代了 Object 监视器方法的使用。Condiction对象得常用方法：

await() : 线程自主释放锁，进入沉睡状态，直到被再次唤醒。
await(long time, TimeUnit unit) ：线程自主释放锁，进入沉睡状态，被唤醒或者未到达等待时间时一直处于等待状态。
signal()： 唤醒一个等待线程。
signal()All() ：唤醒所有等待线程,能够从等待方法返回的线程必须获得与Condition相关的锁。

    public static void main(String[] args) {//设置一个锁Lock lock = new ReentrantLock();Condition condition = lock.newCondition();AtomicInteger number = new AtomicInteger(1);AtomicInteger count = new AtomicInteger(1);new Thread(()->{while (count.get() != 10){lock.lock();try {count.getAndIncrement();if (number.get() != 1 && count.get() != 11){condition.await();}number.getAndIncrement();System.out.println(Thread.currentThread().getName() + "---> 生产");condition.signalAll();}catch (Exception e){e.printStackTrace();}finally {lock.unlock();}}},"producter").start();new Thread(()->{while (count.get() != 10 ){lock.lock();try {count.getAndIncrement();if (number.get() != 2 && count.get() != 11){condition.await();}number.getAndDecrement();System.out.println(Thread.currentThread().getName() + "---> 消费");condition.signalAll();}catch (Exception e){e.printStackTrace();}finally {lock.unlock();}}},"customer").start();}

await操作会立刻释放掉锁，进入阻塞状态，singal会唤醒等待队列中的头节点(失败就依次唤醒)。这个代码逻辑有大问题，只是这样写看得出数据之间的交换即可。注意点：代码一定要在lock和unlock之间。

通过 join 方法来实现线程通信
    public static void main(String[] args) throws InterruptedException {Thread A = new Thread(() -> {System.out.println("执行完毕");},"A");Thread B = new Thread(()->{try {Thread.sleep(1000L);System.out.println(Thread.currentThread().getName() + "测试join");} catch (InterruptedException e) {e.printStackTrace();}},"B");A.start();B.start();B.join();System.out.println("Main线程");}

简单来说，就是join方法会让自己提前执行，比如上面的例子中就是让Main线程阻塞了，等待B线程执行完毕后才会执行。本质就是调用了wait方法，让当前线程阻塞，直到另一个线程执行完毕。(当前线程wait后，执行join方法的线程大概率抢到锁资源，而且当一个线程执行完毕后，会默认调用notifyAll方法。)

小结
其实准确来说，应该只有三种可以通信的方式，join只是让当前线程先执行完，并没有说根据两个线程之间数据的共享。

线程之间的通信方式主要有以下几种：


共享变量：线程之间可以通过共享变量来进行通信。不同的线程可以共享同一个变量，并在变量上进行读写操作。需要注意的是，共享变量可能会引发线程安全问题，需要通过同步机制来确保线程安全。

锁机制：锁机制是一种常用的线程同步机制，可以保证在同一时间只有一个线程能够访问共享资源。Java提供了多种锁类型，如 synchronized 关键字、ReentrantLock 类等。

条件变量：条件变量是一种线程间通信机制，它用于在一个共享资源上等待某个条件的成立。Java 提供了 Condition 接口来支持条件变量的实现，在使用 Condition 时需要先获取锁，然后调用 await() 方法等待条件成立，当条件成立时可以通过 signal() 或 signalAll() 方法唤醒等待该条件的线程。

信号量：信号量是一种常见的线程同步机制，可用于控制多个线程对共享资源的访问。Java 提供了 Semaphore 类来实现信号量，Semaphore 类有两个常用的方法 acquire() 和 release()，分别用于获取和释放信号量。

管道：管道是一种用于线程间通信的高级机制，它可以实现一个线程向另一个线程传送数据。Java 提供了 PipedInputStream 和 PipedOutputStream 两个类来支持管道的实现，其中 PipedInputStream 用于读取数据，PipedOutputStream 用于写入数据。

需要注意的是，以上通信方式都需要在多线程程序中谨慎使用，需要考虑线程安全和性能等方面的问题。为了确保程序正确、高效地运行，需要根据具体情况选择合适的线程通信方式，并进行相应的测试和优化。

具体的示例
共享变量
public class SharedData {private int value;public synchronized int getValue() { return value; }public synchronized void setValue(int value) { this.value = value; }
}

   在这个示例中，定义了一个共享数据类 SharedData，其中包含一个整型变量 value 和两个同步方法 getValue() 和 setValue()，用于获取和设置变量的值。由于这两个方法都是同步的，因此多个线程可以安全地访问该变量。

public class SharedDataExample {public static void main(String[] args) throws InterruptedException {SharedData sharedData = new SharedData();Thread thread1 = new Thread(() -> {for (int i = 0; i < 10; i++) {sharedData.setValue(i);System.out.println(Thread.currentThread().getName() + " write " + sharedData.getValue());try {Thread.sleep(100);} catch (InterruptedException e) {e.printStackTrace();}}});Thread thread2 = new Thread(() -> {for (int i = 0; i < 10; i++) {System.out.println(Thread.currentThread().getName() + " read " + sharedData.getValue());try {Thread.sleep(100);} catch (InterruptedException e) {e.printStackTrace();}}});thread1.start();thread2.start();thread1.join();thread2.join();}
}

在这个示例中，创建了两个线程分别用于读写共享数据 SharedData，多次执行该示例可以看到控制台输出表明两个线程在安全地访问共享变量。

锁机制
public class LockExample {private static Lock lock = new ReentrantLock();private static int count = 0;private static void increase() {lock.lock();try {count++;} finally {lock.unlock();}}public static void main(String[] args) throws InterruptedException {Thread thread1 = new Thread(() -> {for (int i = 0; i < 10000; i++) {increase();}});Thread thread2 = new Thread(() -> {for (int i = 0; i < 10000; i++) {increase();}});thread1.start();thread2.start();thread1.join();thread2.join();System.out.println(count);}
}

在这个示例中，使用了 Lock 接口和 ReentrantLock 类来对计数器进行同步，多次执行该示例可以看到最终输出的计数器值为 20000。

信号量
public class SemaphoreExample {private static Semaphore semaphore = new Semaphore(2);private static void doWork() throws InterruptedException {semaphore.acquire();System.out.println(Thread.currentThread().getName() + " start working");Thread.sleep(1000);System.out.println(Thread.currentThread().getName() + " finish working");semaphore.release();}public static void main(String[] args) throws InterruptedException {Thread thread1 = new Thread(() -> {try {doWork();} catch (InterruptedException e) {e.printStackTrace();}});Thread thread2 = new Thread(() -> {try {doWork();} catch (InterruptedException e) {e.printStackTrace();}});Thread thread3 = new Thread(() -> {try {doWork();} catch (InterruptedException e) {e.printStackTrace();}});thread1.start();thread2.start();thread3.start();thread1.join();thread2.join();thread3.join();}
}

  在这个示例中，使用了 Semaphore 类来定义了一个信号量，线程1、线程2、线程3都需要获取信号量才能进行工作，每次执行 doWork() 方法需要占用资源，执行完毕后释放信号量。

管道
public class PipeExample {static class WriterThread extends Thread {private PipedOutputStream output;WriterThread(PipedOutputStream output) {this.output = output;}@Overridepublic void run() {try {for(int i=1;i<=10;i++) {output.write(i);System.out.println("写入数据：" + i);Thread.sleep(1000);}} catch(Exception e) {e.printStackTrace();} finally {try {output.close();} catch(Exception e) {e.printStackTrace();}}}}static class ReaderThread extends Thread {private PipedInputStream input;ReaderThread(PipedInputStream input) {this.input = input;}@Overridepublic void run() {try {int value;while((value=input.read()) != -1) {System.out.println("读取数据：" + value);}} catch(Exception e) {e.printStackTrace();} finally {try {input.close();} catch(Exception e) {e.printStackTrace();}}}}public static void main(String[] args) throws IOException {PipedOutputStream output = new PipedOutputStream();PipedInputStream input = new PipedInputStream(output);Thread thread1 = new WriterThread(output);Thread thread2 = new ReaderThread(input);thread1.start();thread2.start();try {thread1.join();thread2.join();} catch (InterruptedException e) {e.printStackTrace();}}
}

在这个示例中，使用了 PipedOutputStream 类和 PipedInputStream 类来定义了一个管道，线程1向管道中写入数据，线程2从管道中读取数据，通过管道来实现两个线程之间的通信。

知识来源：

【23版面试突击】 在Java中线程间有哪些通信方式？_哔哩哔哩_bilibili

线程通信的四种方式_我是哎呀呀的博客-CSDN博客

Java线程之间如何通信的，有哪些方式？_java线程间通信的几种方法_Ascend1797的博客-CSDN博客

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

如若内容造成侵权/违法违规/事实不符，请联系长河编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

TypeScript_树结构-BST树

TypeScript_树结构-BST树

树结构 树的特点 树通常有一个根。连接着根的是树干树干到上面之后会进行分叉成树枝&#xff0c;树枝还会分又成更小的树枝在树枝的最后是叶子 树的抽象 树可以模拟生活中的很多场景&#xff0c;比如&#xff1a;公司组织架构、家谱、DOM Tree、电脑文件夹架构 优秀的哈希函…
阅读更多...
STM32 SPI对存储芯片发送写是能命令后一直忙等待

STM32 SPI对存储芯片发送写是能命令后一直忙等待

我采用CUBE配置的SPI外设&#xff0c;对NSS引脚选择了硬件输出&#xff0c;这种方式对读取命令没有影响&#xff0c;但是对写命令有&#xff0c;当我发送写是能命令后&#xff0c;读取状态寄存器的值一直都是忙&#xff0c;我猜测这可能是硬件控制NSS引脚后&#xff0c;对于HAL…
阅读更多...
如何用Jmeter编写脚本压测？

如何用Jmeter编写脚本压测？

随着商业业务不断扩张&#xff0c;调用adsearch服务频率越来越高&#xff0c;所以这次想做个压测&#xff0c;了解目前多少并发量可以到达adsearch服务的界值。 这次选用的jmeter压测工具&#xff0c;压测思路如图&#xff1a; 一、日志入参 日志选取的adsearch 的 getads部分…
阅读更多...
WEB APIs day6

WEB APIs day6

一、正则表达式 RegExp是正则表达式的意思 <!DOCTYPE html> <html lang"en"><head><meta charset"UTF-8"><meta http-equiv"X-UA-Compatible" content"IEedge"><meta name"viewport" co…
阅读更多...
二叉树的介绍及二叉树的链式结构的实现（C语言版）

二叉树的介绍及二叉树的链式结构的实现（C语言版）

前言 二叉树是一种特殊的树&#xff0c;它最大的度为2&#xff0c;每个节点至多只有两个子树。它是一种基础的数据结构&#xff0c;后面很多重要的数据结构都是依靠它来进行实现的。了解并且掌握它是很重要的。 目录 1.二叉树的介绍 1.1概念 1.2现实中的二叉树 1.3特殊的二叉…
阅读更多...
QCAD for Mac免费下载：卓越的2D辅助设计工具

QCAD for Mac免费下载：卓越的2D辅助设计工具

QCAD是一款功能强大的2D辅助设计画图软件&#xff0c;现已适配Mac系统&#xff0c;为Mac用户提供了便捷高效的设计工具。 QCAD提供了丰富的绘图功能&#xff0c;可以轻松绘制各种平面图形&#xff0c;包括直线、圆、椭圆、弧线等。 同时&#xff0c;QCAD还支持多种绘图工具&am…
阅读更多...
树莓 LUMA-OLED.EXAMPLE使用

树莓 LUMA-OLED.EXAMPLE使用

详细介绍在文件目录下的README.rst中 第一步 $ sudo usermod -a -G i2c,spi,gpio pi //好像没什么用 $ sudo apt install python3-dev python3-pip python3-numpy libfreetype6-dev libjpeg-dev build-essential //安装依赖包&#xff0c;树莓派中好像已经有了 $ sudo a…
阅读更多...
linux信号量

linux信号量

通过学习linux的信号量&#xff0c;对linux的信号量进行了编程。
阅读更多...
iPhone 15 Pro展示设计：7项全新变化呈现

iPhone 15 Pro展示设计：7项全新变化呈现

我们不应该再等iPhone 15 Pro在苹果9月12日的“Wonderlust”活动上发布了&#xff0c;而且可能会有很多升级。有传言称&#xff0c;iPhone 15 Pro将是自iPhone X以来最大的飞跃&#xff0c;这要归功于大量的新变化&#xff0c;从带有更薄边框的新钛框架到顶级A17仿生芯片和动作…
阅读更多...
Burp插件HaE与Authz用法

Burp插件HaE与Authz用法

HaE与Authz均为BurpSuite插件生态的一员&#xff0c;两者搭配可以避免“越权”、“未授权”两类漏洞的重复测试行为。&#xff08;适用于业务繁杂&#xff0c;系统模块功能多的场景&#xff09; 两个插件都可以在store里安装 安装完后&#xff0c;点击Filter Settings勾选Sho…
阅读更多...
构建稳定的爬虫系统：如何选择合适的HTTP代理服务商

构建稳定的爬虫系统：如何选择合适的HTTP代理服务商

在构建一个稳定、高效的爬虫系统中&#xff0c;选择合适的HTTP代理服务商是至关重要的一步。本文将介绍如何选取可靠且性能优秀的HTTP代理服务供应商&#xff0c;来完成搭建一个强大而稳定的爬虫系统。 1.了解不同类型和特点 -免费公开代理服务器:提供免费但可能存在限制或不…
阅读更多...
整数拆分【动态规划】

整数拆分【动态规划】

整数拆分 给定一个正整数 n &#xff0c;将其拆分为 k 个 正整数 的和&#xff08; k > 2 &#xff09;&#xff0c;并使这些整数的乘积最大化。 返回 你可以获得的最大乘积 。 class Solution {public int integerBreak(int n) {int[] dp new int[n 1];//正整数&#x…
阅读更多...
mysql数据库使用技巧整理

mysql数据库使用技巧整理

查看当前数据库已建立的client连接 > SHOW VARIABLES LIKE max_connections; -- 查看数据库允许的最大连接数&#xff0c;不是实时正在使用的连接数 > SHOW STATUS LIKE Threads_connected; -- 查看当前数据库client的连接数 > SHOW PROCESSLIST; -- 查看具体的连接
阅读更多...
【jsvue】联合gtp仿写一个简单的vue框架，以此深度学习JavaScript

【jsvue】联合gtp仿写一个简单的vue框架，以此深度学习JavaScript

用 gtp 学习 Vue 生命周期的原理 lifecycle.js function Vue(options) {// 将选项保存到实例的 $options 属性中this.$options options;// 若存在 beforeCreate 钩子函数&#xff0c;则调用之if (typeof options.beforeCreate function) {options.beforeCreate.call(this);…
阅读更多...
类和对象(中)

类和对象(中)

&#x1f493;博主个人主页:不是笨小孩&#x1f440; ⏩专栏分类:数据结构与算法&#x1f440; C&#x1f440; 刷题专栏&#x1f440; C语言&#x1f440; &#x1f69a;代码仓库:笨小孩的代码库&#x1f440; ⏩社区&#xff1a;不是笨小孩&#x1f440; &#x1f339;欢迎大…
阅读更多...
vs2008下的mfc hello world实现

vs2008下的mfc hello world实现

笔者不知道会写这种博文&#xff0c;好久没写mfc程序&#xff0c;hello world都不会创建了。起因是来了个mfc任务&#xff0c;那就得把mfc熟悉起来&#xff0c;先看下实现效果吧 因为是基于2008的&#xff0c;那就按照2008创建吧 文章目录 第一步&#xff1a;文件新建项目第二…
阅读更多...
【二等奖方案】大规模金融图数据中异常风险行为模式挖掘赛题「冀科数字」解题思路

【二等奖方案】大规模金融图数据中异常风险行为模式挖掘赛题「冀科数字」解题思路

第十届CCF大数据与计算智能大赛&#xff08;2022 CCF BDCI&#xff09;已圆满结束&#xff0c;大赛官方竞赛平台DataFountain&#xff08;简称DF平台&#xff09;正在陆续释出各赛题获奖队伍的方案思路&#xff0c;欢迎广大数据科学家交流讨论。 本方案为【大规模金融图数据中…
阅读更多...
CS420 课程笔记 P4 - 以16进制形态编辑游戏文件

CS420 课程笔记 P4 - 以16进制形态编辑游戏文件

文章目录 IntroductionFinding save filesStringsUnicodeExample!Value searchHealth searchConclusion Introduction 这节课我们将学习编辑十六进制&#xff0c;主要用于编辑保存文件&#xff0c;但十六进制编辑涉及的技能可以很好地转移到&#xff1a; Save file editingRe…
阅读更多...
python数据分析基础—取某列字符的前几个字符

python数据分析基础—取某列字符的前几个字符

文章目录 前言取某列前几个字符方法一&#xff1a;[x[:7] for x in data["calling_nbr"]]方法二&#xff1a;data[calling_nbr].str[:7] 前言 在进行数据分析时&#xff0c;有时候我们需要提取单列的前几个字符串进行分析。本文主要讲述针对这种情况处理方法。 取某…
阅读更多...
Keil Flash的下载算法

Keil Flash的下载算法

更进一步的了解Keil Flash的下载算法 前面提到了通用算法的选择&#xff0c;那么问题来了&#xff0c;这个算法文件如何来的呢&#xff1f;如果你所用的MCU不是默认支持的品牌&#xff0c;如何编写属于自己的算法呢&#xff1f; 工具/原料 Keil uVision ULINK2仿真器 方法/…
阅读更多...
最新文章
推荐文章

Copyright @ 2022~2023