前言

在 专栏 之前的文章中，我们已经知道了协程的启动、挂起、取消、异常以及常用的协程作用域等基础应用。
这些基础应用适合的场景是一次性任务，执行完就结束了的场景。

launch / async 适合的场景

  • 网络请求
  • 数据库查询
  • 文件读写
  • 并行计算任务
  • 等等

而对于一些相对复杂的场景，例如：持续的数据流、需要在不同的协程之间传递数据、需要顺序或背压控制等场景，基础的 launch / async
就不够用了。

例如：

  • 用户点击、输入等事件流的处理
  • 生产者-消费者模型的需求：任务排队、日志流
  • 高频数据源处理（相机帧、音频流等）

类似这种持续的、需要顺序控制、或者多个协程配合执行的场景，就需要用到 Channel 了。

Channel 的概念和基本使用

概念

顾名思义，Channel 有管道、通道的意思。Channel 跟 Java 中的 BlockingQueue 很相似，区别在于 Channel 是挂起的，不是阻塞的。

Channel 的核心特点就是能够在不同的协程之间进行数据传递，并且能够控制数据传递的顺序。
使用起来很简单，基本就分为以下几步：

  1. 创建 Channel
  2. 通过 channel.send 发送数据
  3. 通过 channel.receive 接收数据

整体的概念也比较简单形象，就是一根管道，一个口子发送数据，一个口子接收数据。

Channel 的创建

先来看下 Channel 的源码，可以看到会根据传入的参数选择不同的实现。

public fun <E> Channel(capacity: Int = RENDEZVOUS,onBufferOverflow: BufferOverflow = BufferOverflow.SUSPEND,onUndeliveredElement: ((E) -> Unit)? = null
): Channel<E> =when (capacity) {RENDEZVOUS -> {if (onBufferOverflow == BufferOverflow.SUSPEND)BufferedChannel(RENDEZVOUS, onUndeliveredElement) // an efficient implementation of rendezvous channelelseConflatedBufferedChannel(1,onBufferOverflow,onUndeliveredElement) // support buffer overflow with buffered channel}CONFLATED -> {require(onBufferOverflow == BufferOverflow.SUSPEND) {"CONFLATED capacity cannot be used with non-default onBufferOverflow"}ConflatedBufferedChannel(1, BufferOverflow.DROP_OLDEST, onUndeliveredElement)}UNLIMITED -> BufferedChannel(UNLIMITED,onUndeliveredElement) // ignores onBufferOverflow: it has buffer, but it never overflowsBUFFERED -> { // uses default capacity with SUSPENDif (onBufferOverflow == BufferOverflow.SUSPEND) BufferedChannel(CHANNEL_DEFAULT_CAPACITY,onUndeliveredElement)else ConflatedBufferedChannel(1, onBufferOverflow, onUndeliveredElement)}else -> {if (onBufferOverflow === BufferOverflow.SUSPEND) BufferedChannel(capacity, onUndeliveredElement)else ConflatedBufferedChannel(capacity, onBufferOverflow, onUndeliveredElement)}}

参数概览

参数类型默认值描述
capacityIntRENDEZVOUS通道容量，决定缓冲区大小和行为模式
onBufferOverflowBufferOverflowSUSPEND缓冲区溢出时的处理策略
onUndeliveredElement((E) -> Unit)?null元素未能送达时的回调函数
capacity（容量配置）

capacity 参数决定了 Channel 的缓冲行为和容量大小：

  • RENDEZVOUS（值为 0）：无缓冲，发送者和接收者必须同时准备好
  • CONFLATED（值为 -1）：只保留最新的元素，旧元素会被覆盖
  • UNLIMITED（值为 Int.MAX_VALUE）：理论上就是无限容量，永不阻塞发送
  • BUFFERED（值为 64）：默认缓冲大小
  • 自定义正整数：自己指定具体的缓冲区大小
onBufferOverflow（溢出策略）

当缓冲区满时的处理策略：

  • SUSPEND：挂起发送操作，等待缓冲区有空间（默认）
  • DROP_OLDEST：丢弃旧的元素，添加新元素
  • DROP_LATEST：丢弃新元素，保留缓冲区中的现有元素
onUndeliveredElement（未送达回调）

当元素无法送达时的清理回调函数：

  • null：不执行任何清理操作（默认）
  • 自定义函数：用于资源清理、日志记录等，根据业务需求来定义

参数组合效果

capacityonBufferOverflow行为适用场景
RENDEZVOUSSUSPEND无缓冲，同步通信严格的生产者-消费者同步
BUFFEREDSUSPEND有限缓冲，满时挂起一般的异步处理，默认的缓冲数量是 64
UNLIMITEDSUSPEND缓冲长度为 Int.MAX_VALUE高吞吐量场景（生产上不建议使用，有内存方面的风险）
CONFLATEDDROP_OLDEST无缓冲，只保留最新值状态更新、实时数据
自定义大小SUSPEND固定大小，满时挂起批量处理、批量任务
自定义大小DROP_OLDEST固定大小，丢弃旧数据获取最近 N 个元素
自定义大小DROP_LATEST固定大小，拒绝新数据保护重要历史数据

Capacity

RENDEZVOUS（会合模式）

特点：

  • 容量为 0，无缓冲区
  • 发送者和接收者必须同时准备好才能完成数据传输
  • 提供强同步保证，一手交钱一手交货

使用示例：

suspend fun demonstrateRendezvousChannel() {// 创建 RENDEZVOUS Channel（默认容量为 0），默认什么都不传就是 rendezvous 模式，Channel<String>()val rendezvousChannel = Channel<String>(Channel.RENDEZVOUS)// 启动发送者协程val senderJob = GlobalScope.launch {println("[发送者] 准备发送消息...")rendezvousChannel.send("Hello from RENDEZVOUS!")println("[发送者] 消息已发送")rendezvousChannel.send("Second message")println("[发送者] 第二条消息已发送")rendezvousChannel.close()}// 启动接收者协程val receiverJob = GlobalScope.launch {delay(1000) // 延迟1秒，发送者会等待接收者准备好println("[接收者] 开始接收消息...")for (message in rendezvousChannel) {println("[接收者] 收到消息: $message")delay(500) // 模拟处理时间}println("[接收者] Channel已关闭")}// 等待所有协程完成joinAll(senderJob, receiverJob)
}

执行结果
在这里插入图片描述

CONFLATED（只留最新值）

特点：

  • 容量为 1，但会丢弃旧值
  • 只保留最新的元素
  • 发送操作永不阻塞
  • 只能使用 BufferOverflow.SUSPEND 策略

源码分析：

CONFLATED -> {require(onBufferOverflow == BufferOverflow.SUSPEND) {"CONFLATED capacity cannot be used with non-default onBufferOverflow"}ConflatedBufferedChannel(1, BufferOverflow.DROP_OLDEST, onUndeliveredElement)
}

使用示例：

suspend fun demonstrateConflatedChannel() {// 创建 CONFLATED Channel，相当于：Channel<String>(1, BufferOverflow.DROP_OLDEST)val conflatedChannel = Channel<String>(Channel.CONFLATED)// 快速发送多个消息val senderJob = GlobalScope.launch {repeat(5) { i ->val message = "Update-$i"conflatedChannel.send(message)println("[发送者] 发送更新: $message")delay(100) // 短暂延迟}conflatedChannel.close()}// 慢速接收者val receiverJob = GlobalScope.launch {delay(1000) // 延迟1秒，让发送者发送完所有消息println("[接收者] 开始接收（只会收到最新的值）...")for (message in conflatedChannel) {println("[接收者] 收到: $message")}}joinAll(senderJob, receiverJob)
}

在这里插入图片描述

UNLIMITED（无限容量）

特点：

  • 容量为 Int.MAX_VALUE，理论上无限容量
  • 发送操作永不阻塞，但要注意内存使用
  • 忽略 onBufferOverflow 参数
  • 适用于高吞吐量场景，但生产环境需谨慎使用
suspend fun demonstrateUnlimitedChannel() {val unlimitedChannel = Channel<String>(Channel.UNLIMITED)val senderJob = GlobalScope.launch {repeat(10) { i ->val message = "Message-$i"unlimitedChannel.send(message)println("[发送者] 立即发送: $message")}unlimitedChannel.close()println("[发送者] 所有消息已发送，Channel已关闭")}val receiverJob = GlobalScope.launch {delay(1000) // 延迟1秒开始接收println("[接收者] 开始慢速接收...")for (message in unlimitedChannel) {println("[接收者] 处理: $message")delay(300) // 模拟处理时间}}joinAll(senderJob, receiverJob)
}

在这里插入图片描述

BUFFERED（有限容量）

特点：

  • 使用默认容量 (CHANNEL_DEFAULT_CAPACITY，通常为 64)
  • 在缓冲区满时根据 onBufferOverflow 策略处理

源码分析：

BUFFERED -> {if (onBufferOverflow == BufferOverflow.SUSPEND)BufferedChannel(CHANNEL_DEFAULT_CAPACITY, onUndeliveredElement)elseConflatedBufferedChannel(1, onBufferOverflow, onUndeliveredElement)
}

使用示例：

suspend fun demonstrateBufferedDefaultChannel() {// 创建 BUFFERED Channel（默认容量为 64）val bufferedChannel = Channel<String>(Channel.BUFFERED)val senderJob = GlobalScope.launch {repeat(100) { i ->bufferedChannel.send("Message-$i")println("[发送者] 发送 Message-$i")}bufferedChannel.close()}val receiverJob = GlobalScope.launch {delay(1000) // 延迟接收for (message in bufferedChannel) {println("[接收者] 收到: $message")delay(50)}}joinAll(senderJob, receiverJob)
}

与下面自定义容量效果类似。

自定义容量

特点：

  • 指定具体的缓冲区大小
  • 根据 onBufferOverflow 策略处理溢出

源码分析：

else -> {if (onBufferOverflow === BufferOverflow.SUSPEND)BufferedChannel(capacity, onUndeliveredElement)elseConflatedBufferedChannel(capacity, onBufferOverflow, onUndeliveredElement)
}

使用示例：

suspend fun demonstrateBufferedChannel() {// 创建容量为3的缓冲Channelval bufferedChannel = Channel<Int>(capacity = 3)// 启动发送者协程val senderJob = GlobalScope.launch {repeat(5) { i ->println("[发送者] 发送数字: $i")bufferedChannel.send(i)println("[发送者] 数字 $i 已发送")}bufferedChannel.close()println("[发送者] Channel已关闭")}// 启动接收者协程，延迟接收以观察缓冲效果val receiverJob = GlobalScope.launch {delay(2000) // 延迟2秒开始接收println("[接收者] 开始接收数字...")for (number in bufferedChannel) {println("[接收者] 收到数字: $number")delay(800) // 模拟慢速处理}}joinAll(senderJob, receiverJob)
}

可以看到，因为默认的溢出策略是 SUSPEND，所以当缓冲区满了时，发送者会被挂起，直到接收者处理完一个元素，才会继续发送。
在这里插入图片描述

BufferOverflow 策略详解

当 Channel 的缓冲区满时，BufferOverflow 参数决定了如何处理新的发送请求：

SUSPEND（默认策略）

  • 行为：当缓冲区满时，挂起发送操作直到有空间可用
  • 特点：提供背压控制，防止生产者过快
  • 使用场景：需要确保所有数据都被处理的场景
suspend fun demonstrateBasicOperations() {//容量为 2，溢出策略为SUSPENDval channel = Channel<String>(capacity = 2, onBufferOverflow = BufferOverflow.SUSPEND)//发送的速度快val job1 = GlobalScope.launch {repeat(5) {channel.send("Message-$it")println("[发送者] 发送 Message-$it")}channel.close()}val job2 = GlobalScope.launch {//除了用 channel.recrive 外，也可以直接 用 for 循环接收数据for (message in channel) {//接收的速度慢delay(1000)println("[接收者] 接收到: $message")}}joinAll(job1, job2)
}

在这里插入图片描述

DROP_LATEST

  • 行为：当缓冲区满时，丢弃新元素，保留缓冲区中的现有元素
  • 特点：保护已缓冲的数据不被覆盖
  • 使用场景：保护重要的历史数据，防止新数据覆盖
  • 性能特点：发送操作永不阻塞，但新数据可能被丢弃
suspend fun demonstrateBasicOperations() {val channel = Channel<String>(capacity = 2, onBufferOverflow = BufferOverflow.DROP_LATEST)val job1 = GlobalScope.launch {repeat(5) {channel.send("Message-$it")println("[发送者] 发送 Message-$it")}channel.close()}val job2 = GlobalScope.launch {for (message in channel) {delay(1000)println("[接收者] 接收到: $message")}}joinAll(job1, job2)
}

可以看到，当缓冲区满时，会把新数据丢弃掉，因此，接收端只接收到了旧数据。

在这里插入图片描述

DROP_OLDEST

  • 行为：当缓冲区满时，丢弃旧的元素，添加新元素
  • 特点：保持固定的内存使用，优先保留新数据
  • 使用场景：实时数据流、最近N个元素
  • 性能特点：发送操作永不阻塞，但可能丢失历史数据
suspend fun demonstrateBasicOperations() {val channel = Channel<String>(capacity = 2, onBufferOverflow = BufferOverflow.DROP_OLDEST)val job1 = GlobalScope.launch {repeat(5) {channel.send("Message-$it")println("[发送者] 发送 Message-$it")}channel.close()}val job2 = GlobalScope.launch {for (message in channel) {delay(1000)println("[接收者] 接收到: $message")}}joinAll(job1, job2)
}

在这里插入图片描述

需要注意的是，当缓冲区满了之后，1 和 2 被丢弃了，3 和 4 被放进去了。从这里可以看出，丢弃数据时，并不是把最早的旧数据丢掉，这里跟内部的实现有关。

onUndeliveredElement 回调

当元素无法送达时（如 Channel 被取消或关闭），会调用此回调函数

suspend fun demonstrateBasicOperations() {val channel = Channel<String>(capacity = 2, onBufferOverflow = BufferOverflow.DROP_OLDEST) {println("[Channel] 缓冲区已满，无法放到缓冲区,值：${it}")}// 演示基本的send和receive操作val job1 = GlobalScope.launch {repeat(5) {channel.send("Message-$it")println("[发送者] 发送 Message-$it")}channel.close()}val job2 = GlobalScope.launch {for (message in channel) {delay(1000)println("[接收者] 接收到: $message")}}joinAll(job1, job2)
}

在这里插入图片描述

Channel 操作方式

Channel 提供了两种操作方式：阻塞操作和非阻塞操作。

阻塞操作（send/receive）

send() 和 receive() 方法都是挂起方法，它们会阻塞当前协程，直到完成操作。

非阻塞操作（trySend/tryReceive）

trySend() 和 tryReceive() 是 Channel 提供的非阻塞操作 API。与阻塞版本不同，这些方法会立即返回结果，不会挂起当前协程，也不会抛出异常。

操作对比

操作类型阻塞版本非阻塞版本行为差异
发送send()trySend()send() 会挂起直到有空间；trySend() 立即返回结果
接收receive()tryReceive()receive() 会挂起直到有数据；tryReceive() 立即返回结果

返回值类型

  • trySend() 返回 ChannelResult<Unit>
  • tryReceive() 返回 ChannelResult<T>

ChannelResult 是一个密封类，通过密封类中的成员 isSuccess 和 getOrNull() 可以判断操作是否成功。

在这里插入图片描述

大部分场景下，send / receive + 合理的 Channel 配置就能解决问题，trySend/tryReceive 更多的是想达到如下效果：

  • 避免不必要的协程挂起开销，希望立即得到结果
  • 提供更精细的控制逻辑，如：超时处理、重试机制等
  • 实现更好的错误处理和用户反馈，能更好地处理异常场景

runBlocking {val channel = Channel<Int>(2)val sendJob = launch {repeat(5) {delay(100)val sendResult = channel.trySend(it)sendResult.onSuccess {println("发送成功")}.onFailure {println("发送失败")}.onClosed {println("通道已关闭")}}}val receiveJob = launch {for (i in channel) {delay(300)println("接收到数据:${i}")}}joinAll(sendJob, receiveJob)}

在这里插入图片描述

Channel 状态管理

Channel 在其生命周期中会经历以下几个关键状态：

  • 活跃状态（Active）：可以正常发送和接收数据
  • 发送端关闭（Closed for Send）：不能发送新数据，但可以接收缓冲区中的数据
  • 接收端关闭（Closed for Receive）：不能接收数据，缓冲区已清空
  • 取消状态（Cancelled）：Channel 被取消，所有操作都会失败

API

  • channel.close()：关闭 Channel
  • channel.isClosedForSend：判断发送端是否已关闭
  • channel.isClosedForReceive：判断接收端是否已关闭
  • channel.cancel()：取消 Channel

Close（关闭操作）

  • 调用 close() 后，isClosedForSend 立即变为 true
  • 此时，缓冲区中的数据仍可被消费
  • 只有当缓冲区清空后，isClosedForReceive 才变为 true

示例：

    suspend fun demonstrateChannelClose() {val channel = Channel<String>(1)val producer = GlobalScope.launch {try {for (i in 1..5) {val message = "Message $i"println("准备发送: $message")channel.send(message)println("成功发送: $message")delay(100)}} catch (e: ClosedSendChannelException) {println("生产者: Channel已关闭，无法发送数据 - ${e.message}")}}val consumer = GlobalScope.launch {try {for (message in channel) {println("接收到: $message")delay(200)}println("消费者: Channel已关闭，退出接收循环")} catch (e: Exception) {println("消费者异常: ${e.message}")}}delay(300) // 模拟让一些数据能够被接收到// 检查Channel状态println("关闭前状态:")println("  isClosedForSend: ${channel.isClosedForSend}")println("  isClosedForReceive: ${channel.isClosedForReceive}")// 关闭Channelprintln("\n正在关闭Channel...")channel.close()// 检查关闭后的状态println("关闭后状态:")println("  isClosedForSend: ${channel.isClosedForSend}")println("  isClosedForReceive: ${channel.isClosedForReceive}")// 等待协程完成producer.join()consumer.join()println("最终状态:")println("  isClosedForSend: ${channel.isClosedForSend}")println("  isClosedForReceive: ${channel.isClosedForReceive}")
}

在这里插入图片描述

Cancel（取消操作）

cancel() 方法用于强制取消 Channel，它会：

  • 立即关闭发送和接收端
  • 清空缓冲区中的所有数据
  • 触发 onUndeliveredElement 回调（如果设置了）
suspend fun demonstrateChannelCancel() {val channel = Channel<String>(capacity = 5) {println("消息未被接收:${it}")}val producer = GlobalScope.launch {try {for (i in 1..8) {val message = "Message $i"println("尝试发送: $message")channel.send(message)println("成功发送: $message")delay(100)}} catch (e: CancellationException) {println("生产者: Channel被取消 - ${e.message}")}}val consumer = GlobalScope.launch {try {for (message in channel) {println("接收到: $message")delay(300)}} catch (e: CancellationException) {println("消费者: 协程被取消 - ${e.message}")}}delay(400) // 让一些操作执行println("\n取消前状态:")println("  isClosedForSend: ${channel.isClosedForSend}")println("  isClosedForReceive: ${channel.isClosedForReceive}")// 取消Channelprintln("\n正在取消Channel...")channel.cancel(CancellationException("主动取消Channel"))println("取消后状态:")println("  isClosedForSend: ${channel.isClosedForSend}")println("  isClosedForReceive: ${channel.isClosedForReceive}")// 等待协程完成producer.join()consumer.join()
}

在这里插入图片描述

Channel 异常处理

在使用 Channel 的过程中，会遇到各种异常情况。主要包括以下几种类型：

ClosedSendChannelException

触发条件：

  • 在已关闭的 Channel 上调用 send() 方法
  • Channel 调用 close() 后，发送端立即关闭

示例：

suspend fun demonstrateClosedSendException() {val channel = Channel<String>()// 关闭 Channelchannel.close()try {// 尝试在已关闭的 Channel 上发送数据channel.send("This will throw exception")} catch (e: ClosedSendChannelException) {println("捕获异常: ${e.message}")println("异常类型: ${e::class.simpleName}")}
}

ClosedReceiveChannelException

触发条件：

  • 从已关闭且缓冲区为空的 Channel 调用 receive() 方法
  • 当 isClosedForReceive 为 true 时调用 receive()

示例：

suspend fun demonstrateClosedReceiveException() {val channel = Channel<String>()// 关闭 Channelchannel.close()try {// 尝试从已关闭且空的 Channel 接收数据val message = channel.receive()println("收到消息: $message")} catch (e: ClosedReceiveChannelException) {println("捕获异常: ${e.message}")println("异常类型: ${e::class.simpleName}")}
}

CancellationException

触发条件：

  • Channel 被 cancel() 方法取消
  • 父协程被取消，导致 Channel 操作被取消
  • 超时或其他取消信号

示例：

suspend fun demonstrateCancellationException() {val channel = Channel<String>()val job = GlobalScope.launch {try {// 这个操作会被取消channel.send("This will be cancelled")} catch (e: CancellationException) {println("发送操作被取消: ${e.message}")throw e // 重新抛出 CancellationException}}delay(100)// 取消 Channelchannel.cancel(CancellationException("手动取消 Channel"))try {job.join()} catch (e: CancellationException) {println("协程被取消: ${e.message}")}
}

异常与状态关系

Channel 状态send() 行为receive() 行为trySend() 行为tryReceive() 行为
活跃状态正常发送或挂起正常接收或挂起返回成功/失败结果返回成功/失败结果
发送端关闭抛出 ClosedSendChannelException正常接收缓冲区数据返回失败结果正常返回结果
接收端关闭抛出 ClosedSendChannelException抛出 ClosedReceiveChannelException返回失败结果返回失败结果
已取消抛出 CancellationException抛出 CancellationException返回失败结果返回失败结果

异常处理技巧

使用非阻塞操作避免异常

非阻塞操作不会抛出异常，而是返回结果对象：

suspend fun safeChannelOperations() {val channel = Channel<String>()// 安全的发送操作val sendResult = channel.trySend("Safe message")when {sendResult.isSuccess -> println("发送成功")sendResult.isFailure -> println("发送失败: ${sendResult.exceptionOrNull()}")sendResult.isClosed -> println("Channel 已关闭")}// 安全的接收操作val receiveResult = channel.tryReceive()when {receiveResult.isSuccess -> println("接收到: ${receiveResult.getOrNull()}")receiveResult.isFailure -> println("接收失败: ${receiveResult.exceptionOrNull()}")receiveResult.isClosed -> println("Channel 已关闭")}
}
健壮的异常处理
suspend fun robustChannelUsage() {val channel = Channel<String>()val producer = GlobalScope.launch {try {repeat(5) { i ->if (channel.isClosedForSend) {println("Channel 已关闭，停止发送")break}channel.send("Message $i")delay(100)}} catch (e: ClosedSendChannelException) {println("生产者: Channel 已关闭")} catch (e: CancellationException) {println("生产者: 操作被取消")throw e // 重新抛出取消异常} finally {println("生产者: 清理资源")}}val consumer = GlobalScope.launch {try {while (!channel.isClosedForReceive) {try {val message = channel.receive()println("消费者: 收到 $message")} catch (e: ClosedReceiveChannelException) {println("消费者: Channel 已关闭且无更多数据")break}delay(200)}} catch (e: CancellationException) {println("消费者: 操作被取消")throw e} finally {println("消费者: 清理资源")}}delay(1000)channel.close()joinAll(producer, consumer)
}

总结

Channel 关键概念对比

特性RENDEZVOUSCONFLATEDBUFFEREDUNLIMITED自定义容量
容量0164Int.MAX_VALUE指定值
缓冲行为无缓冲，同步只保留最新值有限缓冲无限缓冲有限缓冲
发送阻塞是否缓冲满时否缓冲满时
适用场景严格同步状态更新一般异步高吞吐量批量处理
内存风险低低中等高可控

溢出策略对比

策略行为性能特点适用场景
SUSPEND挂起发送操作提供背压控制确保数据完整性
DROP_OLDEST丢弃旧元素发送不阻塞实时数据流
DROP_LATEST丢弃新元素发送不阻塞保护历史数据

操作方式

操作类型阻塞版本非阻塞版本异常处理返回值
发送send()trySend()抛出异常ChannelResult<Unit>
接收receive()tryReceive()抛出异常ChannelResult<T>
特点会挂起协程立即返回需要 try-catch通过结果对象判断

Channel 状态生命周期

状态描述send()receive()检查方法
活跃正常工作状态✅ 正常✅ 正常-
发送关闭调用 close() 后❌ 异常✅ 可接收缓冲区数据isClosedForSend
接收关闭缓冲区清空后❌ 异常❌ 异常isClosedForReceive
已取消调用 cancel() 后❌ 异常❌ 异常-

总体来说，Channel 是一种非常强大的协程通信机制，它可以帮助我们在协程之间进行安全、高效的通信。在使用 Channel时，我们需要注意异常处理、缓冲区容量、溢出策略等问题。

感谢阅读，如果对你有帮助请三连（点赞、收藏、加关注）支持。有任何疑问或建议，欢迎在评论区留言讨论。如需转载，请注明出处：喻志强的博客

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

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

相关文章

安装使用Conda

安装使用Conda

文章目录Linux安装 Conda&#xff08;Miniconda 或 Anaconda&#xff09;​Miniconda (轻量版)激活配置Windows安装配置 Conda​添加清华镜像源加速创建并激活 Conda 环境验证步骤​安装项目依赖运行项目Linux安装 Conda&#xff08;Miniconda 或 Anaconda&#xff09;​ Mini…
阅读更多...
面向智能空战的深度强化学习技术综述

面向智能空战的深度强化学习技术综述

CSDN大礼包《大模型课程》 CSDN大礼包《深度强化学习课程》 CSDN大礼包《人工智能平台设计开发课程》
阅读更多...
DeepSeek-V3.1 Claude Code: 革命性的AI编码助手详解与应用指南

DeepSeek-V3.1 Claude Code: 革命性的AI编码助手详解与应用指南

DeepSeek-V3.1 & Claude Code: 革命性的AI编码助手详解与应用指南 今天 DeepSeek模型已支持接入 Claude Code&#xff0c;我们来深入探讨Claude Code ——Anthropic 推出的一个强大工具。它不仅仅是一个简单的代码补全助手&#xff0c;而是一个嵌入终端的智能代理&#xf…
阅读更多...
智能求职推荐系统

智能求职推荐系统

智能求职推荐系统 基于知识图谱和大语言模型的智能求职推荐系统&#xff0c;为求职者提供个性化岗位推荐和AI驱动的匹配分析。 &#x1f680; 系统特性 智能推荐: 基于知识图谱的多维度职位匹配AI分析: 集成DeepSeek大模型提供深度分析和建议可视化展示: 使用ECharts展示推荐结…
阅读更多...
瑞芯微：AIoT芯片领航者的全栈突围与生态崛起

瑞芯微：AIoT芯片领航者的全栈突围与生态崛起

一、业绩高速增长的底层逻辑​​瑞芯微的持续爆发式增长源于三大关键支柱&#xff1a;技术纵深​​&#xff1a;深耕“大音频、大视频、大感知、大软件”四大核心技术矩阵&#xff0c;自研NPU/ISP/编解码等核心IP持续迭代&#xff1b;精准定位​​&#xff1a;瞄准边缘侧与端侧…
阅读更多...
【报错】Please do not run this script with sudo bash

【报错】Please do not run this script with sudo bash

目录 报错 分析 解决方法 扩展 报错分析 安装conda 报错 Please do not run this script with sudo bash: showHelp: command not found 分析 脚本有以下要求： 不能以root身份运行（当前是root用户）
阅读更多...
多线程—飞机大战排行榜功能（2.0版本）

多线程—飞机大战排行榜功能（2.0版本）

&#xff08;一&#xff09;实现功能&#xff1a; 1.基础的成绩排序 2.相同成绩随机排名 3.用户名注册重复 &#xff08;二&#xff09;效果视频&#xff1a; &#xff08;三&#xff09;代码实现&#xff1a; 3.1 && 3.2 在FileRead类中新增方法如下:具体的代码实现&a…
阅读更多...
React + Antd+TS 动态表单容器组件技术解析与实现

React + Antd+TS 动态表单容器组件技术解析与实现

概述在现代前端应用中&#xff0c;表单是用户交互的核心部分。本文将深入分析一个基于 React 和 Ant Design 的高级动态表单容器组件&#xff0c;它提供了强大的可配置性、灵活的布局选项和丰富的功能扩展能力。组件核心特性1. 高度可配置的表单结构interface FormContainerPro…
阅读更多...
51c自动驾驶~合集16

51c自动驾驶~合集16

自己的原文哦~ https://blog.51cto.com/whaosoft/11739891 #CLIP系列模型如何补短板再升级 CLIP&#xff08;Contrastive Language–Image Pre-training&#xff09;模型自推出以来&#xff0c;在图像-文本跨模态理解和生成领域取得了显著成果。然而&#xff0c;经…
阅读更多...
分级设色地图/标注式统计地图-中国地图绘制

分级设色地图/标注式统计地图-中国地图绘制

分级设色地图/标注式统计地图‌1. 这种图长什么样&#xff1f;‌2. 核心应用场景‌3. 工具3.1 自己找数据3.2 智图小易司3.2 Flourish3.3 镝数图表注意事项当你看到一张中国地图&#xff0c;各省份颜色深浅不一&#xff0c;旁边还标注着具体数值时&#xff0c;这种图就是‌分级…
阅读更多...
2025最新华为云国际版注册图文流程-不用绑定海外信用卡注册

2025最新华为云国际版注册图文流程-不用绑定海外信用卡注册

说到华为云&#xff0c;很多人第一反应就是“大厂可靠、服务全”。确实&#xff0c;作为全球知名的云计算服务商&#xff0c;华为云在企业级项目和个人开发者中都挺受欢迎。今天我就带你一步一步走一遍华为云国际版的注册流程&#xff0c;让新手也能轻松上手。下面是最简单的注…
阅读更多...
Android 人脸识别技术全解析

Android 人脸识别技术全解析

人脸识别作为生物识别技术的核心分支&#xff0c;已广泛应用于考勤打卡、身份验证、支付安全等场景。在 Android 平台&#xff0c;实现人脸识别需要兼顾准确性、实时性和设备兼容性三大挑战。本文将系统讲解 Android 人脸识别的技术选型、核心实现、性能优化及安全加固&#xf…
阅读更多...
STM32项目分享：基于STM32单片机驾驶安全监测系统设计

STM32项目分享：基于STM32单片机驾驶安全监测系统设计

“我们不做一锤子买卖&#xff0c;只做技术成长的长期伙伴&#xff01;” 目录 一、视频展示 二、项目简介 三、原理图设计 四、PCB硬件设计 五、程序设计 六、资料分享 一、视频展示 基于stm32单片机驾驶行为监测系统设计 -视频分享二、项目简介 题目&#xff1a;基于s…
阅读更多...
【GaussDB】使用gdb定位GaussDB编译package报错

【GaussDB】使用gdb定位GaussDB编译package报错

【GaussDB】使用gdb定位GaussDB编译package报错 背景 在某次迁移Oracle到GaussDB时&#xff0c;应用开发人员将改好的package在GaussDB里进行创建&#xff0c;没有ERROR也没有WARNING&#xff0c;但是编译无效对象的时候报错了。虽然已经找到了是哪个包编译报错&#xff0c;但…
阅读更多...
One Commander：强大的Windows文件管理器

One Commander：强大的Windows文件管理器

在日常使用电脑的过程中&#xff0c;文件管理和浏览是必不可少的任务。One Commander作为一款功能强大的Windows文件管理器&#xff0c;提供了丰富的功能和便捷的操作方式&#xff0c;帮助用户更高效地管理和浏览文件。它不仅支持多种文件操作&#xff0c;还提供了丰富的自定义…
阅读更多...
SPUpDate Application 程序卸载

SPUpDate Application 程序卸载

我安装了 EzvizStudioSetups.exe 软件&#xff0c;卸载后会在电脑遗留 SPUpDate Application 程序&#xff1b;在某一时刻会占用 CPU 资源&#xff1b;应用卸载方法一&#xff1a;在任务管理器搜索 SPUpDate Application&#xff1b;定位到文件位置&#xff1b;我的路径如下C:\…
阅读更多...
算法题（187）：程序自动分析

算法题（187）：程序自动分析

审题&#xff1a; 本题需要我们判断是否可以同时满足题目给定的若干等式或不等式&#xff0c;判断出后根据结果输出YES或NO 思路&#xff1a; 方法一&#xff1a;离散化并查集 使用并查集&#xff1a;其实题目中只存在两者相等或不等两种情况&#xff0c;而等于具有传递性&…
阅读更多...
strcasecmp函数详解

strcasecmp函数详解

strcasecmp 是 C 语言中用于不区分大小写比较两个字符串的函数&#xff0c;主要用于忽略字符大小写差异的场景&#xff08;如用户输入验证、不区分大小写的字符串匹配等&#xff09;。它属于 POSIX 标准库&#xff0c;定义在 <string.h> 头文件中。 一、函数原型与参数 函…
阅读更多...
Voronoi图

Voronoi图

本文将详细解释 Voronoi 图&#xff0c;它在空间分析和插值中非常常用。1. 概念 Voronoi 图是一种空间划分方法&#xff0c;它把平面&#xff08;或空间&#xff09;划分成若干个区域&#xff0c;使得每个区域内的任意一点都比该区域外的任何一点更靠近该区域的“生成点”&…
阅读更多...
BioScientist Agent：用于药物重定位和作用机制解析的知识图谱增强型 LLM 生物医学代理技术报告

BioScientist Agent：用于药物重定位和作用机制解析的知识图谱增强型 LLM 生物医学代理技术报告

BioScientist Agent：用于药物重定位和作用机制解析的知识图谱增强型 LLM 生物医学代理技术报告 一、项目概述 药物研发是一个周期长、成本高的过程，平均需要超过 10 年时间和 20 亿美元才能将一种新药推向市场，且 90% 以上的候选药物最终失败(1)。这种低成功率主要归因于对…
阅读更多...
最新文章

Copyright @ 2022~2023