Google は、黒人コミュニティに対する人種平等の促進に取り組んでいます。取り組みを見る

CoroutineWorker でのスレッド化

Kotlin ユーザーは WorkManager を使用することによってコルーチンを最大限に活用できます。まず、gradle ファイルに work-runtime-ktx を追加しますWorker を拡張する代わりに、API が若干異なる CoroutineWorker を拡張する必要があります。たとえば、簡単な CoroutineWorker を作成してネットワーク オペレーションを実行する場合は、次のようにします。

class CoroutineDownloadWorker(context: Context, params: WorkerParameters) : CoroutineWorker(context, params) {

    override suspend fun doWork(): Result = coroutineScope {
        val jobs = (0 until 100).map {
            async {
                downloadSynchronously("https://www.google.com")
            }
        }

        // awaitAll will throw an exception if a download fails, which CoroutineWorker will treat as a failure
        jobs.awaitAll()
        Result.success()
    }
}

なお、CoroutineWorker.doWork() は、停止中の関数です。Worker とは異なり、このコードは、Configuration で指定された Executor では実行できません。代わりに、デフォルトで Dispatchers.Default になります。これをカスタマイズするには、独自の CoroutineContext を用意します。上記の例の場合、Dispatchers.IO で次のように処理を行うことをおすすめします。

class CoroutineDownloadWorker(context: Context, params: WorkerParameters) : CoroutineWorker(context, params) {

    override val coroutineContext = Dispatchers.IO

    override suspend fun doWork(): Result = coroutineScope {
        val jobs = (0 until 100).map {
            async {
                downloadSynchronously("https://www.google.com")
            }
        }

        // awaitAll will throw an exception if a download fails, which CoroutineWorker will treat as a failure
        jobs.awaitAll()
        Result.success()
    }
}

CoroutineWorker は、コルーチンをキャンセルしてキャンセル信号を伝達することにより、停止を自動的に処理します。処理の停止に対処するために特別な操作は必要ありません。