协程搬运工-基础

简介: 协程搬运工-基础

协程简介


协程是轻量级的线程,它们在某些coroutiue上下文中与launch构建器一起启动。GlobalScope的生命周期与整个应用程序的生命周期一致。


阻塞与非阻塞


先说结论:

  1. launch不会阻塞线程
  2. async可以阻塞协程也可以不阻塞协程(无法直接运行在线程里,只能运行在协程里)
  3. runBlocking会阻塞线程
  4. suspend会阻塞协程(只能运行在协程里,无法运行在线程里)
  5. withContext会阻塞协程(只能运行在协程里,无法运行在线程里)


launch不会阻塞所在线程

  1. 代码
fun main() = runBlocking {
    log("准备启动协程")// ::A
    GlobalScope.launch {
        log("运行协程")//  ::B
        delay(1)
    }
    log("代码运行到协程体之外")//  ::C
    delay(2)
}
复制代码


  1. 日志输出
日志:  准备启动协程
日志:  代码运行到协程体之外
日志:  运行协程
复制代码
  1. 结论

本例代码中C处的日志比B处先执行,所以证明lunch不会阻塞


async可阻塞也可以不阻塞

不使用await

  1. 代码
fun main() = runBlocking {
    log("A--进入async方法体内")//A
    val async = GlobalScope.async {
        log("B--开始执行async方法体")//B
        delay(1)
        log("C--async方法体执行完成")//C
    }
    log("D-- async方法体外执行")//D
    delay(2)
}
复制代码


  1. 日志
日志:  A--进入async方法体内
日志:  D-- async方法体外执行
日志:  B--开始执行async方法体
日志:  C--async方法体执行完成
复制代码
  1. 结论

async不会阻塞线程 把上一个例子做一些小改动


使用await

  1. 代码
fun main() = runBlocking {
    log("A--进入async方法体内")//A
    val async:Deferred<Unit> = GlobalScope.async {
        log("B--开始执行async方法体")//B
        delay(1)
        log("C--async方法体执行完成")//C
    }
    async.await()//加了这样一个调用
    log("D-- async方法体外执行")//D
    delay(2)
}
复制代码


  1. 日志
日志:  A--进入async方法体内
日志:  B--开始执行async方法体
日志:  C--async方法体执行完成
日志:  D-- async方法体外执行
复制代码


  1. 结论

async如果加上了await就会阻塞线程,


runningBlock会阻塞所在线程

  1. 代码
fun main() {
    log("A--准备进入runningBlock") //A
    runBlocking {
        log("B--进入runningBlock" )//B
        delay(1)
        log("C--执行完成runningBLock")//C
    }
    log("D--runBlocking代码块外执行")//D
    runBlocking {
        delay(3)
    }
}
复制代码


  1. 执行结果
日志:  A--准备进入runningBlock
日志:  B--进入runningBlock
日志:  C--执行完成runningBLock
日志:  D--runBlocking代码块外执行
复制代码


  1. 结论

本示例中runBlocking代码块中的B和C顺序执行完成后才执行的代码块外面的D,这证明了runningBlock会阻塞线程。


suspend函数会阻塞协程

suspend会阻塞所在的协程,不会阻塞线程,因为suspend无法在线程内部调用

  1. 代码
fun main() = runBlocking {
    log("A--调用suspend函数前")
    wait2Second()
    log("B--调用suspend函数后")
    delay(3)
}
suspend fun wait2Second() {
    log("C--调用suspend函数开始")
    delay(2)
    log("D--调用suspend函数结束")
}
复制代码
  1. 日志
日志:  A--调用suspend函数前
日志:  C--调用suspend函数开始
日志:  D--调用suspend函数结束
日志:  B--调用suspend函数后
复制代码
  1. 结论

suspend函数会阻塞协程


withContext是否会阻塞协程

  1. 代码
fun main() = runBlocking {
    log("A--执行withContext前")
    withContext(Dispatchers.Default){
        log("B--开始执行withContext")
        delay(1)
        log("C--withContext执行完成")
    }
    log("D--执行withContext后")
    delay(2)
}
复制代码
  1. 日志
日志:  A--执行withContext前
日志:  B--开始执行withContext
日志:  C--withContext执行完成
日志:  D--执行withContext后
复制代码
  1. 结论

withContext会阻塞协程,withContext只能运行在协程,不能运行在线程中。本例中的Default改为Main就会报错,因为Main相当于运行在主线程


等待一个作业


launch方法会返回一个Job对象,Job对象调用了join方法后,会等待launch协程体执行完成再继续后面的任务。

join方法只能在协程体里面调用,不能在线程中调用

  1. 代码
fun main() = runBlocking {
    log("A")
    val job = GlobalScope.launch {
        log("B")
        delay(2)
        log("C")
    }
    log("D")
    job.join()
    log(E)
}
复制代码
  1. 日志
日志:  A
日志:  D
日志:  B
日志:  C
日志:  E
复制代码
  1. 结论

join会等待协程体执行完成


结构化并发


使用GlobalScope.launch是很危险的,因为它创建的是一个顶层协程,如果launch方法里执行了耗时任务,而我们的对象过早的被回收就会发生内存泄露。

这种情况的解决办法就是在我们指定的作用域范围内开启协程

举例:

  1. 代码
fun main() = runBlocking {
    log(A)
    //这个launch和GlobalScope.launch是不同的,它是运行在runBlocking的作用域内的
    launch {
        log(B)
        delay(2)
        log(C)
    }
    log(D)
}
复制代码
  1. 日志
日志:  A
日志:  D
日志:  B
日志:  C
复制代码
  1. 因为launch方法运行在外部runBlocking作用域内,


作用域构建器(直接抄官方)


除了由不同的构建器提供协程作用域之外,还可以使用 coroutineScope 构建器声明自己的作用域。它会创建一个协程作用域并且在所有已启动子协程执行完毕之前不会结束。

runBlocking 与 coroutineScope 可能看起来很类似,因为它们都会等待其协程体以及所有子协程结束。 主要区别在于,runBlocking 方法会阻塞当前线程来等待, 而 coroutineScope 只是挂起,会释放底层线程用于其他用途。 由于存在这点差异,runBlocking 是常规函数,而 coroutineScope 是挂起函数

  1. 代码
fun main() = runBlocking { // this: CoroutineScope
    launch { 
        delay(200L)
        println("Task from runBlocking")
    }
    coroutineScope { // 创建一个协程作用域
        launch {
            delay(500L) 
            println("Task from nested launch")
        }
        delay(100L)
        println("Task from coroutine scope") // 这一行会在内嵌 launch 之前输出
    }
    println("Coroutine scope is over") // 这一行在内嵌 launch 执行完毕后才输出
}
复制代码
  1. 输出


提前函数重构


我们可以把launch、async中的代码抽离成一个suspend函数,这样的代码更便于阅读


协程很轻量

image.png


全局协程像守护进程

GlobalScope启动的协程并不会使进程保活


其它

  • delay函数不会阻塞线程,但是会挂起协程,所以delay只能在协程中调用



相关实践学习
【涂鸦即艺术】基于云应用开发平台CAP部署AI实时生图绘板
【涂鸦即艺术】基于云应用开发平台CAP部署AI实时生图绘板
相关文章
|
Java 调度
协程搬运工-上下文和调度器
协程搬运工-上下文和调度器
248 0
协程搬运工-组合挂起函数
协程搬运工-组合挂起函数
219 0
协程搬运工-取消与超时
协程搬运工-取消与超时
377 0
|
4月前
|
Go 调度 Python
Golang协程和Python协程用法上的那些“不一样”
本文对比了 Python 和 Go 语言中协程的区别,重点分析了调度机制和执行方式的不同。Go 的协程(goroutine)由运行时自动调度,启动后立即执行;而 Python 协程需通过 await 显式调度,依赖事件循环。文中通过代码示例展示了两种协程的实际运行效果。
209 7
|
3月前
|
数据采集 网络协议 API
协程+连接池:高并发Python爬虫的底层优化逻辑
协程+连接池:高并发Python爬虫的底层优化逻辑
|
5月前
|
数据采集 监控 调度
干货分享“用 多线程 爬取数据”:单线程 + 协程的效率反超 3 倍,这才是 Python 异步的正确打开方式
在 Python 爬虫中,多线程因 GIL 和切换开销效率低下,而协程通过用户态调度实现高并发,大幅提升爬取效率。本文详解协程原理、实战对比多线程性能,并提供最佳实践,助你掌握异步爬虫核心技术。
|
Go Python
使用python实现一个用户态协程
【6月更文挑战第28天】本文探讨了如何在Python中实现类似Golang中协程(goroutines)和通道(channels)的概念。文章最后提到了`wait_for`函数在处理超时和取消操作中的作
238 1
使用python实现一个用户态协程
|
数据库 开发者 Python
实战指南:用Python协程与异步函数优化高性能Web应用
【7月更文挑战第15天】Python的协程与异步函数优化Web性能,通过非阻塞I/O提升并发处理能力。使用aiohttp库构建异步服务器,示例代码展示如何处理GET请求。异步处理减少资源消耗,提高响应速度和吞吐量,适用于高并发场景。掌握这项技术对提升Web应用性能至关重要。
287 10
|
调度 Python
python3 协程实战(python3经典编程案例)
该文章通过多个实战案例介绍了如何在Python3中使用协程来提高I/O密集型应用的性能,利用asyncio库以及async/await语法来编写高效的异步代码。
323 0
|
数据处理 Python
深入探索:Python中的并发编程新纪元——协程与异步函数解析
【7月更文挑战第15天】Python 3.5+引入的协程和异步函数革新了并发编程。协程,轻量级线程,由程序控制切换,降低开销。异步函数是协程的高级形式,允许等待异步操作。通过`asyncio`库,如示例所示,能并发执行任务,提高I/O密集型任务效率,实现并发而非并行,优化CPU利用率。理解和掌握这些工具对于构建高效网络应用至关重要。
217 6