Exception 전파

• 코루틴 빌더는 자동으로 예외를 전파하거나 사용자에게 예외를 노출함.
  • 자동으로 예외가 전파되는 코루틴 빌더 : launch , actor
  • 사용자에게 예외를 노출하는 코루틴 빌더 : async , produce
• 다른 코루틴의 자식이 아닌 root 코루틴을 코루틴 빌더로 만들 때
  • launch , actor 는 uncaughtExceptionHandler와 비슷하게 잡히지 않은 예외로 다룸.
  • async , produce 는 await 이나 receive 를 통해 사용자가 마지막 예외를 소비하는지에 의존.

import kotlinx.coroutines.*

@OptIn(DelicateCoroutinesApi::class)
fun main() = runBlocking {
		// 이 부분에서 GlobalScope를 빼면 예외가 전파되어 print를 호출하고 종료됨.
    val job = GlobalScope.launch { 
        println("Throwing exception from launch")
        throw IndexOutOfBoundsException()
    }
    job.join()
    println("joined failed job")
    val deferred = GlobalScope.async {
        println("Throwing exception from async")
        throw ArithmeticException()
    }
    try {
        deferred.await()
        println("Unreached")
    } catch (e: ArithmeticException) {
        println("Caught ArithmeticException")
    }
}

실행결과
Throwing exception from launch
Exception in thread "DefaultDispatcher-worker-1" java.lang.IndexOutOfBoundsException
	at MainKt$main$1$job$1.invokeSuspend(Main.kt:7)
	at kotlin.coroutines.jvm.internal.BaseContinuationImpl.resumeWith(ContinuationImpl.kt:33)
	at kotlinx.coroutines.DispatchedTask.run(DispatchedTask.kt:108)
	at kotlinx.coroutines.scheduling.CoroutineScheduler.runSafely(CoroutineScheduler.kt:584)
	at kotlinx.coroutines.scheduling.CoroutineScheduler$Worker.executeTask(CoroutineScheduler.kt:793)
	at kotlinx.coroutines.scheduling.CoroutineScheduler$Worker.runWorker(CoroutineScheduler.kt:697)
	at kotlinx.coroutines.scheduling.CoroutineScheduler$Worker.run(CoroutineScheduler.kt:684)
	Suppressed: kotlinx.coroutines.internal.DiagnosticCoroutineContextException: [StandaloneCoroutine{Cancelling}@5428648a, Dispatchers.Default]
joined failed job
Throwing exception from async
Caught ArithmeticException

• launch 는 잡히지 않은 예외로 다룸.
  • 예외를 처리하는 코드가 없어 실제로 처리되지 않고, 잡히지 않은 예외가 발생하면 대부분의 환경은 프로그램이 강제 종료됨.
• runBlocking 코루틴 안에서 GlobalScope.launch를 사용함.
  • 기본적으로는 부모 코루틴에 의해 예외가 처리되지만 위 예제는 조금 다름.
  • 코루틴 안에서 스코프를 명시적으로 사용했음.
    • 즉, 계층관계가 재정의 됨. → 다른 코루틴과 독립적으로 실행
      • 코루틴의 자식들

CoroutineExceptionHandler 사용해 전파된 예외 처리하기

• 잡히지 않은 예외를 콘솔에 출력하도록 기본 동작을 커스텀 할 수 있음.

• root 코루틴의 CoroutineContext인 CoroutineExceptionHandler 이 있음.

  • 이는 root 코루틴과 모든 자식 코루틴들에 대해 커스텀한 예외가 필요한 경우 catch 블록으로 사용됨.
  • 예외를 복구하지 못함.
    • 코루틴은 Handler가 호출되었을 때, 이미 해당 예외처리를 완료함.
  • 오류를 로깅하거나, 에러 메세지를 보여주거나 애플리케이션을 종료하거나 다시 시작하기 위해 사용됨.
  • 잡히지 않은 예외에 대해서만 실행됨.
    • 모든 자식 코루틴들(다른 Job의 Context로 만들어진 코루틴 포함)은 예외처리를 부모 코루틴에 위임함.
      • 그 부모 또한 부모에게 위임해서 루트 코루틴까지 올라감.
      • 따라서 그들의 CoroutineContext에 추가된 CoroutineExceptionHandler는 사용되지 않음.

  async 코루틴 빌더는 모든 예외를 잡아 Deferred 객체에 나타내므로
  CoroutineExceptionHandler가 아무런 효과가 없음.
  

  import kotlinx.coroutines.*
  
  val handler = CoroutineExceptionHandler { _, exception ->
      println("CoroutineExceptionHandler got $exception")
  }
  
  fun main() = runBlocking<Unit> {
      val job = GlobalScope.launch(handler) { // root coroutine, running in GlobalScope
          throw AssertionError()
      }
      val deferred = GlobalScope.async(handler) { // also root, but async instead of launch
          throw ArithmeticException() // Nothing will be printed, relying on user to call deferred.await()
      }
      joinAll(job, deferred)
  }
  
  실행결괴
  CoroutineExceptionHandler got java.lang.AssertionError
  

  https://myungpyo.medium.com/코루틴-공식-가이드-자세히-읽기-part-6-dd7796150ff3

  • 궁금한 부분 코멘트 남김.

Cancellation과 Exceptions

• 취소는 예외와 밀접하게 연관되어 있음.
• 코루틴은 내부적으로 취소를 위해 CancellationException을 사용함.
  • 이는 모든 Handler에서 무시됨.
  • catch 를 사용하여 추가적인 디버깅 정보를 위해서만 사용해야함.
• 코루틴이 Job.cancel()을 사용해 취소될 경우 종료되지만, 부모 코루틴의 실행을 취소하진 않음.

import kotlinx.coroutines.*

fun main() = runBlocking<Unit> {
    val job = launch {
        val child = launch {
            try {
                delay(Long.MAX_VALUE)
            } finally {
                println("Child is cancelled")
            }
        }
        yield()
        println("Cancelling child")
        child.cancel()
        child.join()
        yield()
        println("Parent is not cancelled")
    }
    job.join()
}

실행결과
Cancelling child
Child is cancelled
Parent is not cancelled

• 코루틴은 CancellationException를 제외한 다른 예외들을 만난다면 부모 코루틴까지 취소됨.
  • 부모 코루틴이 취소되면서 자식 코루틴까지 예외가 전파됨.
• 구조화된 동시성을 위해 안정적인 코루틴 계층구조를 제공하기 위해 위 동작은 재정의 할 수 없음.
• CoroutineExceptionHandler의 구현식은 자식 코루틴들을 위해 사용되지 않음

Exceptions 합치기

• 부모 코루틴 복수의 자식들이 예외와 함께 실행에 실패한다면 일반적인 규칙은 첫 번째 예외가 이김.
  • 즉, 첫 번째 예외만 처리됨.
• 첫 예외 이후 생긴 모두 추가적인 예외들은 첫번째 예외에 suppressed로 붙여짐.