Kotlin协程怎样实现并发

在 Kotlin 中，使用协程（coroutines）可以非常简单地实现并发。协程是一种轻量级的线程，它们允许你在代码中编写异步或非阻塞性的代码。要实现并发，你可以使用 launch 和 async 这两个函数。

下面是一个简单的示例，展示了如何使用 Kotlin 协程实现并发：

import kotlinx.coroutines.*

fun main() = runBlocking {
    // 创建两个协程
    val coroutine1 = launch {
        println("Coroutine 1 started")
        delay(1000L) // 模拟耗时操作
        println("Coroutine 1 finished")
    }

    val coroutine2 = launch {
        println("Coroutine 2 started")
        delay(2000L) // 模拟耗时操作
        println("Coroutine 2 finished")
    }

    // 等待所有协程完成
    coroutine1.join()
    coroutine2.join()

    println("All coroutines finished")
}

在这个示例中，我们使用 runBlocking 创建了一个主协程。然后，我们使用 launch 函数创建了两个子协程。这两个子协程会并发地执行，因为它们是在同一个主协程中启动的。delay 函数用于模拟耗时操作，它会让协程暂停一段时间。

注意，launch 函数返回一个 Job 对象，你可以使用 join() 函数等待协程完成。在这个示例中，我们使用 join() 函数等待两个子协程完成，然后打印 “All coroutines finished”。

此外，你还可以使用 async 函数来实现并发。async 函数会返回一个 Deferred 对象，你可以使用 await() 函数获取异步计算的结果。这里有一个使用 async 的示例：

import kotlinx.coroutines.*

fun main() = runBlocking {
    // 创建一个协程并启动异步计算
    val deferredResult = async {
        println("Async computation started")
        delay(1000L) // 模拟耗时操作
        "Hello, World!"
    }

    // 获取异步计算的结果
    val result = deferredResult.await()
    println("Async computation result: $result")

    println("Async computation finished")
}

在这个示例中，我们使用 async 函数创建了一个协程，并启动了一个异步计算。异步计算会立即返回一个 Deferred 对象，我们可以使用 await() 函数获取计算结果。注意，async 函数必须在 suspend 函数内部调用，因为它是一个挂起函数。