Диспетчер работ android: пользовательский интерфейс блокируется при записи файла в локальное хранилище

Question

Это мой рабочий класс:

 class CoroutineDownloadJSONWorker(val context: Context, params: WorkerParameters) :
        CoroutineWorker(context, params) {
        private var notificationManager: NotificationManager? = null

        companion object {
            private const val WORK_NAME = "CoroutineDownloadJSONWorker"
            const val PARAM_PROGRESS = "Progress"

            fun run(context: Context): LiveData<WorkInfo> {
                val work = OneTimeWorkRequestBuilder<CoroutineDownloadJSONWorker>()
                    .build()

                val manager = WorkManager.getInstance(context)
                manager.enqueueUniqueWork(WORK_NAME, ExistingWorkPolicy.REPLACE, work)
                return manager.getWorkInfoByIdLiveData(work.id)
            }

            fun stop(context: Context) {
                //  Timber.d("stop")
                val manager = WorkManager.getInstance(context)
                manager.cancelUniqueWork(WORK_NAME)
            }
        }

        override suspend fun doWork(): Result {
            notificationManager = context.getSystemService(Context.NOTIFICATION_SERVICE) as NotificationManager
            val progress = "Starting Download"
            setForegroundAsync(createForegroundInfo(progress))
            val service = Api.getClient.create(ApiService::class.java)
            val call = service.getMapList().execute()
            if (call.isSuccessful) {
                val mapListResponse = call.body()
                if (!mapListResponse!!.result.isNullOrEmpty()) {
                    val fileUrl = mapListResponse.result!![mapListResponse.result.size - 1].id
                    // getDownloadUrl(fileUrl!!)
                    val mapUrls = service.getDownloadMapURL(fileUrl!!).execute()
                    if (mapUrls.isSuccessful) {
                        val mapUrlsResponse = mapUrls.body()
                        if (!mapUrlsResponse!!.json_link.isNullOrEmpty()) {
                            val fileUrl = mapUrlsResponse.json_link
                            val map = service.downloadLatestMap(fileUrl)!!.execute()
                            if (map.isSuccessful) {
                                if (map.body() != null) {
                                  //  getMapFromUrl(map.body())
                                    try {
                                        val futureStudioIconFile =
                                            File(context.getExternalFilesDir(null), "euthopia.json")
                                        var inputStream: InputStream? = null;
                                        var outputStream: OutputStream? = null;
                                        try {
                                            val buffer = ByteArray(4096)
                                            var fileSizeDownloaded:Long = 0;
                                            inputStream = (map.body()!!.byteStream())
                                            outputStream = FileOutputStream(futureStudioIconFile);
                                            while (true) {
                                                val read = inputStream.read(buffer);
                                                if (read == -1) {
                                                    break;
                                                }
                                                outputStream.write(buffer, 0, read);
                                                fileSizeDownloaded += read
                                                setForeground(createForegroundInfo(AppUtils.getBytesString(fileSizeDownloaded)))

                                            }
                                            outputStream.flush();
                                            saveToDB()
                                        } catch (e: IOException) {
                                        } finally {
                                            if (inputStream != null) {
                                                inputStream.close();
                                            }
                                            if (outputStream != null) {
                                                outputStream.close();
                                            }
                                        }
                                    } catch (e: IOException) {
                                    }

                                }
                            }

                        }

                    }
                }

            }


            return Result.success()
        }


        private fun createForegroundInfo(progress: String): ForegroundInfo {
            val context = context
            val id = context.getString(R.string.notification_channel_id)
            val title = context.getString(R.string.notification_title)
            if (Build.VERSION.SDK_INT >= Build.VERSION_CODES.O) {
            }
            val notification: Notification = NotificationCompat.Builder(context, id)
                .setContentTitle(title)
                .setTicker(title)
                .setContentText(progress)
                .setSmallIcon(R.drawable.logo)
                .setOngoing(true) // Add the cancel action to the notification which can
              .build()
            return ForegroundInfo(notification)
        }

    }

Я следую этому уроку код менеджера работ . Я пытаюсь загрузить файл JSON с сервера и сохранить его в локальном хранилище. Я не уверен, почему пользовательский интерфейс блокирует. при записи файла в локальное хранилище в doWork() функция CoroutineWorker. Я показываю прогресс в уведомлении при записи файла. Приложение застревает.

Answer 1

Поскольку вы используете CoroutineWorker, в вашем doWork() вы должны запустить все коды в 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()
    }
}

Пример взят из: https://developer.android.com/topic/libraries/architecture/workmanager/advanced/coroutineworker

Answer 2

Этот код выглядит хорошо, я думаю, что ваша проблема не здесь, вы можете видеть, в каком потоке вы запускаете функцию doWork, используя эту строку Thread.currentThread().name (распечатайте ее, используя журнал), но я считаю, что она победила ' не быть главной темой. так что вы можете заблокировать основной поток в ожидании результата, но нам потребуется больше кода, чтобы узнать это.

Рассматривали ли вы здесь использование RXJava / Kotlin? Я думаю, что в этом случае будет проще.