Eu criei o seguinte aplicativo para ilustrar algumas dúvidas. Meu exemplo no Github
Neste exemplo, copio um arquivo para outro pacote.
Minhas dúvidas são as seguintes:
Realizando as tarefas em paralelo, é possível retornar os valores que foram concluídos antes do cancelamento?
Por que, em
contentResolver.openInputStream (uri)
, a mensagem "Inappropriate blocking method call" é exibida enquanto eu estou trabalhando com o contexto IO?Enquanto estou lendo a entrada do arquivo a ser copiada para a saída, sempre verifico o status do
job
para que, quando essa tarefa for cancelada, seja interrompida imediatamente, o arquivo de saída criado seja excluído e retorne a exceção de cancelamento, está correto ?Posso delimitar a quantidade de tarefas que são executadas?
fun onClickStartTask(view: View) { var listNewPath = emptyList<String>() CoroutineScope(Main + job).launch { try { //shows something in the UI - progressBar withContext(IO) { listNewPath = listUri.map { uri -> async { //path to file temp val pathFileTemp = "${getExternalFilesDir("Temp").toString()}/${uri.lastPathSegment}" val file = File(pathFileTemp) val inputStream = contentResolver.openInputStream(uri) inputStream?.use { input -> FileOutputStream(file).use { output -> val buffer = ByteArray(1024) var read: Int = input.read(buffer) while (read != -1) { if (isActive) { output.write(buffer, 0, read) read = input.read(buffer) } else { input.close() output.close() file.deleteRecursively() throw CancellationException() } } } } //If completed then it returns the new path. return@async pathFileTemp } }.awaitAll() } } finally { //shows list complete in the UI } } }
Essa seria a ação do botão para executar a tarefa.
Agradeço toda a ajuda.