3

我正在试验Kotlin Coroutines并有以下代码：

fun main(args: Array<String>) = runBlocking {
    val cores = Runtime.getRuntime().availableProcessors()
    println("number of cores: $cores")

    val jobs = List(10) {
        async(CommonPool) {
            delay(100)
            println("async #$it on thread ${Thread.currentThread().name}")
        }
    }
    jobs.forEach { it.join() }
}

这是我的输出：

number of cores: 4
async number:0 on thread ForkJoinPool.commonPool-worker-2
async number:2 on thread ForkJoinPool.commonPool-worker-3
async number:3 on thread ForkJoinPool.commonPool-worker-3
async number:4 on thread ForkJoinPool.commonPool-worker-3
async number:5 on thread ForkJoinPool.commonPool-worker-3
async number:1 on thread ForkJoinPool.commonPool-worker-1
async number:7 on thread ForkJoinPool.commonPool-worker-3
async number:6 on thread ForkJoinPool.commonPool-worker-2
async number:9 on thread ForkJoinPool.commonPool-worker-3
async number:8 on thread ForkJoinPool.commonPool-worker-1

根据 Roman Elizarov对另一个协程相关问题的回答：

“启动只是创建了新的协程，而 CommonPool 将协程分派到 ForkJoinPool.commonPool()，它确实使用了多个线程，因此在本示例中在多个 CPU 上执行。”

根据 Java 8文档：

“对于需要单独或自定义池的应用程序，可以使用给定的目标并行度级别构建 ForkJoinPool；默认情况下，等于可用处理器的数量。”

为什么只使用了 3 个工作线程？即使我将异步任务的数量增加到 1000+，也有相同的 3 个工作线程。

我的配置：Mac/High Sierra，带有双核 cpu（带有超线程，因此有 4 个可见核心）、Kotlin 1.2、kotlinx-coroutines-core:0.19.3 和 JVM 1.8

4

2 回答 2

6

如果您查看 的实现CommonPool，您会注意到它正在运行java.util.concurrent.ForkJoinPool或具有以下大小的线程池：

(Runtime.getRuntime().availableProcessors() - 1).coerceAtLeast(1)

使用4可用的处理器，这将导致3您看到 3 个工作线程的原因。

ForkJoinPool-size 可以如下确定（将相同）：

ForkJoinPool.commonPool().parallelism

如果您使用协程版本 >= 1.0，请查看此答案

于 2017-12-01T11:34:00.253 回答
3

从 Coroutines 1.0 开始，代码看起来会略有不同，因为CommonPool将替换为Dispatchers.Defaultnow：

fun main(args: Array<String>) = runBlocking {
    val cores = Runtime.getRuntime().availableProcessors()
    println("number of cores: $cores")

    val jobs = List(10) {
        async(Dispatchers.Default) {
            delay(100)
            println("async #$it on thread ${Thread.currentThread().name}")
        }
    }
    jobs.forEach { it.join() }
}

此外，您现在将获得以下信息：

它由 JVM 上的共享线程池支持。默认情况下，此调度程序使用的最大线程数等于 CPU 内核数，但至少为两个。

于 2018-11-05T16:02:50.620 回答