Tag: 并行处理

线程未按顺序依次运行

我期望输出为0 0 1 1 2 2 …但是输出是0 1 2 3 … 0 1 2 3 class Runner: Thread() { override fun run() { var i = 0 while (i < 10) { println("${Thread.currentThread().name} $i") i++ } try { Thread.sleep(100) } catch (e: Exception) { e.printStackTrace() } } } fun main(args: Array<String>) { val nah = […]

Kotlin系列的并行操作?

在斯卡拉,人们可以很容易地做一个平行的地图,forEach等,与: collection.par.map(..) Kotlin有没有相同的东西?

Kotlin过程集合并行?

我有一个对象的集合,我需要执行一些转换。 目前我正在使用: var myObjects: List<MyObject> = getMyObjects() myObjects.forEach{ myObj -> someMethod(myObj) } 它工作正常,但我希望通过并行运行someMethod()来加速它,而不是等待每个对象完成,然后再开始下一个对象。 Kotlin有没有办法做到这一点? 也许与doAsyncTask什么的? 我知道一年前这个问题是不可能的, 但是现在Kotlin拥有doAsyncTask这样的协同程序,我很好奇,如果任何协程都可以帮助的话