コルーチンで複数結果の待ち合わせ処理

Question

前提・実現したいこと

kotlinのコルーチンで複数結果の待ち合わせ処理を行いたいです。

該当のソースコード

    val list:List<String> = リストデータ取得関数()
    var latch = CountDownLatch(list.count())
    list.forEach() {
        async {
            latch.countDown()
        }
    }
    latch.await()

試したこと

上記ソースで複数待ち合わせ(CountDownLatch対応)はできたのですが、awaitなどを使用すればもっとわかりやすいように思えます。
ただ、awaitでは、1つのものしか待ち合わせができないため、なにか良い方法はないでしょうか？

補足情報（FW/ツールのバージョンなど）

kotlin:1.2.51

Answer 1

あまり難しく考える必要はありません。
各asyncに対しawaitを呼ぶことで全ての結果を待ち合わせるように書けます。

// 直列に非同期処理を実行
val results = list.map { async { ... }.await() }

// 並列に非同期処理を実行
// （先に全てのasyncを開始して、それからawaitする）
val results = list.map { async { ... } }.map { it.await() }

補足

CountDownLatchのように、コルーチン外でasyncの結果を待ちたい（現在のスレッドをブロックしたい）ということであれば、runBlockingを使ってください。

runBlocking {
    val results = list.map { async { ... } }.map { it.await() }
}

Comments

[tamago83]

ありがとうございます。
欲しかった内容が、runBlockingの動きでした。