【Kotlin】コルーチンなどの非同期処理を並列ではなく順番に処理する方法について

Question

実現したいこと

Kotlinの非同期処理を並列ではなく順番に処理する方法を探しております。
下記コードはAndroidの通知リスナークラスで、通知されるたびにonNotificationPostedが呼び出されます。
その中でDB登録などを行いたいため非同期で処理を実装したのですが、複数通知が同時にされた場合にDB登録の処理も並列で同時に行われてしまいます。
DB登録時に重複チェックや登録状況に応じて何かしらの処理など行いたいため、並列ではなく順番に実行させたいのですが、良い実現方法は無いでしょうか。
実行したスレッドを中断させるrunBlockingなども試しましたが、うまく機能しませんでした。（別スレッドで実行されているため？）

該当のソースコード

class NoticeListenerService : NotificationListenerService() {

    private val notificationListenerScope = CoroutineScope(Dispatchers.IO)

    // 通知されるたびコールされる
    override fun onNotificationPosted(sbn: StatusBarNotification?) {
        super.onNotificationPosted(sbn)
        if (sbn == null ) return

        notificationListenerScope.launch {
            // ここでDB登録などを実行
        }
    }
}

Answer 1

coroutineについてはど素人なので、ドキュメントをみた感じです。

• https://kotlinlang.org/api/kotlinx.coroutines/kotlinx-coroutines-core/kotlinx.coroutines/-dispatchers/-i-o.html

Dispatchers.IO.limitedParallelism(1)とすれば、並列でひとつずつなので、結果的に直列になるのではないでしょうか。

Comments

[woker]

shiketaさん
ご回答いただきありがとうございました。
上記を追加し確認したところ、直列での実行となることを確認できました。

Answer 2

特に詳しいわけではありませんが、そういう場合はよくキュー(queue)を使うと思いまう。

DB登録を行ないたいプロセスがキューにリクエストを出し、DB登録のための別プロセスが1つずつ処理するというイメージです。

Comments

[woker]

TakaiYさん
ご回答いただきありがとうございました。
調べたところqueue機能を実装して実現しているものがいくつかありました。
今回は別途回答いただいた処理で目的の制御が可能であったためそちらで実装しようと思いますが、queue制御についても学んでおきたいと思います。