如何将Java线程转换为Kotlin Coroutines？

Question

我有一段“丑陋”的 Java 代码，需要转换为 Kotlin 惯用的协程，但我不太清楚如何转换。

Thread[] pool=new Thread[2*Runtime.getRuntime().availableProcessors()];
        for (int i=0;i<pool.length;i++)
            pool[i]=new Thread(){
                public void run() {
                    int y; while((y=yCt.getAndIncrement())<out.length) putLine(y,out[y]);
                }
            };
        for (Thread t:pool) t.start();
        for (Thread t:pool) t.join();

我认为可以使用 runBlocking 来实现，但是如何处理 availableProcessors 计数？

Answer 1

我将在此处做一些假设：

1. putline（）是CPU密集型而不是IO操作。我认为这是因为它使用2 * CPU内核的线程执行，通常用于CPU密集型任务。
2. 我们只需要为out中的每个项目执行putline（）。从上面的代码中，尚不清楚eg yct最初是0。
3. OUT不像数百万个项目那样大。
4. 您不会在Kotlin中寻找1：1相同的代码，而是相同的代码。

然后，解决方案真的很容易：

coroutineScope {
    out.forEachIndexed { index, item ->
        launch(Dispatchers.Default) { putLine(index, item) }
    }
}

几个解释的单词：

• deptagter.default coroutine dispatcher专门用于CPU计算，其线程数量取决于CPU内核的数量。我们不需要创建自己的线程，因为Coroutines提供合适的线程池。
• 我们不会手动处理任务的队列，因为Coroutines很轻巧，我们可以根据每个项目安排一个单独的Coroutine，它们将自动排队。
• coroutinescope（）等待其孩子，因此我们不需要手动等待所有异步任务。在所有任务完成时，将执行coroutinesCope（）下方的任何代码。

Java/线程与Kotlin/Coroutines代码之间的行为存在一些差异：

• dispatchers.default默认情况下具有螺纹= CPU内核的数量，而不是2 * CPU内核。
• 在Coroutines解决方案中，如果任何任务失败，则整个操作会引发异常。在原始代码中，错误被忽略，应用程序以不一致的状态继续。
• 在Coroutines解决方案中，线程池与应用程序的其他组件共享。这可能是理想的行为。