Coroutine コンテキストでは、そのコードをどのスレッドで実行するか、exception がスローされたときの処理の方法、キャンセルを伝える親のコンテキストを定義します。
val job = Job()
val exceptionHandler = CoroutineExceptionHandler {
coroutineContext, throwable -> whatever(throwable)
}
launch(CommonPool+exceptionHandler, parent = job) { ... }
job.cancel() は、それの保持しているすべての coroutine をキャンセルします。
そして exceptionHandler は、それらの中でスローされたすべて Exception を受け取ります。
【Android】Kotlin でモダンな concurrency その1
【Android】Kotlin でモダンな concurrency その2
Dispatch は coroutine のキーとなる概念で、スレッド間を移動するアクションとなります。
現在の Java でいう runOnUiThread と等価です。
public final void runOnUiThread(Runnable action) {
if (Thread.currentThread() != mUiThread) {
mHandler.post(action);
} else {
action.run();
}
}
Kotlin Android でのUIコンテキストは、Handlerをベースとして dispatcher が実装されています、
以下のように使います。
launch(UI) { ... }
launch(UI, CoroutineStart.UNDISPATCHED) { ... }
launch(UI) では、Handler 内の Runnable に postされますので直接実行されません。
それに対して、launch(UI, CoroutineStart.UNDISPATCHED) は、そのスレッドですぐにラムダ部分を実行します。
UI は、メインスレッドが resume されたとき、coroutine がそれに対して dispatch されるのを保証しており、 メインルーパーに post するというネイティブAndroidの Handler が使われています。
val UI = HandlerContext(Handler(Looper.getMainLooper()), "UI")
現在の Java/Android の concurrency フレームワークはコールバック地獄の原因となります。
それは、スレッドセーフを保証するシンプルな方法がないからです。
kotlin coroutine は、concurrency を管理するための効果的でシンプルなフレームワークです。
coroutine は、スレッドを置き換えるものではなく、それを管理するフレームワークのようなものです。
元のスレッドをブロックすることなく、バックグラウンド処理完了に対しての wait を可能にする実行コンテキストを定義しています。
コールバックを避けて、簡単に concurrency を行ってみましょう。
最初は非常にシンプルな例です。UIコンテキストで coroutine を起動し、その中でIOコンテキストでイメージを取得します。
その後、UIコンテキストに戻ります。
launch(UI) {
val image = withContext(IO) { getImage() }
imageView.setImageBitmap(image)
}
シングルスレッドのように直感的なコードです。
getImage() がIOスレッドで実行されている間、メインスレッドは、自由に他の処理を行うことができます。
withContext は、その coroutine を getImage() が実行されている間は中断します。
getImage() のあとすぐに、メインlooperが利用可能になり、coroutine はメインスレッドを再開します。
そして imageView.setImageBitmap(image) が呼ばれます。
次の例は、2つのバックグラウンド処理を完了させ、その結果を利用する、というものです。
async/await を使ってパラレルに実行し、それら両方の結果取得のあとメインスレッドでそれを利用した処理を行います。
val job = launch(UI) {
val deferred1 = async { getFirstValue() }
val deferred2 = async(IO) { getSecondValue() }
useValues(deferred1.await(), deferred2.await())
}
job.join()
async は launch に似ていますが、deferred (Kotlin版 Future) を返します。
そして、await() で結果を取得します。パラメータなしで実行した場合は、CommonPool コンテキストで実行されます。
前の例と同様に、2つの結果を待っている間は、メインスレッドは自由に処理を行うことができます。
例にあるように、launch は処理が完了するのを待つのに利用できる Job を返します。
「スレッドをブロックせず coroutine をブロックする」ということを除けば、他の言語と同様です。