Kotlin多線程編程怎樣實現線程間通信

在 Kotlin 中，可以使用多種方法實現線程間通信。這里，我們將討論兩種主要的方法：使用 Channel 和使用 CompletableDeferred。

1. 使用 Channel 進行線程間通信：

Channel 是 Kotlin 協程庫中的一個重要組件，它提供了一種在不同線程之間傳遞數據的同步機制。以下是一個簡單的示例，展示了如何使用 Channel 在兩個線程之間發送和接收數據：

import kotlinx.coroutines.*
import kotlinx.coroutines.channels.*

fun main() = runBlocking {
    val channel = Channel<Int>()

    // 啟動一個協程發送數據到 Channel
    launch {
        for (i in 1..5) {
            channel.send(i)
            println("Sent: $i")
        }
        channel.close()
    }

    // 啟動一個協程從 Channel 接收數據
    launch {
        for (value in channel) {
            println("Received: $value")
        }
    }
}

2. 使用 CompletableDeferred 進行線程間通信：

CompletableDeferred 是一個可完成的延遲計算結果，它可以在不同線程之間傳遞結果。以下是一個簡單的示例，展示了如何使用 CompletableDeferred 在兩個線程之間發送和接收結果：

import kotlinx.coroutines.*

fun main() = runBlocking {
    val deferred = CompletableDeferred<Int>()

    // 啟動一個協程計算結果并發送給 CompletableDeferred
    launch {
        val result = compute() // 假設這是一個耗時的計算任務
        deferred.complete(result)
    }

    // 啟動一個協程從 CompletableDeferred 獲取結果
    launch {
        val value = deferred.await()
        println("Received: $value")
    }
}

suspend fun compute(): Int {
    delay(1000L) // 模擬耗時任務
    return 42
}

這兩種方法都可以實現 Kotlin 中的線程間通信。Channel 更適用于需要傳遞多個值或需要關閉通道的場景，而 CompletableDeferred 更適用于只需要傳遞單個結果的場景。