> 文章列表 > kotlin协程、线程切换,函数方法委托

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

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

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 会阻塞所在线程。https://blog.csdn.net/zhangphil/article/details/129263455