关键词：
本文源码：GitHub·点这里 || GitEE·点这里一、概念简介
1、线程通信
在操作系统中，线程是个独立的个体，但是在线程执行过程中，如果处理同一个业务逻辑，可能会产生资源争抢，导致并发问题，通常使用互斥锁来控制该逻辑。但是在还有这样一类场景，任务执行是有顺序控制的，例如常见的报表数据生成：
- 启动数据分析任务，生成报表数据；
- 报表数据存入指定位置数据容器；
- 通知数据搬运任务，把数据写入报表库；
该场景在相对复杂的系统中非常常见，如果基于多线程来描述该过程，则需要线程之间通信协作，才能有条不紊的处理该场景业务。
2、等待通知机制
如上的业务场景，如果线程A生成数据过程中，线程B一直在访问数据容器，判断该过程的数据是否已经生成，则会造成资源浪费。正常的流程应该如图，线程A和线程B同时启动，线程A开始处理数据生成任务，线程B尝试获取容器数据，数据还没过来，线程B则进入等待状态，当线程A的任务处理完成，则通知线程B去容器中获取数据，这样基于线程等待和通知的机制来协作完成任务。
3、基础方法
等待/通知机制的相关方法是Java中Object层级的基础方法，任何对象都有该方法：
- notify：随机通知一个在该对象上等待的线程，使其结束wait状态返回；
- notifyAll：唤醒在该对象上所有等待的线程，进入对象锁争抢队列中；
- wait：线程进入waiting等待状态，不会争抢锁对象，也可以设置等待时间；
线程的等待通知机制，就是基于这几个基础方法。
二、等待通知原理
1、基本原理
等待/通知机制，该模式下指线程A在不满足任务执行的情况下调用对象wait()方法进入等待状态，线程B修改了线程A的执行条件，并调用对象notify()或者notifyAll()方法，线程A收到通知后从wait状态返回，进而执行后续操作。两个线程通过基于对象提供的wait()/notify()/notifyAll()等方法完成等待和通知间交互，提高程序的可伸缩性。
2、实现案例
通过线程通信解决上述数据生成和存储任务的解耦流程。
public class NotifyThread01 {
static Object lock = new Object() ;
static volatile List<String> dataList = new ArrayList<>();
public static void main(String[] args) throws Exception {
Thread saveThread = new Thread(new SaveData(),"SaveData");
saveThread.start();
TimeUnit.SECONDS.sleep(3);
Thread dataThread = new Thread(new AnalyData(),"AnalyData");
dataThread.start();
}
// 等待数据生成，保存
static class SaveData implements Runnable {
@Override
public void run() {
synchronized (lock){
while (dataList.size()==0){
try {
System.out.println(Thread.currentThread().getName()+"等待...");
lock.wait();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
System.out.println("SaveData .."+ dataList.get(0)+dataList.get(1));
}
}
}
// 生成数据，通知保存
static class AnalyData implements Runnable {
@Override
public void run() {
synchronized (lock){
dataList.add("hello,");
dataList.add("java");
lock.notify();
System.out.println("AnalyData End...");
}
}
}
}注意：除了dataList满足写条件，还要在AnalyData线程执行通知操作。
三、管道流通信
1、管道流简介
基本概念
管道流主要用于在不同线程间直接传送数据，一个线程发送数据到输出管道，另一个线程从输入管道中读取数据，进而实现不同线程间的通信。
实现分类
管道字节流：PipedInputStream和PipedOutputStream；
管道字符流：PipedWriter和PipedReader；
新IO管道流：Pipe.SinkChannel和Pipe.SourceChannel；
2、使用案例
public class NotifyThread02 {
public static void main(String[] args) throws Exception {
PipedInputStream pis = new PipedInputStream();
PipedOutputStream pos = new PipedOutputStream();
// 链接输入流和输出流
pos.connect(pis);
// 写数据线程
new Thread(new Runnable() {
public void run() {
BufferedReader br = new BufferedReader(new InputStreamReader(System.in));
// 将从键盘读取的数据写入管道流
PrintStream ps = new PrintStream(pos);
while (true) {
try {
System.out.print(Thread.currentThread().getName());
ps.println(br.readLine());
Thread.sleep(1000);
} catch (Exception e) {
e.printStackTrace();
}
}
}
}, "输入数据线程：").start();
// 读数据线程
new Thread(new Runnable() {
public void run() {
BufferedReader br = new BufferedReader(new InputStreamReader(pis));
while (true) {
try {
System.out.println(Thread.currentThread().getName() + br.readLine());
} catch (IOException e) {
e.printStackTrace();
}
}
}
}, "输出数据线程：").start();
}
}写线程向管道流写入数据，读线程读取数据，完成基本通信流程。
四、生产消费模式
1、业务场景
基于线程等待通知机制：实现工厂生产一件商品，通知商店卖出一件商品的业务流程。
2、代码实现
public class NotifyThread03 {
public static void main(String[] args) {
Product product = new Product();
ProductFactory productFactory = new ProductFactory(product);
ProductShop productShop = new ProductShop(product);
productFactory.start();
productShop.start();
}
}
// 产品
class Product {
public String name ;
public double price ;
// 产品是否生产完毕,默认没有
boolean flag ;
}
// 产品工厂：生产
class ProductFactory extends Thread {
Product product ;
public ProductFactory (Product product){
this.product = product;
}
@Override
public void run() {
int i = 0 ;
while (i < 20) {
synchronized (product) {
if (!product.flag){
if (i%2 == 0){
product.name = "鼠标";
product.price = 79.99;
} else {
product.name = "键盘";
product.price = 89.99;
}
System.out.println("产品："+product.name+"【价格："+product.price+"】出厂...");
product.flag = true ;
i++;
// 通知消费者
product.notifyAll();
} else {
try {
// 进入等待状态
product.wait();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
}
}
}
// 产品商店：销售
class ProductShop extends Thread {
Product product ;
public ProductShop (Product product){
this.product = product ;
}
@Override
public void run() {
while (true) {
synchronized (product) {
if (product.flag == true ){
System.out.println("产品:"+product.name+"【价格"+(product.price*2)+"】卖出...");
product.flag = false ;
product.notifyAll(); //唤醒生产者
} else {
try {
product.wait();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
}
}
}流程描述：ProductFactory生成一件商品，通知商店售卖，通过flag标识判断控制是否进入等待状态，商店卖出商品后，再次通知工厂生产商品。
五、源代码地址
GitHub·地址
https://github.com/cicadasmile/java-base-parent
GitEE·地址
https://gitee.com/cicadasmile/java-base-parent
| 序号 | 文章标题 |
|---|---|
| 01 | Java并发：线程的创建方式，状态周期管理 |
| 02 | Java并发：线程核心机制，基础概念扩展 |
| 03 | Java并发：多线程并发访问，同步控制 |
java并发编程之十二：线程间通信中notifyall造成的早期通知问题（含代码）
如果线程在等待时接到通知，但线程等待的条件还不满足，此时，线程接到的就是早期通知，如果条件满足的时间很短，但很快又改变了，而变得不再满足，这时也将发生早期通知。这种现象听起来很... 查看详情
java并发编程线程间协作
线程间协作1.等待和通知等待和通知的标准形式等待方：获取对象锁循环中判断条件是否满足，不调用wait()方法条件满足执行业务逻辑通知方：获取对象所改变条件通知所有等待在对象的线程2.wait、notify/notifyAllwait：导致当前线... 查看详情
java并发编程（10）:使用wait/notify/notifyall实现线程间通信的几点重要说明
在Java中，可以通过配合调用Object对象的wait（）方法和notify（）方法或notifyAll（）方法来实现线程间的通信。在线程中调用wait（）方法，将阻塞等待其他线程的通知（其他线程调用notify（）方法或notifyAll（）方法），在线程中调... 查看详情
java多线程编程核心技术读书笔记-线程通信
线程是操作系统中独立的个体，但是这些个体如果无法经过特殊的处理就不能成为一个整体。线程间通信可以实现线程间的信息互换、相互唤起等功能，是系统的交互性更加强大，大大提高CPU的利用率，同时还能让开发者对... 查看详情
《java并发编程的艺术》读后笔记-part4(代码片段)
文章目录《Java并发编程的艺术》读后笔记-part4第四章Java并发编程基础1.线程简介1.1什么是线程？1.2为什么要使用多线程？1.3线程优先级1.4线程的状态1.5Daemon线程2.启动和终止线程2.1构造线程2.2启动线程2.3理解中断3.线程间... 查看详情
java并发编程系列21|condition-lock的等待通知
Java并发编程系列21|Condition-Lock的等待通知收录于话题#进阶架构师|并发编程专题12个点击上方“java进阶架构师”，选择右上角“置顶公众号”20大进阶架构专题每日送达我们知道synchronized锁通过Object类的wait()和notify()方法实现线程... 查看详情
尚硅谷juc高并发编程学习笔记线程通信与集合线程安全(代码片段)
一、线程间通信线程间通信的模型有两种：共享内存和消息传递线程间的通信具体步骤：（涉及上中下部）1、创建资源类，在资源类中船舰属性和操作方法2、在资源类操作方法：判断、操作、通知3、创建... 查看详情
多线程编程学习三(线程间通信)
一、概要 线程是操作系统中独立的个体，但这些个体如果不经过特殊的处理就不能成为一个整体，线程间的通信就是成为整体的必用方案之一。可以说，使线程进行通信后，系统之间的交互性会更强大，在大大提高cpu利... 查看详情
尚硅谷juc高并发编程学习笔记线程通信与集合线程安全(代码片段)
一、线程间通信线程间通信的模型有两种：共享内存和消息传递线程间的通信具体步骤：（涉及上中下部）1、创建资源类，在资源类中船舰属性和操作方法2、在资源类操作方法：判断、操作、通知3、创建... 查看详情
并发编程线程间通信的方式
管道流Pipes“管道”是java.io包的一部分，它是Java的特性。而不是Android特有的。一条“管道”为两个线程建立一个单向的通道。生产者负责写数据。消费者负责读取数据。publicclassPipeExampleActivityextendsActivity{privatestaticfinalStringTAG="P... 查看详情
java并发编程线程简介(进程与线程|并发概念|线程间通信|java并发3特性)(代码片段)
文章目录一、进程与线程二、并发三、线程间通信四、Java并发3特性一、进程与线程最开始是没有线程这个概念的,一个应用程序就是一个进程,应用程序运行时,如果还要处理与用户交互的逻辑,二者只能交替进行,这样CPU执行效率... 查看详情
java线程与并发编程实践----等待通知(生产者消费者问题)线程
Java提供了一套API来支持线程之间的交互。在Object类中提供了一套等待通知的API wait() notify() notifyAll() 此处要注意的是，绝不 查看详情
java并发线程通信
一、概述1.1什么是多线程之间通讯？1.2案例代码实现解决线程安全问题二、等待通知机制2.1示例2.2wait与sleep区别三、Lock锁3.1概述3.2等待/通知机制(Condition)3.3Lock与synchronized比较一、概述1.1什么是多线程之间通讯？多线程之间通讯... 查看详情
java基础教程：多线程基础——线程间的通信
Java基础教程：多线程基础（2）——线程间的通信使线程间进行通信后，系统之间的交互性会更强大，在大大提高CPU利用率的同时还会使程序员对各线程任务在处理的过程中进行有效的把控与监督。线程间的通信思维导图 等... 查看详情
day826.java多线程等待&通知机制-java并发编程实战(代码片段)
Java多线程等待&通知机制Hi，我是阿昌，今天学习记录的是关于用“Java多线程等待&通知机制的内容。死锁问题，在破坏占用且等待条件的时候，如果转出账本和转入账本不满足同时在文件架上这个条件，... 查看详情
day826.java多线程等待&通知机制-java并发编程实战(代码片段)
Java多线程等待&通知机制Hi，我是阿昌，今天学习记录的是关于用“Java多线程等待&通知机制的内容。死锁问题，在破坏占用且等待条件的时候，如果转出账本和转入账本不满足同时在文件架上这个条件，... 查看详情
java并发编程--并发编程线程基础（线程创建与运行线程通知与等待join/sleep/yield方法线程中断线程上下文切换死锁守护线程与用户线程threadlocal）
文章目录1.并发编程线程基础（上篇）1.1线程基础知识1.1.1程序1.2.2进程1.3.3线程1.3.4小结1.2线程创建与运行1.2.1继承Thread类方式的实现1.2.2实现Runnable接口的run方法方式1.2.3使用FutureTask的方式1.3线程通知与等待1.3.1wait（&#... 查看详情
java并发编程--并发编程线程基础（线程创建与运行线程通知与等待join/sleep/yield方法线程中断线程上下文切换死锁守护线程与用户线程threadlocal）(代码片段)
文章目录1.并发编程线程基础（上篇）1.1线程基础知识1.1.1程序1.2.2进程1.3.3线程1.3.4小结1.2线程创建与运行1.2.1继承Thread类方式的实现1.2.2实现Runnable接口的run方法方式1.2.3使用FutureTask的方式1.3线程通知与等待1.3.1wait（&#... 查看详情