@
- 反編譯后代碼分析
關于協(xié)程的一些理解
?協(xié)程掛起讓異步代碼可以像同步代碼一樣調(diào)用,但其本質(zhì)還是同步,即協(xié)程體中的代碼其實是同步。
?
?因為協(xié)程也只是對線程池的封裝,所以需要了解些線程的一些知識。線程本身已經(jīng)有的協(xié)程也會有,但是協(xié)程有的線程不一定有
?
?編譯器會為每一個掛起函數(shù)生成一個匿名內(nèi)部類,其繼承SuspendLabmba類重寫其invokeSuspend方法,這個方法里面即為協(xié)程體的代碼【大致內(nèi)容請先了解】
?
?編譯器會對協(xié)程體中的掛起函數(shù)和普通函數(shù)進行切割,切割時進行l(wèi)abel的自增來保證之后代碼的執(zhí)行順序,即協(xié)程保證運行順序的本質(zhì)。【對比線程:進行PC程序計數(shù)器的控制來恢復執(zhí)行】
?
?協(xié)程體中會添加一個label字段,標識接下來該運行協(xié)程體中的哪行代碼【即協(xié)程如何知道自己執(zhí)行到哪步是用這個label完成的】(對比線程:線程存儲下一個代碼指令是用PC計數(shù)器來做的)
?
?協(xié)程體中的數(shù)據(jù),看過之前那篇文章的人應該大致了解掛起函數(shù)其實就是匿名內(nèi)部類,數(shù)據(jù)是保存在棧幀中的,(對比線程:也是通過棧幀中的局部變量表和操作數(shù)棧來存儲數(shù)據(jù))
?
?協(xié)程體中碰到掛起函數(shù)會直接返回,等待掛起函數(shù)通知
?
?當我們調(diào)用掛起函數(shù)時都會傳入一個Continuation,掛起函數(shù)執(zhí)行完正常退出或者拋異常退出這個時候外面的協(xié)程需要知道這個信息,怎么通知呢?通過Continuation的resumewith方法,這個方法會再次調(diào)用invokeSuspend取出label來保證之后執(zhí)行代碼的順序,即協(xié)程自動恢復運行的本質(zhì)
?
?(對比線程:方法正常執(zhí)行完成之后有兩種情況1、正常結(jié)束,2.異常退出。其里面的PC計數(shù)器保證之后執(zhí)行的代碼順序,也就是說協(xié)程在原本線程之上又加了一層控制)
?
?協(xié)程體中可以在開啟一個協(xié)程,也就是協(xié)程具有父子關系的本質(zhì)。在協(xié)程伊始的時候會默認給一些默認數(shù)據(jù)(包括協(xié)程體運行在哪個線程即調(diào)度器其通過攔截器實現(xiàn),執(zhí)行狀態(tài)檢測用到的Job,攔截器等等)這些數(shù)據(jù)保存在協(xié)程的上下文中,
?
?當在協(xié)程體中又開啟了一個協(xié)程時,其會獲取父協(xié)程的上下文進行和自己的合并作為自己的上下文。
【簡而言之,和協(xié)程本身有關的數(shù)據(jù)保存在上下文中,和業(yè)務有關的代碼會放在匿名內(nèi)部類中。】
?
基礎框架層源碼分析
val createCoroutine = suspend {
//掛起函數(shù)代碼
}.createCoroutine(object : Continuation<Unit> {
override val context: CoroutineContext
get() = TODO("Not yet implemented")
override fun resumeWith(result: Result<Unit>) {
//可從result中獲取返回值或異常
}
})
createCoroutine.resume(Unit)
?1.編譯器會對掛起函數(shù)做處理,讓他繼承SuspendCorunting,重寫其invokeSuspend方法,方法體為掛起函數(shù)中的代碼 2.當手動調(diào)用createCoroutine返回值的resume方法的時候,會調(diào)用到resumeWith函數(shù),其里面會調(diào)用invokeSuspend也就是掛起函數(shù)體里面的代碼,之后兩種情況:3.碰到普通函數(shù)直接執(zhí)行;碰到掛起函數(shù)傳入Continuation并直接返回一個標識代表其為掛起函數(shù),這個時候協(xié)程直接退出,之后掛起函數(shù)執(zhí)行完調(diào)用Continuation的resumeWith繼續(xù)執(zhí)行方法體代碼【通過label確定順序】 4.在invokeSuepend中可以通過result獲取掛起函數(shù)執(zhí)行的結(jié)果:異常或者返回值。進行對應處理。
?
實戰(zhàn)分析
class ExampleUnitTest {
@Test
fun addition_isCorrect() {
GlobalScope.launch {
println("掛起點1開始")
delay(1000) //掛起點1
println("掛起點1結(jié)束")
hello() //掛起點2
println("掛起點2結(jié)束")
delay(1000) //掛起點3
println("掛起點3結(jié)束")
word() //掛起點4
}
}
//掛起函數(shù),編譯器默認傳入Continuation
suspend fun hello(){
//再次掛起
withContext(Dispatchers.IO){
delay(1000)
println("hello")
}
}
suspend fun word(){
withContext(Dispatchers.IO){
delay(1000)
println("word")
}
}
-
封裝
+關注
關注
126文章
7937瀏覽量
143078 -
代碼
+關注
關注
30文章
4798瀏覽量
68715 -
線程
+關注
關注
0文章
505瀏覽量
19703
發(fā)布評論請先 登錄
相關推薦
評論