Kotlin 协程Channel 通道 ① ( Channel#send 发送数据 | Channel#receive 接收数据 )

Posted 韩曙亮

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了Kotlin 协程Channel 通道 ① ( Channel#send 发送数据 | Channel#receive 接收数据 )相关的知识,希望对你有一定的参考价值。

文章目录





一、Channel 通道



协程中的 Channel 通道并发的安全队列 , 不同的协程之间 可以 借助 Channel 通道 进行通信 ;


协程 中 也涉及到 生产消费模式 ,

生产者 协程 产生数据 , 将数据通过 Channel 通道 , 发送给 消费者 协程 消费数据 ;

Flow 流 是 通过 发送元素 , 然后再 收集元素 , Flow 流是冷流 , 其发送元素 需要 通过 收集元素触发 , 也就是 如果不收集元素 , 发送元素 的操作是不执行的 ;

Channel 通道 与 Flow 异步流是不同的 , 生产者协程 产生数据 和 消费者协程 消费数据 是同时进行的 ;





二、Channel#send 发送数据



Channel#send 函数原型 :

/**
 * 将指定的[element]发送到此通道,在此通道的缓冲区已满时挂起调用者
 * 或者如果它不存在,或者如果通道[is closed for `send`][isClosedForSend]抛出异常(详情参见[close])s).
 *
 * [Closing][close]通道_after_此函数已挂起不会导致此挂起[send]调用
 * 因为关闭一个通道在概念上就像在这个通道上发送一个特殊的“关闭令牌”。
 * 通过通道发送的所有元素都按照先进先出的顺序交付。发送元素
 * 将在关闭令牌之前交付给接收者。
 *
 * 这个暂停函数是可以取消的。如果当前协程的[Job]被取消或完成
 * 函数挂起后,该函数立即恢复并返回[CancellationException]。
 * 有**立即取消保证**。如果作业被取消,而此函数被取消
 * 暂停,将无法成功恢复。' send '调用可以将元素发送到通道,
 * 但随后抛出[CancellationException],因此异常不应被视为交付元素失败。
 * 有关处理未交付元素的详细信息,请参见[Channel]文档中的“未交付元素”部分。
 *
 * 注意,该函数在未挂起时不会检查是否取消。
 * 使用[yield]或[CoroutineScope.isActive]如果需要,在紧循环中定期检查取消。
 *
 * 这个函数可以在[select]调用中使用[onSend]子句。
 * 使用[trySend]尝试发送到此通道而不等待。
 */
public suspend fun send(element: E)




三、Channel#receive 接收数据



Channel#receive 函数原型 :

/**
 * 检索并删除该通道中不为空的元素,或在通道为空时挂起调用者,
 * 或者如果通道[为' receive '关闭][isClosedForReceive]则抛出[ClosedReceiveChannelException]。
 * 如果通道由于异常而关闭,则称为_failed_通道,此函数
 * 将抛出原始的[close][SendChannel。关闭]导致异常。
 *
 * 这个暂停函数是可以取消的。如果当前协程的[Job]被取消或完成
 * 函数挂起后,该函数立即恢复并返回[CancellationException]。
 * 有**立即取消保证**。如果作业被取消,而此函数被取消
 * 暂停,将无法成功恢复。' receive '调用可以从通道中检索元素,
 * 但随后抛出[CancellationException],从而无法交付元素。
 * 有关处理未交付元素的详细信息,请参见[Channel]文档中的“未交付元素”部分。
 *
 * 注意,该函数在未挂起时不会检查是否取消。
 * 使用[yield]或[CoroutineScope。isActive]如果需要,在紧循环中定期检查取消。
 *
 * 这个函数可以在[select]调用中使用[onReceive]子句。
 * 使用[tryReceive]尝试从此通道接收而不等待。
 */
public suspend fun receive(): E




四、Channel 通道代码示例



代码示例 :

package kim.hsl.coroutine

import android.os.Bundle
import androidx.appcompat.app.AppCompatActivity
import kotlinx.coroutines.GlobalScope
import kotlinx.coroutines.channels.Channel
import kotlinx.coroutines.delay
import kotlinx.coroutines.launch
import kotlinx.coroutines.runBlocking

class MainActivity : AppCompatActivity() 
    override fun onCreate(savedInstanceState: Bundle?) 
        super.onCreate(savedInstanceState)
        setContentView(R.layout.activity_main)

        runBlocking 
            // Channel 通道, 传递 Int 类型数据
            val channel = Channel<Int>()

            // 数据生产者协程
            val producer = GlobalScope.launch 
                for (i in 0..3) 
                    delay(1000)
                    channel.send(i)
                    println("向通道中发送数据 $i")
                
            

            // 数据消费者协程
            val consumer = GlobalScope.launch 
                while (true) 
                    val num = channel.receive()
                    println("从通道中获取数据 $num")
                
            
        
    

执行结果 :

2022-12-27 11:54:15.689 I/System.out: 向通道中发送数据 0
2022-12-27 11:54:15.690 I/System.out: 从通道中获取数据 0
2022-12-27 11:54:16.707 I/System.out: 向通道中发送数据 1
2022-12-27 11:54:16.708 I/System.out: 从通道中获取数据 1
2022-12-27 11:54:17.745 I/System.out: 向通道中发送数据 2
2022-12-27 11:54:17.746 I/System.out: 从通道中获取数据 2
2022-12-27 11:54:18.749 I/System.out: 向通道中发送数据 3
2022-12-27 11:54:18.749 I/System.out: 从通道中获取数据 3

以上是关于Kotlin 协程Channel 通道 ① ( Channel#send 发送数据 | Channel#receive 接收数据 )的主要内容,如果未能解决你的问题,请参考以下文章

Kotlin 协程协程中的多路复用技术 ① ( 多路复用技术 | await 协程多路复用 | Channel 通道多路复用 )

Kotlin 协程Channel 通道 ② ( Channel 通道容量 | Channel 通道迭代 | 使用 iterator 迭代器进行迭代 | 使用 for in 循环进行迭代 )

Kotlin 协程Channel 通道 ② ( Channel 通道容量 | Channel 通道迭代 | 使用 iterator 迭代器进行迭代 | 使用 for in 循环进行迭代 )

Kotlin 协程Channel 通道 ④ ( Channel 通道的热数据流属性 | Channel 通道关闭过程 | Channel 通道关闭代码示例 )

Kotlin 协程Channel 通道 ⑤ ( BroadcastChannel 广播通道 | 代码示例 )

Kotlin 协程Channel 通道 ③ ( CoroutineScope#produce 构造生产者协程 | CoroutineScope#actor 构造消费者协程 )