kotlin协程、线程切换，函数方法委托

柔光的暖阳◎ 2023-09-26 20:15 117阅读 0赞

## kotlin协程、线程切换，函数方法委托 ##

一般编程的技法，比如，在Android中，假设在主线程中实现了一个函数，但该函数是耗时操作，毫无疑问，需要将这个函数的实现切入非主线程中操作，那么可以设计一种托管的函数，在托管的函数里面干脏活，处理完成后，把结果抛到主线程。

import kotlinx.coroutines.*
    
    // myfun()干脏活的，目的是把long_time函数切入后台线程耗时操作。
    // long_time相当于耗时的sum()，目的是把常规的sum()耗时操作调度到后台线程中操作。
    fun myfun(
        a: Int,
        b: Int,
        long_time: (n1: Int, n2: Int) -> Int, result: (n: Int) -> Unit
    ) {
        //耗时操作放入IO线程
        runBlocking(Dispatchers.IO) {
            println("runBlocking - tid:${Thread.currentThread().threadId()}")
    
            val n1 = a //此处的n1和long_time_fun的n1没关系
            val n2 = b //此处的n2和long_time_fun的n2没关系
    
            //long_time_fun(a,b)也可以
            var r = long_time(n1, n2)
    
            //把结果抛回去
            result(r)
        }
    }
    
    //耗时函数，计算瓶颈模块
    fun sum(a: Int, b: Int): Int {
        Thread.sleep(1000)
        println("sum - tid:${Thread.currentThread().threadId()}")
        return a + b
    }
    
    fun main(args: Array<String>) {
        println("main - tid:${Thread.currentThread().threadId()}")
    
        myfun(2, 3, { a, b -> sum(a, b) }) {
            println("结果1-a: $it - tid:${Thread.currentThread().threadId()}")
            runBlocking(Dispatchers.IO) {
                println("结果1-b: $it - tid:${Thread.currentThread().threadId()}")
            }
        }
    
        println("---")
    
        myfun(4, 5, { a, b -> sum(a, b) }) {
            println("结果2-a: $it - tid:${Thread.currentThread().threadId()}")
            runBlocking(Dispatchers.Default) {
                println("结果2-b: $it - tid:${Thread.currentThread().threadId()}")
            }
        }
    }

> main - tid:1  
> runBlocking - tid:22  
> sum - tid:22  
> 结果1-a: 5 - tid:22  
> 结果1-b: 5 - tid:24  
> \---  
> runBlocking - tid:22  
> sum - tid:22  
> 结果2-a: 9 - tid:22  
> 结果2-b: 9 - tid:24

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

[favicon32.ico]: https://g.csdnimg.cn/static/logo/favicon32.ico
[kotlin_runBlocking _zhangphil_-CSDN_runBlocking _3_3_runBlocking _3_runBlocking _runBlocking _kotlin_runBlocking _ runBlocking _ runBlocking _favicon32.ico_https_blog.csdn.net_zhangphil_article_details_129263455]: https://blog.csdn.net/zhangphil/article/details/129263455