Coroutine Builder: その概要、コルーチンビルダーの種類と動作

Coroutine Builderとは？

Coroutine Builderは、CoroutineScopeとsuspendブロックを受け取り、新しいコルーチンを作成して起動するKotlinの拡張関数です。各ビルダーは、結果の有無、スレッドブロッキングの有無、非同期実行など、コルーチンの実行方法を定義します。ビルダーは言語のコルーチンモデルへのエントリーポイントです。

すべてのビルダーはCoroutineScopeを介して動作し、子コルーチンのライフサイクルを管理します。スコープがキャンセルされると、そのスコープを介して起動されたすべてのコルーチンが自動的にキャンセルされます — これが構造化された並行処理の原則です。このアプローチにより、コルーチンのリークを防ぎ、予測可能な終了を保証します。

import kotlinx.coroutines.*

fun main() = runBlocking {
    // ビルダーはCoroutineScope内で実行されます
    val job = launch {
        delay(1000L)
        println("世界！")
    }
    println("こんにちは、")
    job.join()
}

コルーチンビルダーの主な種類

Kotlinには4つの組み込みコルーチンビルダーがあります: launch、async、runBlocking、produce。それぞれに独自の戻り値の型と適用領域があります。Androidモバイル開発では、launchとasyncが主要なビルダーで、ノンブロッキングで動作し、アーキテクチャコンポーネントと統合できます。

各ビルダーは追加パラメーターを受け付けます: CoroutineStart（起動戦略）、CoroutineContext（ディスパッチャー、例外）、名前付きコードブロック。デフォルトでは、コルーチンは即座に開始されます（CoroutineStart.DEFAULT）。

launch: fire-and-forget実行

launchはAndroid開発で最も使用されるビルダーです。結果を返さないコルーチンを起動し、そのライフサイクルを管理するためのJobオブジェクトを返します。データベースへの保存、アナリティクスの送信、UIの更新など、副作用のみが必要な操作に最適です。

launchの構文と使用法

launchビルダーはCoroutineScope、オプションのCoroutineContext、およびsuspendブロックを受け取ります。返されるJobを使用すると、コルーチンのキャンセル、完了の待機、ステータスの確認ができます。

val scope = CoroutineScope(Dispatchers.IO + SupervisorJob())
val job: Job = scope.launch(CoroutineStart.LAZY) {
    val data = fetchFromNetwork()
    saveToDatabase(data)
}
job.start()
job.join()

CoroutineStart.LAZYパラメーターは、start()またはjoin()が明示的に呼び出されるまで実行を延期します。これは遅延初期化や条件付き実行に便利です。標準の即時実行にはCoroutineStart.DEFAULTを使用するか、パラメーターを省略します。

async: 結果を伴う並列計算

asyncはDeferred<T> — 結果の非同期プロミスを返すビルダーです。await()を呼び出すと、スレッドをブロックせずに結果が得られるまでコルーチンを一時停止します。これはKotlinコルーチンにおける並列タスクの主要なメカニズムです。

2つのリクエストを並列実行

asyncは、複数の独立した操作を同時に実行する必要がある場合に特に効果的です。suspend関数の逐次呼び出しとは異なり、asyncはコルーチンを並列に起動し、総実行時間を短縮します。

suspend fun fetchUserData(): UserData {
    val deferred1 = CoroutineScope(Dispatchers.IO).async { api.getProfile() }
    val deferred2 = CoroutineScope(Dispatchers.IO).async { api.getSettings() }
    val deferred3 = CoroutineScope(Dispatchers.IO).async { api.getNotifications() }
    return UserData(
        profile = deferred1.await(),
        settings = deferred2.await(),
        notifications = deferred3.await()
    )
}

DeferredはJobを継承しているため、asyncはキャンセル、完了待機、例外処理などすべてのライフサイクル操作をサポートします。スコープがキャンセルされると、子Deferredコルーチンは自動的にキャンセルされます。

runBlocking: blocking世界への橋渡し

runBlockingは、コルーチンが完了するまで現在のスレッドをブロックする唯一のビルダーです。新しいCoroutineScopeを作成し、渡されたコルーチンを起動して、呼び出しスレッドをブロックします。main()エントリーポイント、テスト、blockingコードとの統合時に使用されます。

runBlockingが必要なケース

runBlockingは3つのシナリオで正当化されます: アプリケーションのエントリーポイント（main）、suspend関数の単体テスト、suspendが使用できないコールバックベースのライブラリとの統合。本番Androidコードでは、メインスレッドでのrunBlockingの使用は強く推奨されません。

class CoroutineTest {
    @Test
    fun `test suspend function`() = runBlocking {
        val result = mySuspendFunction()
        assertEquals("expected", result)
    }
}

テストでは、runBlockingの代わりにTestCoroutineDispatcherを備えたkotlinx-coroutines-testを使用することをお勧めします。これにより時間制御が可能になり、テスト環境でのブロッキングを回避できます。

適切なビルダーの選び方

Coroutine Builderの選択は、戻り値と実行シナリオによって異なります。データを返す必要がない操作にはlaunchを使用します。非同期操作の結果が必要な場合はasyncを使用します。runBlockingは橋渡しのみに使用し、リアクティブストリームにはproduceをFlowに置き換えてください。

Android向け実践的な推奨事項

Kotlin Coroutinesを使用するAndroidプロジェクトでは、launchとasyncが主要なビルダーのペアです。launchはViewModelやUseCasesでコルーチンを起動するために使用され、asyncはネットワークやデータベースへの並列リクエストに使用されます。最新のライブラリ（Ktor、Room）はすでにsuspend関数をサポートしており、asyncの直接使用の必要性を最小限に抑えます。

• launch — fire-and-forget用（ロギング、アナリティクス、キャッシング）
• async — 結果を結合する並列リクエスト用
• runBlocking — main()とテストのみ（本番環境のMainスレッドでは使用しない）
• produce — Flow / SharedFlow / StateFlowに置き換え