Kotlin协程awaitAll结果排序及原请求对应问题咨询
Kotlin协程awaitAll结果与请求对应问题
问题背景
我正在研究Kotlin协程的awaitAll方法,需要并发执行多个数据库调用,等待全部完成后聚合结果。但awaitAll仅返回一个列表,无法直接将每个结果与原请求对应,导致无法针对不同来源的结果执行特定操作。
当前实现无法区分结果所属的客户端:
val dbClientNames = ArrayList<String>() val dbCallTasks = ArrayList<Deferred<Map<String, Set<String>>?>>() withContext(Dispatchers.IO) { for (client in dbClients){ dbClientNames.add(client.getName()) val deferredTask = async { withTimeoutOrNull(1000L) { client.getItems(instanceList) } } dbCallTasks.add(deferredTask) } dbCallTasks.awaitAll() }
核心疑问
我查看了awaitAll的实现,它有两个版本:kotlin.collections.Collection<kotlinx.coroutines.Deferred<T>>.awaitAll()和awaitAll(vararg deferreds: kotlinx.coroutines.Deferred<T>): kotlin.collections.List<T>。我想确认:该方法返回的列表是否保证与提交的Deferred任务顺序一致?如果顺序有保证,就能通过索引将结果和对应的客户端关联起来。
测试中的异常现象
我尝试用两个列表(客户端名称列表、Deferred任务列表)做对应,假设awaitAll有序的话,索引i的结果应该对应同索引的客户端名称。但测试时结果顺序不稳定,不确定是测试代码问题还是awaitAll本身不保证顺序:
测试代码:
coEvery { dbClient.getName() } returns "A" andThen "B" andThen "C" coEvery { dbClient.getItems(any()) } returns aHashMap andThen bHashMap andThen cHashMap
每次运行测试,awaitAll的结果顺序都可能不同,例如:
[A, B, C] [{}, {C=[i-DontCare]}, {}]
[A, B, C] [{C=[i-DontCare]}, {}, {}]
偶尔结果顺序符合预期:
[A, B, C] [{}, {}, {C=[i-DontCare]}]
内容的提问来源于stack exchange,提问作者Bao Thai
相关产品推荐
相关产品推荐

