CoroutineWorker でのスレッド化

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

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

    override suspend fun doWork(): Result = {
        val data = downloadSynchronously("https://www.google.com")
        saveData(data)

        Result.success()
    }
}

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

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

    override suspend fun doWork(): Result {
        withContext(Dispatchers.IO) {
            val data = downloadSynchronously("https://www.google.com")
            saveData(data)
            return Result.success()
        }

    }
}

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