Upgrade to Pro
— share decks privately, control downloads, hide ads and more …
Speaker Deck
Features
Speaker Deck
PRO
Sign in
Sign up for free
Search
Search
suspending functionの裏側
Search
Keita Kagurazaka
November 09, 2017
Programming
3
450
suspending functionの裏側
第07回Kotlin勉強会@Sansanでの発表資料です。
Keita Kagurazaka
November 09, 2017
Tweet
Share
More Decks by Keita Kagurazaka
See All by Keita Kagurazaka
SELECT FOR UPDATEの話
kkagurazaka
0
410
Mobileアプリのアーキテクチャ設計法
kkagurazaka
2
1.4k
原理から完全理解するDagger Hilt Migration
kkagurazaka
1
1.9k
今後のJetpackでAndroid開発はこう変わる!
kkagurazaka
16
6.2k
外部SDKのViewにマスク処理をする方法と罠
kkagurazaka
0
1k
AWAのフルリニューアルを支えたアーキテクチャ
kkagurazaka
1
900
CQRS Architecture on Android
kkagurazaka
7
3k
coroutinesで非同期ページネーション
kkagurazaka
1
660
async/awaitで快適非同期ライフ
kkagurazaka
4
1.9k
Other Decks in Programming
See All in Programming
CI_CD「健康診断」のススメ。現場でのボトルネック特定から、健康診断を通じた組織的な改善手法
teamlab
PRO
0
180
iOSアプリの信頼性を向上させる取り組み/ios-app-improve-reliability
shino8rayu9
0
150
Чего вы не знали о строках в Python – Василий Рябов, PythoNN
sobolevn
0
160
なぜあの開発者はDevRelに伴走し続けるのか / Why Does That Developer Keep Running Alongside DevRel?
nrslib
3
370
非同期jobをtransaction内で 呼ぶなよ!絶対に呼ぶなよ!
alstrocrack
0
520
いま中途半端なSwift 6対応をするより、Default ActorやApproachable Concurrencyを有効にしてからでいいんじゃない?
yimajo
2
340
dynamic!
moro
9
6.4k
AIエージェント時代における TypeScriptスキーマ駆動開発の新たな役割
bicstone
4
1.5k
uniqueパッケージの内部実装を支えるweak pointerの話
magavel
0
920
クラシルを支える技術と組織
rakutek
0
190
WebエンジニアがSwiftをブラウザで動かすプレイグラウンドを作ってみた
ohmori_yusuke
0
170
開発生産性を上げるための生成AI活用術
starfish719
1
170
Featured
See All Featured
KATA
mclloyd
32
15k
Learning to Love Humans: Emotional Interface Design
aarron
274
40k
Designing Experiences People Love
moore
142
24k
Reflections from 52 weeks, 52 projects
jeffersonlam
352
21k
Music & Morning Musume
bryan
46
6.8k
Being A Developer After 40
akosma
91
590k
The Straight Up "How To Draw Better" Workshop
denniskardys
237
140k
Optimising Largest Contentful Paint
csswizardry
37
3.4k
Thoughts on Productivity
jonyablonski
70
4.9k
jQuery: Nuts, Bolts and Bling
dougneiner
64
7.9k
Cheating the UX When There Is Nothing More to Optimize - PixelPioneers
stephaniewalter
285
14k
The Illustrated Children's Guide to Kubernetes
chrisshort
48
51k
Transcript
suspending functionの裏側 2017/11/9 第7回Kotlin勉強会@Sansan @kkagurazaka
皆さん、coroutines使ってますか?
KotlinConf Keynote Recap
KotlinConf Keynote Recap
None
coroutines じゃんじゃん使っていきましょう
そんなcoroutinesが どうやって実現されているか その裏側をお話します
自己紹介 • Keita Kagurazaka • Android App Developer • Sansan株式会社
2017/4〜 • Kotlin / CQRS / DDD / Splatoon / Github: @k-kagurazaka Twitter: @kkagurazaka
coroutinesとは • 中断・再開可能な計算のインスタンス ◦ Threadクラスのように、作成して実行する launch(UI) { val token =
fetchToken() // Tokenが取得できるまで実行を中断 val item = postItem(token, newItem) // 投稿が完了するまで実行を中断 updateUI(item) }
どのように中断・再開を 実現しているのか?
suspending function
suspending function • 呼び出されるとcoroutinesを中断する(こともできる) • suspending functionはcoroutinesかsuspending functionか らしか呼び出せない •
Java byte codeになる際にCPS transformされる
suspending function • 呼び出されるとcoroutinesを中断する(こともできる) • suspending functionはcoroutinesかsuspending functionか らしか呼び出せない •
Java byte codeになる際にCPS transformされる
Continuation Passing Style (CPS) 戻り値で値を返すのではなく、引数のContinuationインスタンスに 結果を渡すことで値を伝達するスタイル interface Continuation<in T> {
// 成功したことと、その結果を伝達 fun resume(value: T): Unit //失敗したことと、原因の例外を伝達 fun resumeWithException(exception: Throwable): Unit }
CPS transform // Kotlinでの宣言 suspend fun fetchToken(): Token // 変換後のJava
byte codeをKotlinっぽく書いたもの fun fetchToken(continuation: Continuation<Token>): Any? • 中断する場合は COROUTINE_SUSPENDED 定数を返し、 再開するときにContinuationをresumeする • 中断しない場合は結果の T を返す
CPS transform後のイメージ launch(UI) { fetchToken(object : Continuation<Token> { override fun
resume(value: Token) { postItem(value, newItem, object: Continuation<Item> { override fun resume(value: Item) { updateUI(value) } }) } }) } suspending functionの呼び出し以降がContinuationを介した コールバックに変換される
内部的な実装とはいえ コールバックのネストが 深すぎないか?
ステートマシンによる実装 class StateMachine implements Continuation<Object> { int label = 0;
// ステートマシンの状態 Token token; // suspending functionのローカル変数 Item item; // 同上 void resume(Object data) { … } }
void resume(Object data) { switch(label) { case 0: label =
1; data = fetchToken(this); // CPS変換後なのでContinuation=thisを渡す if (data == COROUTINE_SUSPENDED) break; // 中断が発生した場合は抜ける case 1: token = (Token)data; label = 2; data = postItem(token, newItem, this); if (data == COROUTINE_SUSPENDED) break; case 2: item = (Item)data; updateUI(item) label = -1; // ステートマシンの終了 break; } }
内部実装がコールバックヘル というわけではない!
まとめ • coroutineの中断はsuspending functionで発生する • suspending functionはCPS transformによってコールバック に変換される •
複数のsuspending functionの呼び出しはステートマシンにコ ンパイルされる
Thanks!