面试必备：Kotlin 线程同步的 N 种方法

最新推荐文章于 2025-03-01 14:16:18 发布

AI_boom

最新推荐文章于 2025-03-01 14:16:18 发布

阅读量607

点赞数

分类专栏：程序员 Android 移动开发文章标签：移动开发

本文链接：https://blog.csdn.net/Android_boom/article/details/118553822

版权

本文详细介绍了 Kotlin 中实现线程同步的多种方法，包括 Thread.join, Synchronized, ReentrantLock, BlockingQueue, CountDownLatch, CyclicBarrier, CAS, volatile, Future, CompletableFuture, RxJava, Coroutine 和 Flow。通过实例解析了每种方法的使用场景和优缺点，重点推荐了在 Kotlin 中使用协程（Coroutine）作为最佳实践。" 9082489,1443564,ExtJS Panel嵌入HTML元素技巧,"['前端开发', 'Ext JS', 'HTML']

摘要生成于 C知道，由 DeepSeek-R1 满血版支持，前往体验 >

面试的时候经常会被问及多线程同步的问题，例如：

“ 现有 Task1、Task2 等多个并行任务，如何等待全部执行完成后，执行 Task3。”

在 Kotlin 中我们有多种实现方式，本文将所有这些方式做了整理，建议收藏。

1. Thread.join
2. Synchronized
3. ReentrantLock
4. BlockingQueue
5. CountDownLatch
6. CyclicBarrier
7. CAS
8. Future
9. CompletableFuture
10. Rxjava
11. Coroutine
12. Flow

我们先定义三个Task，模拟上述场景， Task3 基于 Task1、Task2 返回的结果拼接字符串，每个 Task 通过 sleep 模拟耗时：

val task1: () -> String = {
    sleep(2000)
    "Hello".also { println("task1 finished: $it") }
}

val task2: () -> String = {
    sleep(2000)
    "World".also { println("task2 finished: $it") }
}

val task3: (String, String) -> String = { p1, p2 ->
    sleep(2000)
    "$p1 $p2".also { println("task3 finished: $it") }
}
复制代码

1. Thread.join()

Kotlin 兼容 Java，Java 的所有线程工具默认都可以使用。其中最简单的线程同步方式就是使用 Thread 的 join() ：

@Test
fun test_join() {
    lateinit var s1: String
    lateinit var s2: String

    val t1 = Thread { s1 = task1() }
    val t2 = Thread { s2 = task2() }
    t1.start()
    t2.start()

    t1.join()
    t2.join()

    task3(s1, s2)

}
复制代码

2. Synchronized

使用 synchronized 锁进行同步

	@Test
    fun test_synchrnoized() {
        lateinit var

最低0.47元/天解锁文章