Coroutine Context와 Dispatcher 3편 - Thread 전환 하기, Context 내부의 Job, Coroutine의 자식들

Context 내부의 Job

Coroutines의 Job은 Context의 구성요소이고, coroutineContext[Job]*1 표현식으로부터 가져올 수 있다. 

fun main() = runBlocking<Unit> {
    println("My job is ${coroutineContext[Job]}")    
}

📌 전체 코드는 이곳에서 확인할 수 있습니다.

디버그 모드에서 출력은 다음과 같다.

My job is "coroutine#1":BlockingCoroutine{Active}@6d311334

CoroutineScope의 isActive는 coroutineContext[Job]?.isActive == true 를 편리하게 사용하기 위한 축약어*2임을 참고하자.

📖 아래 내용은 독자의 이해를 위해 번역자가 추가한 글입니다.

*1. CoroutineContext는 내부 요소들을 Map 형태로 관리한다. Map의 Key값에 Job이 들어가면 CoroutineContext의 Job 구성요소가 추출된다.

public interface Job : CoroutineContext.Element {
    ...
    public companion object Key : CoroutineContext.Key<Job>
    ...
}

*2. CoroutineScope.isActive 확장 함수는 CoroutineScope의 coroutineContext에서 Job 객체를 가져온 다음 Job이 isActive인지 체크하며, 만약 null이라면 true를 리턴한다.

@Suppress("EXTENSION_SHADOWED_BY_MEMBER")
public val CoroutineScope.isActive: Boolean
    get() = coroutineContext[Job]?.isActive ?: true

즉, coroutineScope 내의 CoroutineContext는 하나이며, CoroutineContext 내부에는 CoroutineContext.Key를 상속 받는 Key 값과 해당 Key 값에 대응되는 Value 값으로 구성요소들을 관리한다.  이 구성요소는 Coroutine 현재 실행중인지 판단하는 Job을 포함한다.

이 글은 Coroutines 공식 문서를 번역한 글입니다.

원문 : Coroutine context and dispatchers - Job in the context

원문 최종 수정 :  2022년 6월 27일

Coroutine의 자식들

Coroutine이 다른 Coroutine의 CoroutineScope내에서 실행되면 Context를 CoroutineScope.coroutineContext를 통해 상속 받고 새로운 Coroutine의 Job은 부모 Coroutine의 Job의 자식이 된다. 부모 Coroutine이 취소되면, 자식 Coroutine들 또한 재귀적으로 취소된다.

하지만, 부모-자식 관계는 두가지 방법으로 명시적으로 재정의 될 수 있다.

• Coroutine을 실행할 때 두 개의 다른 Scope이 명시적으로 설정하는 경우(예를 들어, GlobalScope.launch), 부모 Scope으로부터 Job을 상속 받지 않는다.*1
• 새로운 Coroutine을 위해 다른 Job이 Context로 전달되는 경우(아래 예시와 같이) 부모 Scope의 Job을 재정의한다.*2

두 경우 모두 실행된 Coroutine은 실행된 Scope에 묶여있지 않고 독립적으로 동작한다.

// launch a coroutine to process some kind of incoming request
val request = launch {
    // it spawns two other jobs
    launch(Job()) { 
        println("job1: I run in my own Job and execute independently!")
        delay(1000)
        println("job1: I am not affected by cancellation of the request")
    }
    // and the other inherits the parent context
    launch {
        delay(100)
        println("job2: I am a child of the request coroutine")
        delay(1000)
        println("job2: I will not execute this line if my parent request is cancelled")
    }
}
delay(500)
request.cancel() // cancel processing of the request
println("main: Who has survived request cancellation?")
delay(1000) // delay the main thread for a second to see what happens

📌 전체 코드는 이곳에서 확인할 수 있습니다.

코드를 실행한 결과는 다음과 같다.

job1: I run in my own Job and execute independently!
job2: I am a child of the request coroutine
main: Who has survived request cancellation?
job1: I am not affected by cancellation of the request

📖 아래 내용은 독자의 이해를 위해 번역자가 추가한 글입니다.

*1. 아래와 같이 CoroutineScope(Dispatchers.IO) 를 통해 CoroutineScope을 재정의 한다고 해보자. 

fun main() = runBlocking<Unit> {
    CoroutineScope(Dispatchers.IO).launch {
        ...
    }
}

CoroutineScope을 통해 CoroutineContext가 재정의 되면 CoroutineContext는 부모로부터 상속 받지 않게 되어 Job이 없게 된다. 따라서 아래와 같이 context의 Job이 null인 경우 context에 Job을 추가하는 방식으로 CoroutineScope이 만들어진다.

@Suppress("FunctionName")
public fun CoroutineScope(context: CoroutineContext): CoroutineScope =
    ContextScope(if (context[Job] != null) context else context + Job())

이로 인해 부모 Coroutine과는 다른 Job을 가지게 되는 것이다.

*2. CoroutineContext는 구성요소를 Key-Value 값으로 관리한다. 즉, Key인 Job에 대응하는 Value는 하나뿐이다. 따라서 새로운 Job이 CoroutineContext에 설정되면 Key인 Job에 대응되는 Value값은 새로운 Job이 된다.

이 글은 Coroutines 공식 문서를 번역한 글입니다.

원문 : Coroutine context and dispatchers - Children of a coroutine

원문 최종 수정 :  2022년 6월 27일