先说说协程的取消吧，哈哈，你懂的，协程取消其实挺讲究的。

private suspend fun joinSuspend = suspendCancellableCoroutine { continuation -> val disposable = doOnCompleted { _ -> continuation.resume } continuation.invokeOnCancellation { // 所在协程被取消时移除需要等待的目标协程注册的完成回调，防止在完成状态下恢复执行抛出移除 disposable.dispose }}

Ru果 join 函数对应的协程Yi经完成，我们Ke以直接返回；但此时我们Ke以检查一下当前所在协程的状态，Ru果Yi经取消，则抛出取消异常予以响应。

import kotlin.coroutines.intrinsics.COROUTINE_SUSPENDED// @OptInclass CancellableContinuation<T> : Continuation<T> by continuation { private val state = AtomicReference<CancelState> private val decision = AtomicReference // 是否完成 val isCompleted: Boolean get = when ) { CancelState.Incomplete, is CancelState.CancelHandler -> false is CancelState.Complete<*>, CancelState.Cancelled -> true } /** * 注册取消回调 */ fun invokeOnCancellation { val newState = state.updateAndFetch { prev -> when { CancelState.Incomplete -> CancelState.CancelHandler is CancelState.CancelHandler -> throw IllegalStateException is CancelState.Complete<*>, CancelState.Cancelled -> prev } } if { onCancel } } // 其他代码咱就不贴了你懂的}

说实话，CancellableContinuation 的实现还是挺巧妙的，它代理了 Continuation，并在完成时流转状态，支持取消回调的注册。

这个问题啊，害，其实hen简单，因为 CancellationException 是正常的取消控制流，不应该被视为程序崩溃。

override fun resumeWith { // ... // 若Zui终状态携带异常，进入异常分发流程 ?.exception?.let { e -> tryHandleException } newState.notifyCompletion newState.clear}/** * 尝试处理异常，分发前先Zuo静默过滤 */private fun tryHandleException: Boolean { return when { is CancellationException -> { // 忽略正常的取消控制流，避免将其视为程序崩溃 false } else -> { // 将常规未捕获异常交由子类处理 handleJobException } }}

为啥要这样Zuo呢？你想啊，Ru果不忽略 CancellationException，那岂不是每次取消协程dou会被视为崩溃？那还得了！

我们在 AbstractCoroutine 定义一个 handleJobException 函数，返回 true 表示异常Yi处理。它的子类Ke以根据自身需要来实现特有的异常处理逻辑。

为什么百度不收录我的文章啊？

这个问题啊，老生常谈了你得kankan你的文章是不是有什么问题，比如是不是原创度不够，或者是不是关键词堆砌之类的。

StandaloneCoroutine: 由 launch 启动，自身无返回结果。我们希望它在遇到未捕获的异常时优先调用自身的异常处理器进行处理，Ru果没有进行配置，则将异常抛给 completion 调用时所在线程的 uncaughtExceptionHandler 来兜底。

// override fun handleJobException: Boolean { super.handleJobException // 优先由自身的异常处理器处理，无配置则由线程的 uncaughtExceptionHandler 兜底 context?.handleException ?: Thread.currentThread.let { it.uncaughtExceptionHandler.uncaughtException } return true}

取消异步任务通常使用Job.cancel函数，二、cancel 对于cancel的使用方式如下: importkotlinx.coroutines.* fun main = runBlocking { val job = launch {...} job.cancel}

DeferredCoroutine: 由 async 启动，通常有返回结果。由于它需要将结果返回给调用者，所以我们无需覆写该方法去主动处理异常，而是将未捕获的异常存放在Zui终状态中，等外部调用 await 获取结果时才将异常抛出。

Kotlin 协程提供了geng优雅的取消机制,这也是协程比较核心的功Neng之一。.抛出异常的 Job会导致其进入 Cancelling状态,也Ke以使用 cancel方法来随时取消 Job使其立即转换为 Cancelling状态。.

suspend fun delay { if { return } suspendCancellableCoroutine { continuation -> val future = executor.schedule }, time, unit) continuation.invokeOnCancellation { // 当所在协程被取消时取消底层的 future 定时任务 future.cancel } }} 改造 join

private suspend fun testJoin { // join 示例代码...