kotlin协程广播管道BroadcastChannel，订阅管道openSubscription

比眉伴天荒 2023-10-12 12:12 7阅读 0赞

## kotlin协程广播管道BroadcastChannel，订阅管道openSubscription ##

import kotlinx.coroutines.*
    import kotlinx.coroutines.channels.*
    
    fun main(args: Array<String>) {
        //广播消息
        //也可以把普通Channel转换成广播Channel
        //val channel = Channel<Int>()
        //val broadcast = channel.broadcast(5)
        val broadcastChannel = BroadcastChannel<Int>(5)
    
        CoroutineScope(Dispatchers.IO).launch {
            var i = 0
            while (true) {
                broadcastChannel.send(i)
                i++
    
                delay(1000)
            }
        }
    
        //订阅消息
        val receiveChannel1 = broadcastChannel.openSubscription()
        val receiveChannel2 = broadcastChannel.openSubscription()
        runBlocking {
            while (true) {
                var v1 = receiveChannel1.receive()
                println("rc1 - $v1")
    
                var v2 = receiveChannel2.receive()
                println("rc2 - $v2")
            }
        }
    }

[kotlin协程接收管道ReceiveChannel生产者produce\_kotlin produce\_zhangphil的博客-CSDN博客runBlocking 内部启动的3个协程做耗时操作，从输出可以看到3个协程交叉并发执行，runBlocking 会等到3个协程执行结束后才退出，输出结果有明确先后顺序。runBlocking 会等待相同作用域的协程完成才退出runBlocking 本身阻塞线程，但内部运行的协程又非阻塞。kotlin的runBlocking 当内部相同作用域的所有协程都运行结束后，在 runBlocking 之后的代码才能执行， runBlocking 会阻塞所在线程。kotlin协程管道Channel。\_kotlin produce![favicon32.ico][]https://blog.csdn.net/zhangphil/article/details/131103072][kotlin_ReceiveChannel_produce_kotlin produce_zhangphil_-CSDN_runBlocking _3_3_runBlocking _3_runBlocking _runBlocking _kotlin_runBlocking _ runBlocking _ runBlocking _kotlin_Channel_kotlin produce_favicon32.ico_https_blog.csdn.net_zhangphil_article_details_131103072]

[kotlin协程管道Channel\_zhangphil的博客-CSDN博客runBlocking 内部启动的3个协程做耗时操作，从输出可以看到3个协程交叉并发执行，runBlocking 会等到3个协程执行结束后才退出，输出结果有明确先后顺序。runBlocking 会等待相同作用域的协程完成才退出runBlocking 本身阻塞线程，但内部运行的协程又非阻塞。kotlin的runBlocking 当内部相同作用域的所有协程都运行结束后，在 runBlocking 之后的代码才能执行， runBlocking 会阻塞所在线程。kotlin协程管道Channel。![favicon32.ico][]https://blog.csdn.net/zhangphil/article/details/131096899][kotlin_Channel_zhangphil_-CSDN_runBlocking _3_3_runBlocking _3_runBlocking _runBlocking _kotlin_runBlocking _ runBlocking _ runBlocking _kotlin_Channel_favicon32.ico_https_blog.csdn.net_zhangphil_article_details_131096899]

[https://blog.csdn.net/zhangphil/category\_12224054.html![icon-default.png_t_N6B9][]https://blog.csdn.net/zhangphil/category\_12224054.html][https_blog.csdn.net_zhangphil_category_12224054.html_icon-default.png_t_N6B9_https_blog.csdn.net_zhangphil_category_12224054.html]

[favicon32.ico]: https://g.csdnimg.cn/static/logo/favicon32.ico
[kotlin_ReceiveChannel_produce_kotlin produce_zhangphil_-CSDN_runBlocking _3_3_runBlocking _3_runBlocking _runBlocking _kotlin_runBlocking _ runBlocking _ runBlocking _kotlin_Channel_kotlin produce_favicon32.ico_https_blog.csdn.net_zhangphil_article_details_131103072]: https://blog.csdn.net/zhangphil/article/details/131103072
[kotlin_Channel_zhangphil_-CSDN_runBlocking _3_3_runBlocking _3_runBlocking _runBlocking _kotlin_runBlocking _ runBlocking _ runBlocking _kotlin_Channel_favicon32.ico_https_blog.csdn.net_zhangphil_article_details_131096899]: https://blog.csdn.net/zhangphil/article/details/131096899
[icon-default.png_t_N6B9]: https://csdnimg.cn/release/blog_editor_html/release2.3.5/ckeditor/plugins/CsdnLink/icons/icon-default.png?t=N6B9
[https_blog.csdn.net_zhangphil_category_12224054.html_icon-default.png_t_N6B9_https_blog.csdn.net_zhangphil_category_12224054.html]: https://blog.csdn.net/zhangphil/category_12224054.html