后端并行查询库存时，取消Job无法终止非可取消挂起函数

协程取消是协作式的——只有代码主动响应取消信号时，取消才能生效。delay这类挂起函数内部会定期检查取消状态，所以能立即终止；但你的inventory.searchProducts(req)是阻塞式的同步调用，它完全感知不到协程的取消信号，会一直执行到完成，这就是取消Job后其他请求还在等待的核心原因。

1. 将阻塞调用包装为可取消的挂起函数 #

Kotlin 1.6+提供了runInterruptible，可以把阻塞操作包装成可取消的挂起函数。当协程取消时，它会尝试中断执行阻塞操作的线程（只要线程支持中断，比如普通Java线程），从而立即终止任务。

修改products函数：

suspend fun products(req: Request): List<*>? {
    return try {
        // 把阻塞查询包装成可取消的挂起操作
        runInterruptible(Dispatchers.IO) {
            inventory.searchProducts(req)
        }
    } catch (e: CancellationException) {
        println("查询被取消")
        null
    } catch (e: InterruptedException) {
        // 线程被中断，转为协程取消异常
        println("查询线程被中断")
        throw CancellationException("查询被取消", e)
    } catch (e: Exception) {
        // 处理库存查询本身的业务异常
        println("库存查询失败: ${e.message}")
        null
    }
}

2. 优化协程结构，自动管理取消逻辑 #

不需要手动创建Job和CoroutineScope，用coroutineScope创建作用域即可——它会自动在任一子协程失败/取消时，立即取消所有其他子协程，完美匹配你“任一查询失败就停止所有请求”的需求。同时通过抛出异常替代手动cancel()，更符合协程的错误处理范式。

修改searchPackages函数：

override suspend fun searchPackages(req: RequestFromClient): PackageResult? {
    return try {
        coroutineScope {
            // 并行启动两个查询任务
            val products1Deferred = async {
                products(req.type1) ?: throw IllegalStateException("库存X查询失败")
            }
            val products2Deferred = async {
                products(req.type2) ?: throw IllegalStateException("库存Y查询失败")
            }

            // 等待结果，任一任务抛出异常会立即取消另一个
            val products1 = products1Deferred.await() as List<Product1>
            val products2 = products2Deferred.await() as List<Product2>

            // 按业务逻辑组装结果返回
            PackageResult(products1, products2)
        }
    } catch (e: CancellationException) {
        // 协程被取消，返回null（或直接抛异常给上层返回500）
        null
    } catch (e: IllegalStateException) {
        // 查询失败，返回500错误
        null
    }
}

关键注意点 #

• runInterruptible的局限性：如果你的inventory.searchProducts(req)内部不处理InterruptedException，需要确保它能正确响应中断（比如JDBC驱动、主流同步HTTP客户端大多支持中断）。
• 避免全局Scope：coroutineScope是绑定当前上下文的挂起函数，不会造成协程泄漏，比手动创建CoroutineScope更安全。
• 异常优先：用抛出异常触发取消，比手动调用job.cancel()更简洁，也能保证所有子协程都能收到取消信号。

内容的提问来源于stack exchange，提问作者BVtp