실전 레시피와 Workshop

이 장은 API 목록이 아니라 앞 장의 계약을 한 시나리오 안에서 닫는 방법을 보여줍니다. 각 recipe는 owner, child policy, ordering, capacity, cleanup을 함께 명시합니다.

Recipe 1: request 안에서 병렬 조회

suspend fun dashboard(userId: String): Dashboard = coroutineScope {
    val profile = async { profileClient.load(userId) }
    val alerts = async { alertClient.load(userId) }
    Dashboard(profile.await(), alerts.await())
}

• owner: request caller
• failure: 둘 다 필요한 atomic result, 기본 fail-fast
• cleanup: caller cancellation이 두 child에 전파
• 관측: 두 dependency latency와 전체 request latency

별도 DefaultCoroutineScope로 child를 탈출시키지 않습니다.

Recipe 2: fastest completion과 first success

suspend fun fastestCache(key: String): Value = coroutineScope {
    listOf(
        async { localCache.get(key) },
        async { regionalCache.get(key) },
    ).awaitAnyAndCancelOthers()
}

suspend fun firstAvailable(key: String): Value = firstSuccessTaskScope {
    fork { primary.get(key) }
    fork { fallback.get(key) }
    join().result { cause -> ValueUnavailable(key, cause) }
}

첫 함수는 빠른 failure도 winner입니다. 두 번째는 failure를 건너뛰고 성공을 기다립니다. Side effect에 적용한다면 idempotency가 선행 조건입니다.

Recipe 3: ordered response와 throughput-first work

val response = ids.asFlow()
    .async(Dispatchers.IO) { catalog.load(it) }
    .toList() // input order

events.asFlow()
    .mapParallel(parallelism = databasePoolSize / 2) { repository.store(it) }
    .collect() // completion order may differ

Public response ordering과 background work capacity를 같은 operator로 해결하지 않습니다.

Recipe 4: callback bridge

coroutineScope {
    val subject = PublishSubject<Event>()
    val collector = launch { subject.collect(handler) }
    subject.awaitCollector()

    val registration = source.register(
        onEvent = { event -> launch { subject.emit(event) } },
        onError = { error -> launch { subject.emitError(error) } },
    )
    try {
        collector.join()
    } finally {
        registration.close()
        collector.cancelAndJoin()
    }
}

Callback thread, suspending emission, registration cleanup의 owner를 실제 adapter에 맞게 조정합니다. 예제의 핵심은 collector registration을 기다리고 source registration을 finally에서 닫는 것입니다.

Workshop 실행 지도

학습 목표	Workshop	이 매뉴얼의 장
Flow 병렬 enrichment	kotlin/flow-extensions-parallel-enrichment	Flow
race와 fallback 차이	kotlin/flow-extensions-race-fallback	Deferred
Subject delivery 비교	kotlin/flow-extensions-subject-bridge	Subjects
Web request lifecycle	spring-boot/webflux-coroutines	Lifecycle
trace/metric propagation	observability/micrometer-tracing-coroutines	Operations

Workshop은 source of truth가 아니라 실행 가능한 companion입니다. API와 lifecycle 계약은 이 매뉴얼 및 현재 library source를 기준으로 하고, workshop은 그 계약을 바꿔가며 관찰하는 장소입니다.

실습 순서

1. 정상 경로를 실행하고 output order를 기록합니다.
2. 가장 빠른 branch를 failure로 바꿉니다.
3. collector/caller를 중간에 취소합니다.
4. parallelism과 buffer를 downstream capacity보다 크게 설정해 pressure를 관찰합니다.
5. shutdown 뒤 job/thread가 0으로 수렴하는지 확인합니다.

모듈 전체 선택 지도로 돌아가려면 Coroutine과 Flow 확장을 봅니다.