协程范围 - 可压缩延迟取消

Question

关于这个话题，我有两个问题。我将在 android 中将它们与用例类一起使用，并尝试实现与此类似的架构 https://www.youtube.com/watch?v=Sy6ZdgqrQp0 但我需要一些答案。

1(我有一个延迟的异步构建器，当我取消作业时，然后 其他连锁店也被取消了。此代码打印"呼叫已取消"。但我不确定我做得是否正确。

fun main(args: Array<String>) = runBlocking<Unit> {
val job = GlobalScope.launch {
println(getUser())
}
job.cancelAndJoin()
}
suspend fun getUser() = getUserDeferred().await()

suspend fun getUserDeferred() = coroutineScope {
val request = Request.Builder()
.url("https://jsonplaceholder.typicode.com/users")
.build()
val call = OkHttpClient().newCall(request)
val deferred = async(Dispatchers.IO) {
val body = call.execute()
body.body()?.string() ?: ""
}
deferred.invokeOnCompletion {
if (deferred.isCancelled) {
println("Call cancelled")
call.cancel()
}
}
deferred
}

2(我找不到取消这个的方法。我想在 retrofit2 呼叫适配器中使用它，有没有更好的方法来处理这种情况。

fun main(args: Array<String>) = runBlocking<Unit> {
val job = GlobalScope.launch {
println(getUser1())
}
job.cancelAndJoin()
}
suspend fun getUser1() = getUser1Deferred().await()

fun getUser1Deferred(): Deferred<String> {
val request = Request.Builder()
.url("https://jsonplaceholder.typicode.com/users")
.build()
val call = OkHttpClient().newCall(request)
val deferred = CompletableDeferred<String>()
call.enqueue(object : Callback {
override fun onFailure(call: Call, e: IOException) {
deferred.complete("Error")
}
override fun onResponse(call: Call, response: Response) {
deferred.complete(response.body()?.string() ?: "Error")
}
})
deferred.invokeOnCompletion {
if (deferred.isCancelled) {
println("Call cancelled")
call.cancel()
}
}
return deferred
}

Answer 1

应避免使用第一种方法，因为它会阻塞线程池中的线程。使用第二种方法，您可以双向传播取消。如果您取消Deferred它将取消呼叫，如果调用失败，它将取消Deferred，但得到的除外。

fun getUserAsync(): Deferred<String> {
val call = OkHttpClient().newCall(Request.Builder()
.url("https://jsonplaceholder.typicode.com/users")
.build())
val deferred = CompletableDeferred<String>().apply {
invokeOnCompletion {
if (isCancelled) {
call.cancel()
}
}
}
call.enqueue(object : Callback {
override fun onResponse(call: Call, response: Response) {
deferred.complete(response.body()?.string() ?: "Error")
}
override fun onFailure(call: Call, e: IOException) {
deferred.cancel(e)
}
})
return deferred
}

然而，走Deferred路线可能是一条红鲱鱼。如果你取消它，根本原因是你正在拯救你正在做的整个任务。相反，您应该取消它运行的整个协程。如果您正确实现了结构化并发，那么当您的活动被破坏时，一切都会自动发生。

所以我的建议是使用以下代码：

suspend fun getUser() = suspendCancellableCoroutine<String> { cont ->
val call = OkHttpClient().newCall(Request.Builder()
.url("https://jsonplaceholder.typicode.com/users")
.build())
cont.invokeOnCancellation {
call.cancel()
}
call.enqueue(object : Callback {
override fun onResponse(call: Call, response: Response) {
cont.resume(response.body()?.string() ?: "Error")
}
override fun onFailure(call: Call, e: IOException) {
cont.resumeWithException(e)
}
})
}

如果您绝对需要Deferred，因为您在后台并发运行它，那么使用上述方法很容易做到：

val userDeferred = this.async { getUser() }

我认为this是你的活动，这也是一个CoroutineScope.

Answer 2

第二种情况没有取消的原因是因为你正在使用CompletableDeferred. 它不是作为协程启动的，因此不是父协程的子项。 因此，如果您取消父级，则不会取消延期。

它在第一种情况下有效，因为async启动链接到父项的新子协程。 当您取消任何一个时，它们都会被取消。

为了将Deferred链接到您的父作业，您需要引用它并使用invokeOnCompletion

var deferred : Deferred<Void>? = null
launch {        
deferred = retroService.someDeferredCall()
deferred.await()
}.invokeOnCompletion {
//job was cancelled.  Probably activity closing.
if(it is CancellationException) {
deferred?.let { it.cancel() }
}
}

不是很漂亮，但应该完成工作。