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