【Kotlin】【Coroutines】asyncの挙動を確認する【株式会社ライトコード】

※弊社のエンジニア記事になります。

Android Coroutines Async の挙動を確認したのでメモとして残しておく

1.準備

// Coroutines
dependencies {
    <省略>
    def coroutines_android_version = '1.6.0'
    implementation "org.jetbrains.kotlinx:kotlinx-coroutines-core:$coroutines_android_version"
    implementation "org.jetbrains.kotlinx:kotlinx-coroutines-android:$coroutines_android_version"
    <省略>
}

suspend関数作成

まずはasyncで動作させるsuspend関数を作成

suspend fun mySuspend(name: String, delayTimeMillis: Long): Int {
    return withContext(Dispatchers.Default) {
        log.emit("---------start mySuspend() $name---------")
        var result = 0
        (1..5).forEach {
            result += (1..100).random()
            delay(delayTimeMillis)
            log.emit("mySuspend() $name - $it")
        }
        log.emit("---------finish mySuspend() $name---------")
        return@withContext result
    }

例外発生用のsuspend関数作成

例外を発生させる関数も作っておく

@Suppress("UNREACHABLE_CODE")
suspend fun error(name: String, crashTime: Int = 5): Int {
    withContext(Dispatchers.Default) {
        log.emit("---------start error() $name---------")
        (crashTime downTo 0).forEach {
            if (it <= 0) {
                log.emit("throw Exception!")
                throw Exception("error")
            }
            log.emit("throw Exception まで あと${it}秒")
            delay(1000L)
        }
        log.emit("---------finish error() $name---------")
    }
    return (1..100).random()
}

ログ表示用のLiveData用意しておく

TextViewにログを表示するために実装（必須ではない）

val log = MutableSharedFlow<String>(replay = 100)

val logTextLiveData: LiveData<String> = log.mapLatest {
    Log.d("my_log", it)
    val stringBuilder = StringBuilder()
    log.replayCache.forEach {
        stringBuilder.append(it)
        stringBuilder.append("\n")
    }
    stringBuilder.toString()
}.asLiveData()

記事の続きは以下URLからご覧ください。

https://rightcode.co.jp/blog/information-technology/kotlin-coroutines-async