fun main(): Unit = runBlocking {
launch {
launch {
delay(1000)
throw Error("Some error")
}
launch {
delay(2000)
println("Will not be printed")
}
launch {
delay(500)
println("Will be printed")
}
}
}
fun main(): Unit = runBlocking {
// 아래 try-catch 는 무시됨
try {
launch {
delay(1000)
throw Error("Some error")
}
} catch (e: Throwable) {
println("Will not be printed")
}
launch {
delay(2000)
println("Will not be printed")
}
}
// 결과는 아무것도 출력되지 않고 그냥 Exception
SupervisorJob 으로 사용하면, 자식에서 발생한 모든 예외를 무시할 수 있음 (p. 116 그림)fun main(): Unit = runBlocking {
val scope = CoroutineScope(SupervisorJob())
scope.launch {
delay(1000)
throw Error("Some error")
}
scope.launch {
delay(2000)
println("Will be printed")
}
delay(3000)
}
실수 주의: 자식 코루틴 하나가 있고, 부모 코루틴이 없는 잡은 일반 잡과 동일하게 동작함 (1)
fun main(): Unit = runBlocking { launch(SupervisorJob()) { // 1 launch { delay(1000) throw Error("Some error") } launch { delay(2000) println("Will not be printed") } } delay(3000) }
fun main(): Unit = runBlocking {
val job = SupervisorJob()
launch(job) {
delay(1000)
throw Error("Some error")
}
launch(job) {
delay(2000)
println("Will be printed")
}
job.join()
}
위 아래 코드의 차이가 뭔가요?
- 코루틴 취소의 전파 여부:
- 첫 번째 코드에서는 내부
launch블록에서 발생한 에러로 인해 동일한 상위launch블록 내의 다른 코루틴들도 취소됩니다. 따라서 두 번째launch블록의 출력이 발생하지 않습니다.- 두 번째 코드에서는
SupervisorJob이 두launch블록에 공유되기 때문에, 첫 번째launch에서 예외가 발생하더라도 두 번째launch에는 영향을 미치지 않습니다. 따라서 두 번째launch블록에서 메시지가 출력됩니다.
fun main(): Unit = runBlocking {
supervisorScope {
launch {
delay(1000)
throw Error("Some error")
}
launch {
delay(2000)
println("Will be printed")
}
}
delay(1000)
println("Done")
}
supervisorScope 로 코루틴 빌더를 래핑할 경우 다른 코루틴에서 발생한 예외를 무시하고 부모와의 연결을 유지함supervisorScope는 중단 함 수 일뿐이며, 중단 함수 본체를 래핑하는데 사용된다.supervisorScope를 사용하는 일반적인 방법은 서로 무관한 다수의 작업을 스코프 내에서 실행하는 것suspend fun notifyAnalytics(actions: List<UserAction>) = supervisorScope {
actions.forEach { action ->
launch {
notifyAnalytics(action) // ?
}
}
}
supervisorScope 는 withContext(SupervisorJob()) 으로 대체될 수 없다는 점에 주의suspend fun sendNotifications(notifications: List<Notification>) = withContext(SupervisorJob()) {
for (notification in notifications) {
launch {
client.send(notification)
}
}
}
SupervisorJob이 withContext 의 부모가 된다.withContext 로 전달이되며, Job 이 취소되고 다른 자식 코루틴까지 취소된 다음 예외가 던져진다.async 코루틴 빌더는 launch 처럼 부모 코루틴을 종료하고, 부모와 관련있는 다른 코루틴 빌더도 종료시킨다.class MyException: Throwable()
suspend fun main() = supervisorScope {
val str1 = async<String> {
delay(1000)
throw MyException()
}
val str2 = async {
delay(2000)
"Text2"
}
try {
println(str1.await())
} catch (e: MyException) {
println(e)
}
println(str2.await())
}
// MyException
// Text2
supervisorScope 안에서 실행되었기 때문에 str2 는 중단되지 않고, 끝까지 실행됨CancellationException 을 상속받은 서브 클래스라면 예외가 부모로 전파되지 않는다.
CancellationException 은 open class 기때문에 다른 클래스나 객체로 확장될 수 있음object MyNonPropagatingException: CancellationException()
suspend fun main(): Unit = coroutineScope {
launch { // 1
launch { // 2
delay(2000)
println("Will not be printed")
}
throw MyNonPropagatingException // 3
}
launch { // 4
delay(2000)
println("Will be printed")
}
}
// 2초 후 Will be printed
CancellationException 하위 클래스인 MyNonPropagatingException 터짐launch 에서 잡힘
launch 는 영향을 받지않고, 문구를 출력함CoroutineExceptionHandler 컨텍스트를 사용하면 예외를 처리하는 기본 행동을 정의할 수 있음fun main(): Unit = runBlocking {
val handler = CoroutineExceptionHandler { ctx, exception ->
println("Caught $exception")
}
val scope = CoroutineScope(SupervisorJob() + handler)
scope.launch {
delay(1000)
throw Error("Some Error")
}
scope.launch {
delay(2000)
println("Will be printed")
}
}
// 에러 로그와 "Will be printed" 모두 출력