协程搬运工-基础

本文涉及的产品
日志服务 SLS,月写入数据量 50GB 1个月
简介: 协程搬运工-基础

协程简介


协程是轻量级的线程,它们在某些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只能在协程中调用



相关实践学习
日志服务之使用Nginx模式采集日志
本文介绍如何通过日志服务控制台创建Nginx模式的Logtail配置快速采集Nginx日志并进行多维度分析。
相关文章
|
Java 调度
协程搬运工-上下文和调度器
协程搬运工-上下文和调度器
116 0
协程搬运工-组合挂起函数
协程搬运工-组合挂起函数
109 0
协程搬运工-取消与超时
协程搬运工-取消与超时
270 0
|
4月前
|
Go Python
使用python实现一个用户态协程
【6月更文挑战第28天】本文探讨了如何在Python中实现类似Golang中协程(goroutines)和通道(channels)的概念。文章最后提到了`wait_for`函数在处理超时和取消操作中的作
41 1
使用python实现一个用户态协程
|
10天前
|
调度 Python
python3 协程实战(python3经典编程案例)
该文章通过多个实战案例介绍了如何在Python3中使用协程来提高I/O密集型应用的性能,利用asyncio库以及async/await语法来编写高效的异步代码。
11 0
|
3月前
|
数据库 开发者 Python
实战指南:用Python协程与异步函数优化高性能Web应用
【7月更文挑战第15天】Python的协程与异步函数优化Web性能,通过非阻塞I/O提升并发处理能力。使用aiohttp库构建异步服务器,示例代码展示如何处理GET请求。异步处理减少资源消耗,提高响应速度和吞吐量,适用于高并发场景。掌握这项技术对提升Web应用性能至关重要。
75 10
|
3月前
|
数据处理 Python
深入探索:Python中的并发编程新纪元——协程与异步函数解析
【7月更文挑战第15天】Python 3.5+引入的协程和异步函数革新了并发编程。协程,轻量级线程,由程序控制切换,降低开销。异步函数是协程的高级形式,允许等待异步操作。通过`asyncio`库,如示例所示,能并发执行任务,提高I/O密集型任务效率,实现并发而非并行,优化CPU利用率。理解和掌握这些工具对于构建高效网络应用至关重要。
43 6
|
3月前
|
大数据 数据处理 API
性能飞跃:Python协程与异步函数在数据处理中的高效应用
【7月更文挑战第15天】在大数据时代,Python的协程和异步函数解决了同步编程的性能瓶颈问题。同步编程在处理I/O密集型任务时效率低下,而Python的`asyncio`库支持的异步编程利用协程实现并发,通过`async def`和`await`避免了不必要的等待,提升了CPU利用率。例如,从多个API获取数据,异步方式使用`aiohttp`并发请求,显著提高了效率。掌握异步编程对于高效处理大规模数据至关重要。
46 4
|
3月前
|
设计模式 机器学习/深度学习 测试技术
设计模式转型:从传统同步到Python协程异步编程的实践与思考
【7月更文挑战第15天】探索从同步到Python协程异步编程的转变,异步处理I/O密集型任务提升效率。async/await关键词定义异步函数,asyncio库管理事件循环。面对挑战,如思维转变、错误处理和调试,可通过逐步迁移、学习资源、编写测试和使用辅助库来适应。通过实践和学习,开发者能有效优化性能和响应速度。
46 3
|
3月前
|
调度 Python
揭秘Python并发编程核心:深入理解协程与异步函数的工作原理
【7月更文挑战第15天】Python异步编程借助协程和async/await提升并发性能,减少资源消耗。协程(async def)轻量级、用户态,便于控制。事件循环,如`asyncio.get_event_loop()`,调度任务执行。异步函数内的await关键词用于协程间切换。回调和Future对象简化异步结果处理。理解这些概念能写出高效、易维护的异步代码。
45 2