Kenji - Part 19

Kotlin 1.3 で使えるようになるコルーチンでの例外の扱いについてドキュメントを読んでまとめました。

ここでは例外処理と例外発生時のキャンセル処理について記述しています。キャンセルされたコルーチンは CancellationException を停止位置でスローします。そして、コルーチンの機構によりそれは無視されます。しかし、例外がキャンセルされたり、同じコルーチンの複数の子が例外をスローした場合はどうなるでしょうか。

検証環境

OpenJDK 10.0.2
Kotlin 1.3.0-rc-146
org.jetbrains.kotlinx:kotlinx-coroutines-core:0.30.2

例外の伝播

コルーチンビルダには2つの種類があります。例外を自動的に伝播するもの (launch, actor) とユーザに例外処理を委ねるもの (async, produce)。前者は Java の Thread.uncaughtExceptionHandler のように、例外を未処理のものとして扱います。後者はユーザが最終的な例外をどのように処理するかに依存しており、例えば await, receive があります。

GlobalScope を使った単純な例で実験してみます。

fun main(args: Array<String>) = runBlocking {
val job = GlobalScope.launch {
println("Throwing exception from launch")
throw IndexOutOfBoundsException()
// Will be printed to the console by Thread.defaultUncaughtExceptionHandler
}
job.join()
println("Joined failed job")
val deferred = GlobalScope.async {
println("Throwing exception from async")
throw ArithmeticException()
// Nothing is printed, relying on user to call await
}
try {
deferred.await()
println("Unreached")
} catch (e: ArithmeticException) {
println("Caught ArithmeticException")
}
}

fun main(args: Array<String>) = runBlocking {

val job = GlobalScope.launch {

println("Throwing exception from launch")

throw IndexOutOfBoundsException()

// Will be printed to the console by Thread.defaultUncaughtExceptionHandler

}

job.join()

println("Joined failed job")

val deferred = GlobalScope.async {

println("Throwing exception from async")

throw ArithmeticException()

// Nothing is printed, relying on user to call await

}

try {

deferred.await()

println("Unreached")

} catch (e: ArithmeticException) {

println("Caught ArithmeticException")

}

出力は次のようになります。

Throwing exception from launch
Exception in thread "DefaultDispatcher-worker-1 @coroutine#2" java.lang.IndexOutOfBoundsException
at com.improve_future.kotlincoroutine.MainKt$main$1$job$1.invokeSuspend(Main.kt:44)
at com.improve_future.kotlincoroutine.MainKt$main$1$job$1.invoke(Main.kt)
at kotlin.coroutines.experimental.migration.ExperimentalSuspendFunction1Migration.invoke(CoroutinesMigration.kt:134)
at kotlin.coroutines.experimental.migration.ExperimentalSuspendFunction1Migration.invoke(CoroutinesMigration.kt:130)
at kotlin.coroutines.experimental.intrinsics.IntrinsicsKt__IntrinsicsJvmKt$createCoroutineUnchecked$$inlined$buildContinuationByInvokeCall$IntrinsicsKt__IntrinsicsJvmKt$2.resume(IntrinsicsJvm.kt:122)
at kotlin.coroutines.experimental.intrinsics.IntrinsicsKt__IntrinsicsJvmKt$createCoroutineUnchecked$$inlined$buildContinuationByInvokeCall$IntrinsicsKt__IntrinsicsJvmKt$2.resume(IntrinsicsJvm.kt:98)
at kotlinx.coroutines.experimental.DispatchedTask$DefaultImpls.run(Dispatched.kt:168)
at kotlinx.coroutines.experimental.DispatchedContinuation.run(Dispatched.kt:13)
at kotlinx.coroutines.experimental.scheduling.Task.run(Tasks.kt:94)
at kotlinx.coroutines.experimental.scheduling.CoroutineScheduler.runSafely(CoroutineScheduler.kt:583)
at kotlinx.coroutines.experimental.scheduling.CoroutineScheduler.access$runSafely(CoroutineScheduler.kt:60)
at kotlinx.coroutines.experimental.scheduling.CoroutineScheduler$Worker.run(CoroutineScheduler.kt:729)
Joined failed job
Throwing exception from async
Caught ArithmeticException

Throwing exception from launch

Exception in thread "DefaultDispatcher-worker-1 @coroutine#2" java.lang.IndexOutOfBoundsException

at com.improve_future.kotlincoroutine.MainKt$main$1$job$1.invokeSuspend(Main.kt:44)

at com.improve_future.kotlincoroutine.MainKt$main$1$job$1.invoke(Main.kt)

at kotlin.coroutines.experimental.migration.ExperimentalSuspendFunction1Migration.invoke(CoroutinesMigration.kt:134)

at kotlin.coroutines.experimental.migration.ExperimentalSuspendFunction1Migration.invoke(CoroutinesMigration.kt:130)

at kotlin.coroutines.experimental.intrinsics.IntrinsicsKt__IntrinsicsJvmKt$createCoroutineUnchecked$$inlined$buildContinuationByInvokeCall$IntrinsicsKt__IntrinsicsJvmKt$2.resume(IntrinsicsJvm.kt:122)

at kotlin.coroutines.experimental.intrinsics.IntrinsicsKt__IntrinsicsJvmKt$createCoroutineUnchecked$$inlined$buildContinuationByInvokeCall$IntrinsicsKt__IntrinsicsJvmKt$2.resume(IntrinsicsJvm.kt:98)

at kotlinx.coroutines.experimental.DispatchedTask$DefaultImpls.run(Dispatched.kt:168)

at kotlinx.coroutines.experimental.DispatchedContinuation.run(Dispatched.kt:13)

at kotlinx.coroutines.experimental.scheduling.Task.run(Tasks.kt:94)

at kotlinx.coroutines.experimental.scheduling.CoroutineScheduler.runSafely(CoroutineScheduler.kt:583)

at kotlinx.coroutines.experimental.scheduling.CoroutineScheduler.access$runSafely(CoroutineScheduler.kt:60)

at kotlinx.coroutines.experimental.scheduling.CoroutineScheduler$Worker.run(CoroutineScheduler.kt:729)

Joined failed job

Throwing exception from async

Caught ArithmeticException

launch はその場で例外が発生しており、 await は処理実行時に例外を発生させています。

CoroutineExceptionHandler

もしユーザが例外の全てをコンソールに表示したくない場合はどうでしょうか。 CoroutineExceptionHandler コンテキストが、コルーチンの一般的な catch ブロックに使用することができ、独自のログ出力や例外処理を行う際に使用できます。これは Thread.uncaughtExceptionHandler に似ています。

JVM では ServiceLoader を経由して CoroutineExceptionHander を登録することで、全てのコルーチンに対してグローバル例外ハンドラを再定義することができます。グローバル例外ハンドラは、他に特別なハンドラが登録されていない場合の Thread.defaultUncaughtExceptionHandler に似ています。 Android では uncaughtExceptionPreHandler がグローバルコルーチン例外ハンドラとして登録されています。

CoroutineExceptionHandler はユーザが予期していなかった例外が発生した場合にのみ実行されます。そのため async のビルダなどに登録しても効果がありません。

fun main(args: Array<String>) = runBlocking {
val handler = CoroutineExceptionHandler { _, exception -> 
println("Caught $exception") 
}
val job = GlobalScope.launch(handler) {
throw AssertionError()
}
val deferred = GlobalScope.async(handler) {
throw ArithmeticException() // Nothing will be printed, relying on user to call deferred.await()
}
joinAll(job, deferred)
}

fun main(args: Array<String>) = runBlocking {

val handler = CoroutineExceptionHandler { _, exception ->

println("Caught $exception")

}

val job = GlobalScope.launch(handler) {

throw AssertionError()

}

val deferred = GlobalScope.async(handler) {

throw ArithmeticException() // Nothing will be printed, relying on user to call deferred.await()

}

joinAll(job, deferred)

}

このコードのアウトプットは次のようになります。

Caught java.lang.AssertionError

1	Caught java.lang.AssertionError

launch でも、 async でも CoroutineExceptionHandler を使っていますが、 async の方では意味をなしていません。コードが実行されていないためです。

次のようにコードを変えてみます。

fun main(args: Array<String>) = runBlocking {
val handler = CoroutineExceptionHandler { _, exception ->
println("Caught $exception")
}
val job = GlobalScope.launch(handler) {
throw AssertionError()
}
val deferred = GlobalScope.async(handler) {
throw ArithmeticException() // Nothing will be printed, relying on user to call deferred.await()
}
joinAll(job, deferred)
deferred.await()
delay(1000L)
}

fun main(args: Array<String>) = runBlocking {

val handler = CoroutineExceptionHandler { _, exception ->

println("Caught $exception")

}

val job = GlobalScope.launch(handler) {

throw AssertionError()

}

val deferred = GlobalScope.async(handler) {

throw ArithmeticException() // Nothing will be printed, relying on user to call deferred.await()

}

joinAll(job, deferred)

deferred.await()

delay(1000L)

}

出力が変わってきます。

Caught java.lang.AssertionError
Exception in thread "main" java.lang.ArithmeticException
at com.improve_future.kotlincoroutine.MainKt$main$1$deferred$1.invokeSuspend(Main.kt:48)
at com.improve_future.kotlincoroutine.MainKt$main$1$deferred$1.invoke(Main.kt)
at kotlin.coroutines.experimental.migration.ExperimentalSuspendFunction1Migration.invoke(CoroutinesMigration.kt:134)
at kotlin.coroutines.experimental.migration.ExperimentalSuspendFunction1Migration.invoke(CoroutinesMigration.kt:130)
at kotlin.coroutines.experimental.intrinsics.IntrinsicsKt__IntrinsicsJvmKt$createCoroutineUnchecked$$inlined$buildContinuationByInvokeCall$IntrinsicsKt__IntrinsicsJvmKt$2.resume(IntrinsicsJvm.kt:122)
at kotlin.coroutines.experimental.intrinsics.IntrinsicsKt__IntrinsicsJvmKt$createCoroutineUnchecked$$inlined$buildContinuationByInvokeCall$IntrinsicsKt__IntrinsicsJvmKt$2.resume(IntrinsicsJvm.kt:98)
at kotlinx.coroutines.experimental.DispatchedTask$DefaultImpls.run(Dispatched.kt:168)
at kotlinx.coroutines.experimental.DispatchedContinuation.run(Dispatched.kt:13)
at kotlinx.coroutines.experimental.scheduling.Task.run(Tasks.kt:94)
at kotlinx.coroutines.experimental.scheduling.CoroutineScheduler.runSafely(CoroutineScheduler.kt:583)
at kotlinx.coroutines.experimental.scheduling.CoroutineScheduler.access$runSafely(CoroutineScheduler.kt:60)
at kotlinx.coroutines.experimental.scheduling.CoroutineScheduler$Worker.run(CoroutineScheduler.kt:729)

Caught java.lang.AssertionError

Exception in thread "main" java.lang.ArithmeticException

at com.improve_future.kotlincoroutine.MainKt$main$1$deferred$1.invokeSuspend(Main.kt:48)

at com.improve_future.kotlincoroutine.MainKt$main$1$deferred$1.invoke(Main.kt)