在 Kotlin 中,實現并發主要依賴于協程(coroutines)。協程是一種輕量級的線程,它允許你編寫異步代碼,而無需處理線程或線程池。Kotlin 提供了強大的協程庫,使得編寫并發代碼變得簡單而高效。
以下是如何使用 Kotlin 協程實現并發的幾個關鍵概念:
引入協程依賴:
在你的 build.gradle
文件中添加 Kotlin 協程庫的依賴:
dependencies {
implementation 'org.jetbrains.kotlinx:kotlinx-coroutines-core:1.6.0'
}
創建協程作用域:
使用 CoroutineScope
創建一個協程作用域,以便在其中啟動和管理協程。你可以使用 GlobalScope
或自定義的作用域。
val scope = CoroutineScope(Dispatchers.Default)
啟動協程:
使用 launch
或 async
函數啟動協程。launch
用于非阻塞的異步任務,而 async
用于可以返回結果的異步任務。
scope.launch {
// 異步任務代碼
}
使用 Dispatchers
:
Kotlin 提供了不同的調度器(dispatchers),如 Dispatchers.Default
、Dispatchers.IO
和 Dispatchers.Main
。你可以根據需要選擇合適的調度器來執行協程。
scope.launch(Dispatchers.IO) {
// 執行 I/O 密集型任務
}
處理結果:
如果你使用 async
啟動了一個返回結果的協程,可以使用 await()
函數獲取結果。
val result = scope.async(Dispatchers.IO) {
// 執行 I/O 密集型任務并返回結果
}.await()
取消協程:
你可以使用 cancel
函數取消協程。一旦協程被取消,它將停止執行并拋出 CancellationException
。
val job = scope.launch {
// 異步任務代碼
}
// 取消協程
job.cancel()
以下是一個完整的示例,展示了如何使用 Kotlin 協程實現并發:
import kotlinx.coroutines.*
fun main() = runBlocking {
val scope = CoroutineScope(Dispatchers.Default)
val jobs = List(10) {
scope.launch(Dispatchers.IO) {
performTask("Task $it")
}
}
jobs.forEach { it.join() }
}
suspend fun performTask(task: String): String {
delay(1000L) // 模擬 I/O 操作
println("$task completed")
return task
}
在這個示例中,我們創建了一個協程作用域,并在其中啟動了 10 個異步任務。每個任務都在 Dispatchers.IO
上執行,模擬 I/O 操作。最后,我們使用 join
函數等待所有任務完成。