6월 3일의 ⁠#Android11: 베타 버전 출시 행사에 참여하세요.

CoroutineWorker의 스레딩

WorkManager는 Kotlin 사용자에게 코루틴을 위한 최고 수준의 지원을 제공합니다. 시작하려면 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는 코루틴을 취소하고 취소 신호를 전파하여 자동으로 중지를 처리합니다. 작업 중지를 처리하기 위해 특별히 해야 할 일은 없습니다.