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 を使った単純な例で実験してみます。
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 |
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") } } |
出力は次のようになります。
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 |
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 のビルダなどに登録しても効果がありません。
|
1 2 3 4 5 6 7 8 9 10 11 12 |
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) } |
このコードのアウトプットは次のようになります。
|
1 |
Caught java.lang.AssertionError |
launch でも、 async でも CoroutineExceptionHandler を使っていますが、 async の方では意味をなしていません。 コードが実行されていないためです。
次のようにコードを変えてみます。
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 |
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) } |
出力が変わってきます。
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 |
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) |
出力は変わったものの、 async で登録した CoroutineExceptionHandler は実行されていません。
async の中で launch を実行しても、 スタックトレースは変わるものの、同じ結果になります。
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 |
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) { launch(handler) { throw ArithmeticException() // Nothing will be printed, relying on user to call deferred.await() } } joinAll(job, deferred) deferred.await() delay(1000L) } |
Kotlin 1.3: コルーチンでの例外の扱い方 (2/2) に続きます。