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

Posted 2022-12-30 韩曙亮

文章目录

• 一、多路复用技术
• 二、await 协程多路复用
• 三、Channel 通道多路复用

一、多路复用技术

---

在信号传输时 , 通信信道 的 带宽 远大于 传输单一信号的需求 ,

在同一信道中可以同时传递 多路 信号 ,

该技术成为 " 多路复用技术 " ;

二、await 协程多路复用

---

在 协程 中 , 可以通过 复用 多个 await 的方式 , 实现 多路复用 ;

使用场景 :

使用 不同的协程 , 分别从 网络 和 本地 获取数据 ,

协程 A 从网络获取数据 ,

协程 B 从本地获取数据 ,

哪个协程 先返回 , 则 优先使用该协程返回的数据 ;

在 select 代码块中 , 同时 调用 Job.onAwait 函数 , 同时执行两个协程, 哪个先执行完毕, 就取哪个协程的执行结果 ;

                // 同时执行两个协程, 哪个先执行完毕, 就取哪个协程的执行结果
                val data = select<String> 
                    localJob.onAwaitit
                    remoteJob.onAwaitit
                

代码示例 :

package kim.hsl.coroutine

import android.os.Bundle
import androidx.appcompat.app.AppCompatActivity
import kotlinx.coroutines.*
import kotlinx.coroutines.selects.select

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

        runBlocking 
            GlobalScope.launch 
                val localJob = GlobalScope.getDataFromLocal()
                val remoteJob = GlobalScope.getDataFromNetwork()

                // 同时执行两个协程, 哪个先执行完毕, 就取哪个协程的执行结果
                val data = select<String> 
                    localJob.onAwaitit
                    remoteJob.onAwaitit
                

                println("最终数据为 $data")
            
        
    

    // 将 getDataFromLocal 函数定义为 GlobalScope 的扩展函数
    fun GlobalScope.getDataFromLocal() = async(Dispatchers.IO) 
        delay(500)
        println("获取本地数据")
        "本地数据"
    

    // 将 getDataFromNetwork 函数定义为 GlobalScope 的扩展函数
    fun GlobalScope.getDataFromNetwork() = async(Dispatchers.IO) 
        delay(1000)
        println("获取网络数据")
        "网络数据"
    

执行结果 :

22:03:52.684 System.out   kim.hsl.coroutine     I  获取本地数据
22:03:52.686 System.out   kim.hsl.coroutine     I  最终数据为 本地数据
22:03:53.176 System.out   kim.hsl.coroutine     I  获取网络数据

三、Channel 通道多路复用

---

Channel 通道多路复用 , 就是 多个 Channel 通道同时 传递消息 , 取传递消息最快的 Channel 通道中的信息 ;

代码示例 :

package kim.hsl.coroutine

import android.os.Bundle
import androidx.appcompat.app.AppCompatActivity
import kotlinx.coroutines.*
import kotlinx.coroutines.channels.Channel
import kotlinx.coroutines.selects.select

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

        runBlocking 
            val channel0 = Channel<Int>()
            val channel1 = Channel<Int>()

            GlobalScope.launch 
                delay(500)
                channel0.send(500)
                println("channel0 通道发送 500")
            

            GlobalScope.launch 
                delay(1000)
                channel1.send(1000)
                println("channel1 通道发送 1000")
            

            val num = select<Int> 
                channel0.onReceive it
                channel1.onReceive it
            

            println("最终结果为 $num")
        
    

执行结果 :

22:16:39.609 System.out   kim.hsl.coroutine     I  channel0 通道发送 500
22:16:39.611 System.out   kim.hsl.coroutine     I  最终结果为 500