Kotlin 协程 (三)

协程通信是协程之间进行数据交换和同步的关键机制。Kotlin 协程提供了多种通信方式，使得协程能够高效、安全地进行交互。以下是对协程通信的详细讲解，包括常见的通信原语、使用场景和示例代码。

1.1 Channel

定义：Channel 是一个消息队列，用于协程之间的通信。它允许协程发送和接收数据，类似于 MPI（Message Passing Interface）中的消息传递机制。

特点：

  • 线程安全。
  • 支持多种通信模式，如无缓冲、有缓冲和无限缓冲。
  • 提供挂起函数 send 和 receive，用于发送和接收数据。
  • 可以关闭。

Channel 类型

类型描述创建方式适用场景
Rendezvous无缓冲（默认）Channel<T>()严格的发送-接收同步
Buffered固定大小缓冲Channel<T>(capacity)控制内存使用
Conflated保留最新值Channel<T>(CONFLATED)只需要最新数据
Unlimited无限缓冲Channel<T>(UNLIMITED)生产者快于消费者
Broadcast广播给多个接收者BroadcastChannel<T>(capacity)一对多通信

使用场景：

1.生产者-消费者模式
  • 场景描述：一个或多个生产者协程生成数据，一个或多个消费者协程处理数据。
  • 适用性：当数据需要按顺序处理时，Channel 提供了天然的 FIFO 队列。
  • 示例：文件处理流水线，其中文件读取、处理和写入由不同的协程完成。
2 .协程间的事件总线
  • 场景描述：一个协程发送事件，多个协程监听并响应这些事件。
  • 适用性：当需要解耦协程之间的通信时，Channel 可以作为事件传递的媒介。
  • 示例：在 GUI 应用中，用户操作（如按钮点击）通过 Channel 发送事件，不同的协程根据事件执行相应的逻辑。
3. 资源池管理
  • 场景描述：多个协程需要共享一组有限资源，如数据库连接或网络请求。
  • 适用性：Channel 可以控制对资源的并发访问，避免资源争用导致的冲突。
  • 示例：使用 Channel 作为资源池，协程从池中请求资源，使用完毕后释放回池中

示例：

fun main() = runBlocking {val channel = Channel<Int>() // 创建无缓冲通道// 生产者协程launch {for (x in 1..5) {println("Sending $x")channel.send(x) // 挂起直到有接收者delay(100) // 模拟工作}channel.close() // 关闭通道}// 消费者协程launch {for (y in channel) { // 使用for循环接收println("Received $y")}println("Channel is closed")}delay(2000)
}
1.2 Flow

定义：Flow 是一种冷流（cold stream），意味着数据流只有在收到收集（collection）请求时才会开始发射数据。它支持挂起操作，可以与协程完美结合，实现异步计算和数据处理。

特点：

  • 异步数据流：以异步方式处理连续数据流。
  • 声明式编程：通过操作符链式调用处理数据流。
  • 可组合性：支持 map、filter、flatMap、zip 等操作符。
  • 取消支持：与协程一样支持取消操作。

基本使用：

//使用 flow 建造器创建一个 Flow 对象。
fun transformFlow() = flow {for (i in 1..5) {delay(100)emit(i)}
}.map { it * 2 } // 将每个值乘以 2.filter { it > 4 } // 过滤掉小于等于 4 的值fun main() = runBlocking {
//使用 collect 函数收集 Flow 发射的数据。transformFlow().collect { value -> println("Transformed value: $value")}
}

使用场景：

1 .异步数据流处理
  • 场景描述：对异步数据流进行转换、合并、过滤等操作。
  • 适用性：当需要对数据流进行复杂的操作时，Flow 提供了丰富的操作符。
  • 示例：在数据处理管道中，使用 Flow 对数据进行映射、过滤和归约。
2. 网络请求与数据解析
  • 场景描述：从网络获取数据，并进行解析和转换。
  • 适用性：Flow 可以与网络库（如 Retrofit）结合，简化异步网络请求的处理。
  • 示例：使用 Flow 处理分页网络请求，逐页获取数据并进行解析。
3. 数据库查询与观察
  • 场景描述：从数据库查询数据，并对结果进行观察。
  • 适用性：Flow 可以与数据库库（如 Room）结合，实现数据的异步查询和实时更新。
  • 示例：在 Android 应用中，使用 Flow 监听数据库表的变化，并更新 UI。

示例：

import retrofit2.Retrofit
import retrofit2.converter.gson.GsonConverterFactory
import retrofit2.http.GET
import kotlinx.coroutines.*interface ApiService {@GET("data")fun fetchData(): Flow<String>
}val apiService = Retrofit.Builder().baseUrl("https://api.example.com").addConverterFactory(GsonConverterFactory.create()).build().create(ApiService::class.java)fun main() = runBlocking {apiService.fetchData().flowOn(Dispatchers.IO) // 在 IO 线程上执行网络请求.collect { data ->println("Received data: $data")}
}
1.3 SharedFlow 和 StateFlow

定义：SharedFlow 和 StateFlow 是 Kotlin Flow 库中的两种特殊 Flow，用于在多个收集器之间共享状态和数据流。

特点：

  • SharedFlow：热流，允许多个收集器接收数据，可配置重放（replay）和缓冲，不保存状态。
  • StateFlow：特殊的 SharedFlow，必须有初始值，只保留最新值，并在收集器加入时立即发出当前状态。

使用场景：

1. 事件流共享
  • 场景描述：多个协程需要共享同一个事件流，并且每个协程都能接收到事件。
  • 适用性：当事件需要被多个订阅者处理，且每个订阅者都能独立地接收事件时。
  • 示例：在实时数据应用中，传感器数据通过 SharedFlow 分发给多个处理单元。
2 状态广播
  • 场景描述：一个协程更新状态，多个协程监听状态变化。
  • 适用性：当状态变化需要通知给多个观察者时，SharedFlow 提供了广播机制。
  • 示例：在游戏开发中，玩家状态（如生命值、分数）通过 SharedFlow 广播给 UI 和逻辑处理单元。
3. 背压管理
  • 场景描述：生产者生成数据的速度可能快于消费者处理数据的速度。
  • 适用性：SharedFlow 支持背压策略，可以控制数据的发送速度，避免消费者过载。
  • 示例：在数据流处理中，使用 SharedFlow 缓解高速数据源对处理单元的压力。

示例：

import kotlinx.coroutines.*
import kotlinx.coroutines.flow.*fun main() = runBlocking {val sharedFlow = MutableSharedFlow<String>()// 事件发送协程launch {sharedFlow.emit("Event 1")delay(1000)sharedFlow.emit("Event 2")}// 事件监听协程 1launch {sharedFlow.collect { event ->println("Listener 1 received: $event")}}// 事件监听协程 2launch {sharedFlow.collect { event ->println("Listener 2 received: $event")}}delay(2000) // 等待事件处理完成coroutineContext.cancelChildren() // 取消所有子协程
}
1.4 Await 和 Async

定义：async 是一种启动协程并获取其结果的方式。await 用于等待 async 协程的结果。

特点：

  • async 会立即返回一个 Deferred 对象，可以在需要时通过 await 获取结果。
  • 支持结构化并发，await 会在需要时挂起协程，直到结果准备好。

使用场景：

  • 当需要并行执行任务并聚合结果时。
  • 当需要按需获取协程结果时。

示例：

 import kotlinx.coroutines.*suspend fun main() {val deferred = async { expensiveComputation() }val result = deferred.await()println("Result: $result")}suspend fun expensiveComputation(): Int {delay(1000)return 42}
1.5 Actor

定义：Actor 是结合了协程和通道的实体，封装了状态和处理消息的能力。

特点：

  • 消息传递：Actor 之间通过发送和接收消息进行通信。
  • 封装状态：每个 Actor 封装了自己的状态和行为，其他 Actor 无法直接访问其内部状态。
  • 异步通信：通过消息传递实现异步交互，避免传统并发模型中的死锁和竞争问题。

使用场景：

  • 分布式系统：在分布式环境中，Actor 可以作为独立的计算单元，通过消息传递完成协同任务。
  • 实时通信：适用于需要实时处理消息的场景，如聊天应用、游戏服务器等。
  • 高并发任务处理：处理需要同时执行多个任务的应用，例如订单处理、数据分析等。

示例：

import kotlinx.coroutines.*
import kotlinx.coroutines.channels.*fun main() = runBlocking {val actor = actor<String> {//Actor 内部通过 for 循环接收来自 channel 的消息，并执行相应的处理逻辑。for (msg in channel) {println("Received: $msg")// 处理消息}}// 向 Actor 发送消息actor.send("Hello")actor.send("World")actor.close() // 关闭 Actor
}

2. 示例：实时搜索场景
class SearchViewModel : ViewModel() {// 使用 MutableStateFlow 存储可变的搜索查询字符串// StateFlow 是热流，会自动收集数据，适合 UI 状态管理private val searchQuery = MutableStateFlow("")// 使用 MutableStateFlow 存储可变的搜索结果列表// 注意：这里返回的 searchResults 是不可变的 StateFlow，避免外部直接修改private val _searchResults = MutableStateFlow<List<String>>(emptyList())val searchResults: StateFlow<List<String>> = _searchResultsinit {// 在 viewModelScope 中启动协程// viewModelScope 是 ViewModel 提供的协程作用域，基于 Dispatchers.Main 运行// 当 ViewModel 销毁时，viewModelScope 会自动取消所有协程，避免内存泄漏viewModelScope.launch {// 构建 Flow 管道，处理搜索查询到结果的转换searchQuery// debounce(300)：防抖处理，300ms 内多次输入只触发最后一次// 避免用户快速输入时触发过多搜索请求.debounce(300)// filter it.length > 2：过滤短查询，避免无效请求// 只有查询长度大于 2 时才继续处理.filter { it.length > 2 }// distinctUntilChanged()：忽略重复的查询，避免重复请求// 只有查询内容变化时才继续处理.distinctUntilChanged()// flatMapLatest：取消前一个未完成的搜索，只保留最新的查询结果// 当新的查询到来时，会取消前一个协程任务.flatMapLatest { query ->// 调用 performSearch 发起搜索，返回 Flow<List<String>>performSearch(query)}// catch emit(emptyList())：捕获异常并返回空列表，避免 UI 出错// 如果搜索过程中发生异常，会发射空列表作为默认结果.catch { emit(emptyList()) }// collect：收集 Flow 发射的数据，更新搜索结果.collect { results ->// 更新 _searchResults 的值，UI 会自动响应变化_searchResults.value = results}}}// 处理用户输入变化，更新搜索查询fun onSearchQueryChanged(query: String) {// 直接设置 MutableStateFlow 的值，会触发 Flow 管道重新计算searchQuery.value = query}// 模拟网络搜索请求，返回 Flow<List<String>>private fun performSearch(query: String): Flow<List<String>> = flow {// delay(1000)：模拟耗时操作（如网络请求），可被协程取消// 如果协程被取消，delay 会立即抛出 CancellationExceptiondelay(1000)// emit：发射搜索结果// 这里模拟返回两个结果项emit(listOf("query result 1", "query result 2"))}
}

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

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

相关文章

使用SQLite Studio导出/导入SQL修复损坏的数据库

使用SQLite Studio导出/导入SQL修复损坏的数据库

使用SQLite Studio导出/导入SQL修复损坏的数据库 使用Zotero时遇到了数据库损坏&#xff0c;在软件中寸步难行&#xff0c;遂尝试修复数据库。 一、SQLite Studio简介 SQLite Studio是一款专为SQLite数据库设计的免费开源工具&#xff0c;支持Windows/macOS/Linux。相较于其…
阅读更多...
【git config --global alias | Git分支操作效率提升实践指南】

【git config --global alias | Git分支操作效率提升实践指南】

git config --global alias | Git分支操作效率提升实践指南 背景与痛点分析 在现代软件开发团队中&#xff0c;Git分支管理是日常工作的重要组成部分。特别是在规范的开发流程中&#xff0c;我们经常会遇到类似 feature/user-management、bugfix/login-issue 或 per/cny/dev …
阅读更多...
（八）深度学习---计算机视觉基础

（八）深度学习---计算机视觉基础

分类问题回归问题聚类问题各种复杂问题决策树√线性回归√K-means√神经网络√逻辑回归√岭回归密度聚类深度学习√集成学习√Lasso回归谱聚类条件随机场贝叶斯层次聚类隐马尔可夫模型支持向量机高斯混合聚类LDA主题模型 一.图像数字化表示及建模基础 二.卷积神经网络CNN基本原…
阅读更多...
在tensorflow源码环境里，编译出独立的jni.so，避免依赖libtensorflowlite.so，从而实现apk体积最小化

在tensorflow源码环境里，编译出独立的jni.so，避免依赖libtensorflowlite.so，从而实现apk体积最小化

需要在APP里使用tensorflow lite来运行PC端训练的model.tlite&#xff0c;又想apk的体积最小&#xff0c;尝试了如下方法&#xff1a; 1. 在gradle里配置 implementation("org.tensorflow:tensorflow-lite:2.16.1") 这样会引入tensorflow.jar&#xff0c;最终apk的…
阅读更多...
neo4j框架：java安装教程

neo4j框架：java安装教程

安装使用neo4j需要事先安装好java&#xff0c;java版本的选择是一个犯难的问题。本文总结了在安装java和使用Java过程中遇到的问题以及相应的解决方法。 Java的安装包可以在java官方网站Java Downloads | Oracle 中国进行下载 以java 8为例&#xff0c;选择最后一行的x64 compr…
阅读更多...
[服务器备份教程] Rclone实战：自动备份数据到阿里云OSS/腾讯云COS等对象存储

[服务器备份教程] Rclone实战：自动备份数据到阿里云OSS/腾讯云COS等对象存储

更多服务器知识&#xff0c;尽在hostol.com 各位服务器的守护者们&#xff0c;咱们都知道&#xff0c;数据是数字时代的“黄金”&#xff0c;而服务器上的数据更是我们业务的命脉。可天有不测风云&#xff0c;硬盘可能会突然“寿终正寝”&#xff0c;手滑执行了“毁灭性”命令…
阅读更多...
Nextjs App Router 开发指南

Nextjs App Router 开发指南

Next.js是一个用于构建全栈web应用的React框架。App Router 是 nextjs 的基于文件系统的路由器&#xff0c;它使用了React的最新特性&#xff0c;比如 Server Components, Suspense, 和 Server Functions。 术语 树(Tree): 一种用于可视化的层次结构。例如&#xff0c;包含父…
阅读更多...
山东大学计算机图形学期末复习15——CG15

山东大学计算机图形学期末复习15——CG15

CG15 OpenGL缓冲区、读写操作以及混合&#xff08;Blending&#xff09; 一、OpenGL缓冲区概述 OpenGL中的缓冲区是用于存储像素数据的内存区域&#xff0c;主要包括以下类型&#xff1a; 颜色缓冲区&#xff08;Color Buffer&#xff09;&#xff1a;存储每个像素的颜色值…
阅读更多...
html+css+js趣味小游戏~记忆卡片配对（附源码）

html+css+js趣味小游戏~记忆卡片配对（附源码）

下面是一个简单的记忆卡片配对游戏的完整代码&#xff0c;使用HTML、CSS和JavaScript实现&#xff1a; html <!DOCTYPE html> <html lang"zh"> <head><meta charset"UTF-8"><meta name"viewport" content"wid…
阅读更多...
⼀个并发访问量⽐较⼤的key在某个时间过期，在redis中这个时间过期什么意思

⼀个并发访问量⽐较⼤的key在某个时间过期，在redis中这个时间过期什么意思

在 Redis 中&#xff0c;当提到一个键&#xff08;key&#xff09;“在这个时间过期”&#xff0c;指的是为该键设置了生存时间&#xff08;TTL, Time To Live&#xff09;或过期时间&#xff08;expiration time&#xff09;。一旦到达设定的过期时间&#xff0c;Redis 会自动…
阅读更多...
【设计模式】- 行为型模式1

【设计模式】- 行为型模式1

模板方法模式 定义了一个操作中的算法骨架&#xff0c;将算法的一些步骤推迟到子类&#xff0c;使得子类可以不改变该算法结构的情况下重定义该算法的某些步骤 【主要角色】&#xff1a; 抽象类&#xff1a;给出一个算法的轮廓和骨架&#xff08;包括一个模板方法 和 若干基…
阅读更多...
ubuntu22.04 卸载ESP-IDF

ubuntu22.04 卸载ESP-IDF

要在Ubuntu 22.04上完全卸载ESP-IDF&#xff0c;请按照以下步骤操作&#xff1a; 卸载ESP-IDF的步骤 删除ESP-IDF目录&#xff1a; # 假设ESP-IDF安装在~/esp/esp-idf目录 rm -rf ~/esp/esp-idf删除ESP-IDF工具链和下载的工具&#xff1a; rm -rf ~/.espressif从PATH中移除ESP…
阅读更多...
SQLMesh 内置宏详解：@PIVOT等常用宏的核心用法与示例

SQLMesh 内置宏详解：@PIVOT等常用宏的核心用法与示例

本文系统解析 SQLMesh 的四个核心内置宏&#xff0c;涵盖行列转换的 PIVOT、精准去重的 DEDUPLICATE、灵活生成日期范围的 DATE_SPINE&#xff0c;以及动态表路径解析的 RESOLVE_TEMPLATE。通过真实案例演示参数配置与 SQL 渲染逻辑&#xff0c;并对比宏调用与传统 SQL 的差异&…
阅读更多...
基于Springboot + vue3实现的工商局商家管理系统

基于Springboot + vue3实现的工商局商家管理系统

项目描述 本系统包含管理员、商家两个角色。 管理员角色&#xff1a; 用户管理&#xff1a;管理系统中所有用户的信息&#xff0c;包括添加、删除和修改用户。 许可证申请管理&#xff1a;管理商家的许可证申请&#xff0c;包括搜索、修改或删除许可证申请。 许可证审批管理…
阅读更多...
第五部分：第五节 - Express 路由与中间件进阶：厨房的分工与异常处理

第五部分：第五节 - Express 路由与中间件进阶：厨房的分工与异常处理

随着你的 Express 应用变得越来越大&#xff0c;所有的路由和中间件都写在一个文件里会变得难以管理。这时候就需要将代码进行拆分和组织。此外&#xff0c;一个健壮的后端应用必须能够优雅地处理错误和一些常见的 Web 开发问题&#xff0c;比如跨域。 路由模块化 (express.Ro…
阅读更多...
萌新联赛第（三）场

萌新联赛第（三）场

C题 这道题用暴力去写想都不要想&#xff0c;一定超时&#xff0c;于是我们需要优化&#xff0c;下面是思路过程&#xff1a; 如图&#xff0c;本题只需找到x的因数个数和(n-x)的因数个数&#xff0c;这两个相乘&#xff0c;得到的就是对于这个x来说组合的个数&#xff0c;且x…
阅读更多...
【Android构建系统】如何在Camera Hal的Android.bp中选择性引用某个模块

【Android构建系统】如何在Camera Hal的Android.bp中选择性引用某个模块

背景描述 本篇文章是一个Android.bp中选择性引用某个模块的实例。 如果是Android.mk编译时期&#xff0c;在编译阶段通过某个条件判断是不是引用某个模块A, 是比较好实现的。Android15使用Android.bp构建后&#xff0c;要想在Android.bp中通过自定义的一个变量或者条件实现选…
阅读更多...
【OneNET】_01_使用微信小程序通过新版OneNET平台获取STM32设备信息并进行控制

【OneNET】_01_使用微信小程序通过新版OneNET平台获取STM32设备信息并进行控制

【OneNET】_01_使用微信小程序通过新版OneNET平台获取STM32设备信息并进行控制 一、 前言1.1 OntNET硬件方面: STM32F103C8T6 ESP01S教程 1.2 微信小程序方面 二、STM32代码部分修改三、微信小程序修改的部分四、小笔记&#xff08;个人杂记&#xff09;4.1 OneNETOneNET物联网…
阅读更多...
用 python 编写的一个图片自动分类小程序（三）

用 python 编写的一个图片自动分类小程序（三）

图片自动分类识别小程序记录 2025/5/18 0:38修改程序界面&#xff0c;增加一些功能 用 python 编写的一个图片自动识别分类小程序。 操作系统平台&#xff1a;Microsoft Windows 11 编程语言和 IDE&#xff1a;python 3.10 Visual studio code 一&#xff1a;图片自动分…
阅读更多...
嵌入式硬件篇---SGP30 气体传感器

嵌入式硬件篇---SGP30 气体传感器

文章目录 前言一、SGP30 气体传感器详解（一）基本概述（二）工作原理传感器结构检测机制自校准功能（三）主要特性（四）应用场景智能家居空气质量检测仪汽车行业商业建筑二、TVOC 与 eCO2 的含义（一）TVOC（总挥发性有机化合物）定义危害健康标准（二）eCO2（等效二氧化碳）…
阅读更多...
最新文章

Copyright @ 2022~2023