使用Kotlin协程返回首个成功任务且不等待/取消其他任务

你需要实现一个任务分发器，要求立即返回首个执行成功的任务结果，同时不等待也不取消其他正在执行的任务。当前代码的问题在于coroutineScope会等待所有子协程完成后才返回，导致execute()函数无法在拿到第一个成功结果后立刻返回，进而让main函数里的println(result)延迟执行。

核心思路是让执行任务的协程脱离当前的coroutineScope，使用独立的后台Scope来启动任务，这样当前Scope无需等待所有任务完成就能返回结果。

修改后的完整代码如下：

import kotlinx.coroutines.*
import kotlinx.coroutines.flow.channelFlow
import kotlinx.coroutines.flow.filter
import kotlinx.coroutines.flow.firstOrNull

data class Result(val success: Boolean, val value: String)

interface Task {
    suspend fun execute(): Result
}

val taskA = object : Task {
    override suspend fun execute(): Result {
        delay(100)
        println("Execute task A")
        return Result(false, "A")
    }
}

val taskB = object : Task {
    override suspend fun execute(): Result {
        delay(200)
        println("Execute task B")
        return Result(true, "B")
    }
}

val taskC = object : Task {
    override suspend fun execute(): Result {
        delay(300)
        println("Execute task C")
        return Result(true, "C")
    }
}

class Dispatcher {
    // 定义后台协程Scope，用于执行无需阻塞当前流程的任务
    private val backgroundScope = CoroutineScope(Dispatchers.Default)

    suspend fun execute(): Result? = coroutineScope {
        val deferred: List<Deferred<Result>> = listOf(taskA, taskB, taskC).map {
            // 使用后台Scope启动async，避免阻塞当前coroutineScope
            backgroundScope.async { it.execute() }
        }

        // 收集首个成功的任务结果
        val result = channelFlow {
            deferred.forEach { launch { send(it.await()) } }
        }
            .filter { it.success }
            .firstOrNull()

        println("Execution result: $result")

        result
    }
}

fun main() = runBlocking {
    val result = Dispatcher().execute()
    println(result)
    delay(1000)
}

修改后运行的输出将符合你的期望：

Execute task A
Execute task B
Execution result: Result(success=true, value=B)
Result(success=true, value=B)
Execute task C

原因解释：

• 任务A、B、C通过backgroundScope.async启动，属于后台协程，不受execute()函数的coroutineScope约束。
• 当拿到taskB的成功结果后，execute()函数立刻返回，main函数随即打印result。
• 后台的taskC会继续执行，在延迟300ms后打印"Execute task C"，完全不影响主线程的流程。

注意：实际项目中建议自定义带有生命周期管理的Scope，避免使用无约束的全局Scope，这里用backgroundScope是为了简洁演示。

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