協(xié)程源碼的結(jié)構(gòu)

在研究Kotlin源碼之前，得先搞懂Kotlin源碼結(jié)構(gòu)分布。不然找不到該看哪里的代碼。看源碼之前當然先得有一個目標，最好是帶著這個目標去看源碼才比較有針對性，抓主流程，不然可能會陷入浩瀚的源碼細節(jié)中。

協(xié)程源碼，按道理可以分成2個倉庫，一個是Kotlin倉庫，一個是Kotlin協(xié)程倉庫。

• Kotlin倉庫 https://github.com/JetBrains/kotlin
• 協(xié)程倉庫 kotlinx.coroutines https://github.com/Kotlin/kotlinx.coroutines

Kotlin倉庫中定義了協(xié)程的基礎(chǔ)元素，這些基礎(chǔ)元素非常關(guān)鍵，它們是構(gòu)建協(xié)程的基礎(chǔ)。而協(xié)程倉庫相當于是用Kotlin倉庫中定義的基礎(chǔ)元素來實現(xiàn)協(xié)程的邏輯。

Kotlin協(xié)程源碼分為3層：

• 基礎(chǔ)層：Kotlin庫中定義的協(xié)程基礎(chǔ)元素。比如CancellationException、CombinedContext、Continuation、ContinuationInterceptor、CoroutineContext、SafeContinuation等。
• 中間層：協(xié)程倉庫中，協(xié)程框架的通用邏輯kotlinx.coroutine-common。比如Job、Deferred、Select、Channel、Flow。
• 平臺層：協(xié)程倉庫中，協(xié)程在特定平臺的實現(xiàn)。如JVM、JS、Native。

下面，我們來詳細了解一下這些層是怎么分布的。

基礎(chǔ)層

Kotlin庫中，協(xié)程的基礎(chǔ)層具體位置是在/kotlin/libraries/stdlib/src/kotlin/coroutines/里面。官方把這些基礎(chǔ)元素放標準庫里面，是為了解耦。

• 通過這些基礎(chǔ)元素可以組合成各種協(xié)程框架，雖然目前是官方的協(xié)程框架組合的最好。
• 在基礎(chǔ)層定義好了API之后，協(xié)程庫在各自的平臺層才好有規(guī)可循，在這些API下面開發(fā)平臺相關(guān)的代碼。

中間層

在kotlin.coroutines庫中的/kotlinx.coroutines/kotlinx-coroutines-core/common/子模塊下，是一些公共的邏輯。比如launch、async、withContext、Deferred、Job、NonCancellable、Channel、Flow、AbstractCoroutine，這些東西是對基礎(chǔ)層的元素進行的封裝，使上手協(xié)程更容易。

在這些公共邏輯的源碼里，是不涉及平臺相關(guān)的邏輯的。

平臺層

因為Kotlin是跨平臺的，所以它的平臺相關(guān)的邏輯又分為了js、jvm、native，它們的目錄與common平級，分別是：

js：kotlinx-coroutines-core/js/

jvm：kotlinx-coroutines-core/jvm/

native：kotlinx-coroutines-core/native/

我們重點關(guān)注一下jvm的就行，下面是jvm目錄下的代碼，其他平臺也需要實現(xiàn)其自己的線程池、事件循環(huán)、異步任務等。

.
├── AbstractTimeSource.kt
├── Builders.kt
├── CoroutineContext.kt
├── CoroutineExceptionHandlerImpl.kt
├── Debug.kt
├── DebugStrings.kt
├── DefaultExecutor.kt
├── Dispatchers.kt
├── EventLoop.kt    //事件循環(huán)
├── Exceptions.kt
├── Executors.kt
├── Future.kt     
├── Interruptible.kt
├── Runnable.kt    //java.lang.Runnable
├── SchedulerTask.kt
├── ThreadContextElement.kt     //線程池
├── ThreadPoolDispatcher.kt
├── channels
│?? ├── Actor.kt
│?? └── TickerChannels.kt
├── debug
│?? ├── AgentPremain.kt
│?? └── internal
│??     ├── AgentInstallationType.kt
│??     ├── ConcurrentWeakMap.kt
│??     ├── DebugCoroutineInfo.kt
│??     ├── DebugCoroutineInfoImpl.kt
│??     ├── DebugProbes.kt
│??     ├── DebugProbesImpl.kt
│??     ├── DebuggerInfo.kt
│??     └── StackTraceFrame.kt
├── flow
│?? └── internal
│??     ├── FlowExceptions.kt
│??     └── SafeCollector.kt
├── internal
│?? ├── Concurrent.kt
│?? ├── ExceptionsConstructor.kt
│?? ├── FastServiceLoader.kt
│?? ├── InternalAnnotations.kt
│?? ├── LocalAtomics.kt
│?? ├── MainDispatchers.kt
│?? ├── ProbesSupport.kt
│?? ├── ResizableAtomicArray.kt
│?? ├── StackTraceRecovery.kt
│?? ├── Synchronized.kt
│?? ├── SystemProps.kt
│?? ├── ThreadContext.kt
│?? └── ThreadLocal.kt   //java.lang.ThreadLocal
└── scheduling
    ├── CoroutineScheduler.kt
    ├── Deprecated.kt
    ├── Dispatcher.kt
    ├── Tasks.kt
    └── WorkQueue.kt

以上就是kotlin源碼結(jié)構(gòu)層次詳解的詳細內(nèi)容，更多關(guān)于kotlin源碼結(jié)構(gòu)的資料請關(guān)注腳本之家其它相關(guān)文章！

最新評論