[kotlin/코틀린 코루틴의 정석] 5장. async와 Deferred

`launch` : 작업 실행 후 결과를 반환하지 않음

`async` : 코루틴으로부터 결괏값을 수신 → Deferred 객체 반환

 

async 사용해 결과값 수신하기

async 사용해 Deferred 만들기

fun <T> CoroutineScope.async(
	context: CoroutineContext = EmptyCoroutineContext,   // CoroutineDispatcher 설정 가능
	start: CoroutineStart = CoroutineStart.DEFAULT,  // 지연시작 설정 가능
	block: suspend CoroutineScope.() -> T
): Deferred<T>

Deferred

• 코루틴을 추상화한 객체
• 코루틴으로부터 생성된 결과값을 감싸는 기능을 가짐
• 결과값의 타입은 제네릭 타입 <T>

 

await를 사용한 결과값 수신

`await()`

• 결과값 수신의 대기를 위한 함수
• Deferred 코루틴이 실행 완료될 때까지 await() 를 호출한 코루틴 일시 중단
• Deferred 코루틴 실행이 완료되면 결과값을 반환하고 코루틴 재개
• Job 객체의 join() 와 유사한 동작

fun main() = runBlocking<Unit> {
  val networkDeferred: Deferred<String> = async(Dispatchers.IO) {
    delay(1000L) // 네트워크 요청
    return@async "Dummy Response" // 결과값 반환
  }
  val result = networkDeferred.await() // networkDeferred로부터 결과값이 반환될 때까지 runBlocking 일시 중단
  println(result) // Dummy Response 출력
}

 

Deferred는 특수한 형태의 Job이다

• Deferred 인터페이스는 Job 인터페이스의 서브타입으로 선언된 인터페이스
  → 결과값 수신을 위해 Job 객체에 몇가지 기능만이 추가됐을 뿐
• Job 객체의 모든 함수와 프로퍼티를 사용할 수 있음(join, cancle, …)

 

복수의 코루틴으로부터 결과값 수신하기

await를 사용해 복수의 코루틴으로부터 결과값 수신하기

fun main() = runBlocking<Unit> {
  val startTime = System.currentTimeMillis() // 1. 시작 시간 기록
  val participantDeferred1: Deferred<Array<String>> = async(Dispatchers.IO) { // 2. 플랫폼1에서 등록한 관람객 목록을 가져오는 코루틴
    delay(1000L)
    return@async arrayOf("James","Jason")
  }

  val participantDeferred2: Deferred<Array<String>> = async(Dispatchers.IO) { // 3. 플랫폼2에서 등록한 관람객 목록을 가져오는 코루틴
    delay(1000L)
    return@async arrayOf("Jenny")
  }

  val participants1 = participantDeferred1.await() // 4. 결과가 수신 될 때까지 대기
  val participants2 = participantDeferred2.await() // 5. 결과가 수신 될 때까지 대기

  println("[${getElapsedTime(startTime)}] 참여자 목록: ${listOf(*participants1, *participants2)}") // 6. 지난 시간 기록 및 참여자 목록 병합
}

1. `participantDeferred1` 코루틴 실행
2. `participantDeferred2` 코루틴 실행
3. `participantDeferred1` 결과값 대기
4. `participantDeferred2` 결과값 대기

➡️ 코루틴 두개가 동시에 실행되어 모든 코루틴이 완료되기까지 1초 정도만 소요

 

awaitAll을 사용한 결과값 수신

suspend fun <T> awaitAll(vararg deferred: Deferred<T>): List<T>

• 가변인자로 Deferred 타입의 객체를 받아 인자로 받은 모든 코루틴으로부터 결과가 수신될 때까지 호출부의 코루틴을 일시 중단
• 수신한 결과값들을 List로 반환

fun main() = runBlocking<Unit> {
  val startTime = System.currentTimeMillis() // 1. 시작 시간 기록
  val participantDeferred1: Deferred<Array<String>> = async(Dispatchers.IO) { // 2. 플랫폼1에서 등록한 관람객 목록을 가져오는 코루틴
    delay(1000L)
    return@async arrayOf("James","Jason")
  }

  val participantDeferred2: Deferred<Array<String>> = async(Dispatchers.IO) { // 3. 플랫폼2에서 등록한 관람객 목록을 가져오는 코루틴
    delay(1000L)
    return@async arrayOf("Jenny")
  }

	val results: List<Array<String>> = awaitAll(participantDeferred1, participantDeferred2) // 4. 요청이 끝날 때까지 대기

  println("[${getElapsedTime(startTime)}] 참여자 목록: ${listOf(*participants1, *participants2)}") // 6. 지난 시간 기록 및 참여자 목록 병합
}

• 위의 연속된 `await()` 사용과 동일한 처리 순서

 

withContext

withContext로 async-await 대체하기

`withContext()` : async-await 작업 대체

suspend fun <T> withContext(
	context: CoroutineContext,
	block: suspend CoroutineScope.() -> T
): T

• block 람다식을 실행하고, 완료되면 그 결과를 바로 반환
• async-await 쌍을 연속적으로 실행했을 때의 동작과 비슷

withContext 동작 방식

• `async-await` : 새로운 코루틴을 생성해 작업을 처리
  `withContext`: 실행중이던 코루틴을 그대로 유지한 채로 코루틴의 실행 환경만 변경해 작업 처리

fun main() = runBlocking<Unit> {
  println("[${Thread.currentThread().name}] runBlocking 블록 실행")
  withContext(Dispatchers.IO) {
    println("[${Thread.currentThread().name}] withContext 블록 실행")
  }
}
/*
// 결과:
[main @coroutine#1] runBlocking 블록 실행
[DefaultDispatcher-worker-1 @coroutine#1] withContext 블록 실행
*/

실행하는 스레드는 다르지만, 코루틴은 동일 → 기존의 코루틴에서 CoroutineContext 객체만 바꿔서 실행

• 컨텍스트 스위칭: 실행 중인 코루틴의 실행 환경이 context 인자로 변경되어 실행
• block 람다식이 실행되는 동안 코루틴의 실행 환경을 변경 ( 람다식을 벗어나면 원래의 context 사용 )

 

withContext 사용 시 주의점

복수의 독립적인 작업이 병렬로 실행되어야 하는 상황에 성능 문제 유발

• async-await 쌍을 연속적으로 사용했을 때와 동일한 문제
• 하나의 코루틴에서 사용하기 때문에 병렬적으로 실행되지 않고 순차적으로 실행됨

---

http://www.acornpub.co.kr/book/kotlin-coroutines

코틀린 코루틴의 정석

🌟후기🌟

Spring Boot - Kotlin 사용하는 환경에서 코루틴에 대한 더 깊은 지식이 필요해 찾다 발견한 책. 
한국인 저자 분이어서 그런지 전반적으로 이해하기 굉장히 쉽게 되어있고,
기존 코틀린 책에서는 쉽게 다뤄지지 않는 더 딥한 코루틴 기능까지 알 수 있음.
(지금까지 읽은 기술서 중 실무에서 가장 잘 쓰고 있는 책...가장 술술 읽힌 책...👍)
SpringBoot-Kotlin 환경에서 코루틴을 더 공부하고 싶다면 정말 강추 필수 필수 👍🔥👍🔥👍🔥👍🔥👍🔥