In part 2 of the Cancellation and Exceptions in Coroutines series, we learnt the importance of cancelling work when it’s no longer needed. On Android, you can use the CoroutineScopes provided by Jetpack: viewModelScope or lifecycleScope that cancel any running work when their scope completes — that is when the Activity/Fragment/Lifecycle completes. If you’re creating your own CoroutineScope, make

Coroutines are stable as of 1.3!Migrated to personal blog: https://alexsaveau.dev/2018/10/30/advanced-kotlin-coroutines-tips-and-tricks/ Kotlin Coroutines starts off incredibly simple: just put some long running operation in launch and you’re good, right? For simple cases, sure. But pretty soon, the complexity inherent to concurrency and parallelism starts piling up. Here’s what you need to know w

But what happens if the collector is also slow and adds its own 100 ms delay before printing each element? Check it out: It takes around 2 seconds to complete, because both emitter and collector are parts of a sequential execution here and it alternates between them: Concurrent coroutinesCan we structure this execution so that the whole operation completes faster, changing neither emitter’s nor co

Room 2.1 adds support for Kotlin coroutines. DAO methods can now be marked as suspending to ensure that they are not executed on the main thread. Read on to see how to use this, how it works under the hood and how to test this new functionality. Add some suspense to your databaseTo use coroutines and Room in your app, update to Room 2.1 and add the new dependency to your build.gradle file: impleme

If you’re coming from Java, you probably associate asynchronous with threads. And that means you’ve dealt with shared mutable state. You’ve spent countless hours chasing down deadlocks and race conditions. You’ve taken care when modifying shared state using locking primitives like synchronized. You might have even used higher order locking functions like Semaphores and Latches. At this point you c

- Kotlin1.3とCoroutine1.0.0とJetpack - なぜAndroidでコルーチンを使いたいか - Androidでコルーチンを使う準備 - 並行処理を書く(直列、並列、スコープと例外) - おまけ1: Rx with Coroutine - おまけ2: Jetpack with Coroutine

Structured concurrency – Roman Elizarov – Mediumでは、Kotlin coroutine 0.26.0でCoroutineScopeを導入した経緯などが書かれているんですが、タイトルのStructured concurrencyってのが結局なんなのか本文中にはあんまり出てこないんですよね。 んで、CoroutineScopeの動作の理解に精一杯で、coroutineScope関数がなんなのか、どういう時に使うべきなのかよくわからないし、ましてやsupervisorScope関数なんて言われた日には意味が不明なわけです。 とりあえずlaunch関数内でasync関数呼び出したら駄目なんだな〜ふ〜んなんで？ Notes on structured concurrency, or: Go statement considered harmfulを頑張

はじめに Kotlinのcoroutinesはスレッドと比べると非常に軽量であり、Non-blocking操作をさせるだけなら100,000個を同時起動したとしても問題なく処理を行えます。 一方で、サーバに負荷がかかるからAPIをあまり同時に呼びすぎないようにしたい、など並列に実行する数を制限したいシチュエーションというのも勿論存在します。 今回の記事ではcoroutinesの同時実行数をどのように制御すればいいのかについて書きたいと思います。 前提条件 あるAPIを呼び出す関数が以下のように定義されているとします。 また、HTTPリクエストはNon-blockingで、レスポンスが返るまでこのsuspending functionは中断しているとします。 (Androidのretrofitではenqueueベースに実装するとこうなります) うまくいかないやりかた Blockingに慣れた

前書き coroutineはKotlin 1.1から搭載された新機能ですが、まだexperimentalなこともあってバリバリ使っている人は多くないと思われます。しかしながら、experimentalとはいえproduction readyなことは宣言されており、Kotlin 1.3ではexperimentalが外れる(予定の)ため、そろそろ学んでおいても悪くない時期になってきています。 そこで、この記事ではcoroutineを実践するにあたって抑えておくと役立つ知見を共有します。ご参考になれば幸いです！ 注: この記事はKotlin 1.2.21, kotlinx.coroutines 0.22.5に基づいて書かれています。 coroutineとは何であって何でないのか coroutineとは何か coroutineとは何かを一言で表現すると、「中断可能な計算インスタンス」になります。こ

Table of ContentsHow to launch a coroutineHow to launch a coroutine with a timeoutHow to cancel a coroutineHow to handle exceptions with coroutinesHow to test coroutinesHow to log coroutine threadSource code for this article is available at dmytrodanylyk/coroutine-recipes Based on coroutine version v1.0.0 Dependenciesimplementation 'org.jetbrains.kotlinx:kotlinx-coroutines-core:1.0.0'implementatio