2024.10.10
将来は卵1パックの価格が2倍に? 多くの日本人が知らない世界の新潮流、「動物福祉」とは
Kotlin編「並⾏処理・⾮同期処理のアプローチKotlin」(全1記事)
リンクをコピー
記事をブックマーク
狩谷洋平氏(以下、狩谷):よろしくお願いします。「Kotlinの並行処理へのアプローチ」というタイトルで発表します。
最初に簡単な自己紹介です。GO株式会社のIoT開発部で仕事をしている狩谷洋平と申します。2018年4月にサーバーサイドエンジニアとして入社、その後、車載アプリ開発チームへ異動しました。タクシー車両の中で動くAndroidアプリの開発をしています。
狩谷:さて、発表に入ります。最初に「どうして並行処理が必要なの?」という話をしていきます。KotlinといえばAndroidアプリです。
ボタンをタップするとデバイスとの接続状況を確認する機能があるとします。(スライドを示して)スライドの右側にソースコードがあります。button.onClickListenerで、ボタンをタップ時のハンドラを記述できます。
中括弧の中にタップ時の処理が書いてあって、showProgress()で、「診断中」というダイアログを表示します。その後、checkDevices()で実際にデバイスとの接続状況をチェックします。チェックが終わったらhideProgress()でダイアログを消します。そんなソースコードです。
動かすとどうなるでしょうか。注目ポイントとしては、checkDevices()の処理が実際のデバイスと通信をするために時間がかかるというところです。時間がかかるということは、returnされるまで待つことになります。AndroidアプリのようなGUIアプリケーションでは、UIスレッドで時間がかかる処理をすると画面が固まってしまいます。
スライドの吹き出しにあるように、戻るボタンをタップして前画面に戻りたくても、画面が固まってしまっていて、タップしても反応してくれません。これは困ります。そこで、待ち時間に別の処理を実行できる必要があります。つまり、並行処理が必要になります。
狩谷:次に「どうやって並行処理をするの?」という話に移ります。KotlinではCoroutineというものを使って並行処理を実現します。launchというブロックでCoroutineを生成して、Coroutineでブロック内に記述した処理を順次実行します。
(スライド)右側のソースコードは先ほどのものとほぼ同様ですが、checkDevices()とhideProgress()がlaunchブロックで囲まれているところが違います。こうすることで「待ち」が発生したCoroutine以外の処理を実行することができます。checkDevices()によって「待ち」が発生することには変わりませんが、別のCoroutineが動けるので、先ほどと異なり画面が固まっておらず、戻るボタンをタップするとちゃんと反応してくれます。
Coroutineについて、もう少し深掘りしていきます。
狩谷:CoroutineはOSが提供するスレッドではありません。CoroutineはただのKotlinのオブジェクトになります。1つのスレッドで複数のCoroutineに切り替えて実行できます。ただ、Kotlinはシングルスレッドで動いているというわけではなく、複数のスレッドを使って動きます。
Coroutineとスレッドの関係を見ていきましょう。Kotlinランタイムが複数のCoroutineから、次に実行するCoroutineを選んでくれます。さらに、用途別のスレッドのまとまりが用意されています。
(スライド)図の右下にあるようなイメージです。UIスレッドやI/Oで使うスレッドのまとまりなどが用意されています。Kotlinランタイムは複数あるスレッドの中から1つのスレッドを選び出し、Coroutineをスレッドに割り当てて実行してくれます。
プログラマーは用途別のスレッドのまとまりを指定するだけです。スレッドの状態を管理する必要はなく、スレッド一つひとつまで意識しなくてもいいです。ソースコード例のようにlaunch時にパラメーターでDispatchersというものを使って、スレッドのまとまりを指定することができます。
並行処理をするためにCoroutineの数がスレッドより多い場合は、スレッドに対して割り込む必要があります。例えば、UIスレッドは1つしかないので、割り込まないと並行処理ができません。Go言語などでは実行系が強制的に割り込みますが、Kotlinでは中断を明示的に宣言したタイミングでしか割り込みません。
KotlinのCoroutineにおいて、中断とはsuspendというキーワードを付与したメソッドを呼び出したタイミングです。Kotlinではfunというキーワードでメソッドを定義します。funの前にsuspendというキーワードを付加できます。
ソースコードの例がありますが、bというメソッドにsuspendキーワードが付いています。Kotlinコンパイラは、Coroutineで実行したい処理を中断できる処理に変換します。
変換がどういうものかというイメージの話になりますが、launchブロック内に、a、b、cと順次メソッドを呼び出しているソースコードがあるとします。(スライドを示して)この時コンパイラは右側のコードのような処理に変換します。ここの例では、launchブロック全体がinvokeというメソッドになっています。
when式でthis.stateを参照し、その値に応じて処理を分岐します。Coroutineが初めて実行された場合、つまりinvokeが初めて呼ばれた場合、this.stateの値は0になっています。suspend funであるbの呼び出し箇所まで処理が進むと、stateを1にしてからbを呼び出し、returnします。
次にCoroutineが再開された時、つまりもう一度invokeが呼ばれた場合は、stateが1になっているため、分岐によって残りの処理、cメソッドの呼び出しだけが実行されるというわけです。
このように中断と再開をします。Coroutineはsuspend funを呼び出したタイミングで中断します。suspendというキーワードが中断の目印になり、Coroutineを切り替えることができるようになります。
狩谷:次に、KotlinのCoroutineは構造化できるという話をします。Coroutineは親子関係を持つことができます。launchブロックの中で、さらにlaunchすると、親子関係を持ちます。内側で生成されたCoroutineが子どもです。
今まで省略してきましたが、実はlaunchはCoroutineScopeというクラスのメソッドになっています。
ソースコードを見ると、coroutineScope.という記述が増えています。CoroutineScopeオブジェクトと外側のlaunchで作られたCoroutineには、直接関係があることがわかります。
内側のlaunchがどうなっているかというと、thisというキーワードでCoroutineScopeを参照できるようになっています。
Kotlinではthisは省略可能なキーワードなので、外側のlaunchのCoroutineのCoroutineScopeを参照する場合はthisを書いても書かなくても同じ意味になります。
新たに登場したCoroutineScopeですが、CoroutineScopeを使って、親子関係を持つ複数のCoroutineを管理することができます。
管理とは、例えばどれか1つのCoroutineで例外が発生した場合の対応方法があります。
すべてのCoroutineがキャンセルされるようにするというようなことができます。
このように、CoroutineScopeで複数のCoroutineを管理できる仕組みを、Kotlinでは「Structured concurrency」と呼んでいます。Coroutineが実行しっぱなしになることを防ぐことができます。
狩谷:CoroutineScopeの例ですが、Androidアプリ開発では、標準ライブラリから提供されるCoroutineScopeを利用することができます。例えば、表示中の画面に紐づくCoroutineScopeが用意されています。
(スライドを示して)右側のコード例でいうと、viewLifecycleOwner.lifecycleScopeというオブジェクトが、提供されているCoroutineScopeになります。
「画面表示中はナビゲーションを更新し続ける」というような処理があるとします。スクリーンショットでいうと、緑色の線でルート案内が表示がされていて、これを車両の現在地によって書き換えていきます。launchブロックで囲まれている処理はCoroutineで実行されます。whileループでtrueの間はisActiveがナビゲーションを更新し続けてくれるソースコードです。
isActiveでCoroutineがキャンセルされたかどうかを判定します。別画面に切り替わるとCoroutineScopeが終了して、管理下にあるCoroutineがすべてキャンセルされます。
このようにして「画面遷移後に不要になるCoroutineが動きっぱなしになってしまう」ことを簡単に防ぐことができます。
狩谷:まとめです。Kotlinがスレッドに割り当てるCoroutineの切り替えをやってくれます。プログラマーは、Coroutineを程よく制御できる機能を使うことができます。「Coroutineに割り当ててほしいスレッドのまとまりを指定する」とか、「Coroutineを構造化してキャンセルの取り扱い方を決める」などです。
また、スライドでは触れなかったですが、asyncやflowなどといったコードの「書きやすさ/読みやすさ」を上げるAPIが用意されています。
感想になりますが、これらの特徴がAndroidアプリを実装しやすくすることにつながっているな、と感じています。
以上で発表を終わります。ありがとうございました。
司会者:狩谷さん、ありがとうございました。終了時刻が押していますが、狩谷さんへの質問が終わり次第クロージングに移っていくので、みなさま最後までお付き合いいただけるとうれしいです。ということで狩谷さん、1個質問に答えてもらえると。
狩谷:そうですね。「Coroutine内に書いた処理はいつまで継続されるのでしょうか。アクティビティがさらに切り替わったり、アプリが終了されても継続されるのでしょうか」。
先ほどの例にあったisActiveというものをチェックしていると、画面が切り替わるとCoroutineScopeが終了するので、それに引きずられるかたちでCoroutineScopeにぶら下がっているCoroutineたちも終了します。なのでアクティビティが切り替わる、画面が変わるタイミングでCoroutineも止まります。
司会者:ありがとうございます。2つ目もいきますか。
狩谷:「他の言語では見られなかった構文がいろいろありましたが、これらはAndroidアプリ開発が念頭にあって設計された言語だからでしょうか」。
そうですね。構文が多いですね。GoのチャネルみたいなものもKotlinには用意されていたりして、同じ仕組みでだいたい機能として実現することはできるのですが、より簡単に使えるようにするAPIがけっこう用意されています。文法レベルでいうと、最初のsuspendだけであって、あとはライブラリから提供されているAPIがたくさん揃っているという感じのイメージですね。
個人的な印象では、Androidアプリを楽にするために、そういったAPIがどんどん追加されているんじゃないかなと感じています。
司会者:狩谷さん、ありがとうございました。
関連タグ:
2024.11.13
週3日働いて年収2,000万稼ぐ元印刷屋のおじさん 好きなことだけして楽に稼ぐ3つのパターン
2024.11.11
自分の「本質的な才能」が見つかる一番簡単な質問 他者から「すごい」と思われても意外と気づかないのが才能
2024.11.13
“退職者が出た時の会社の対応”を従業員は見ている 離職防止策の前に見つめ直したい、部下との向き合い方
2024.11.12
自分の人生にプラスに働く「イライラ」は才能 自分の強みや才能につながる“良いイライラ”を見分けるポイント
2023.03.21
民間宇宙開発で高まる「飛行機とロケットの衝突」の危機...どうやって回避する?
2024.11.11
気づいたら借金、倒産して身ぐるみを剥がされる経営者 起業に「立派な動機」を求められる恐ろしさ
2024.11.11
「退職代行」を使われた管理職の本音と葛藤 メディアで話題、利用者が右肩上がり…企業が置かれている現状とは
2024.11.18
20名の会社でGoogleの採用を真似するのはもったいない 人手不足の時代における「脱能力主義」のヒント
2024.11.12
先週まで元気だったのに、突然辞める「びっくり退職」 退職代行サービスの影響も?上司と部下の“すれ違い”が起きる原因
2024.11.14
よってたかってハイリスクのビジネスモデルに仕立て上げるステークホルダー 「社会的理由」が求められる時代の起業戦略