Alamofire按ID分块发多请求仅返回首块结果问题求助

• 原有request方法遍历分块发起请求时，第一个请求返回就立刻调用了completion回调，后续分块的请求结果根本不会被收集。
• 用withUnsafeThrowingContinuation包装时，continuation仅能被resume一次，首块请求触发resume后，剩余请求的回调即使执行也无法生效，甚至会触发重复resume的崩溃。
• 之前尝试的递归、DispatchGroup方案未生效，基本都是因为没有正确等待所有分块请求返回就提前触发完成回调，或是错误处理分支漏写状态同步逻辑、没有做全量结果聚合。
• 额外问题：Alamofire 5.5+ 已原生支持Swift并发，手动用UnsafeContinuation包装回调很容易引入线程安全问题。

直接用Swift原生的withThrowingTaskGroup处理多请求聚合，搭配Alamofire原生async接口，不需要自己封装回调层，也不用手动处理DispatchGroup的enter/leave配对问题，逻辑更稳定：
首先抽离单个分块的请求逻辑：

import Alamofire

private func requestSingleChunk(
    idsDict: [String: [String]],
    chunk: [String],
    idSchema: String
) async throws -> SomeModel {
    let parameters = constructQueryParams(idsDict, chunk, idSchema, apiKey, clientId)
    // 自动校验状态码、解码响应，错误会自动向外抛出
    return try await AF.request(baseURL, parameters: parameters)
        .validate()
        .serializingDecodable(SomeModel.self, decoder: JSONDecoder())
        .value
}

然后实现批量请求方法，支持控制并发数避免触发接口限流：

func getIdsEntities(
    _ idsDict: [String: [String]],
    _ idSchema: String,
    maxConcurrent: Int = 2
) async throws -> [SomeModel] {
    let chunks = transformEntitiesIdsToChunks(idsDict)
    var aggregatedResults = [SomeModel]()
    // 串行队列保证多线程写结果数组的线程安全
    let resultWriteQueue = DispatchQueue(label: "com.app.batchRequest.writeQueue")
    // 信号量控制最大并发数，不需要限流可删除相关逻辑
    let concurrencySemaphore = DispatchSemaphore(value: maxConcurrent)

    try await withThrowingTaskGroup(of: SomeModel.self) { group in
        for chunk in chunks {
            concurrencySemaphore.wait()
            group.addTask {
                defer { concurrencySemaphore.signal() }
                return try await requestSingleChunk(
                    idsDict: idsDict,
                    chunk: chunk,
                    idSchema: idSchema
                )
            }
        }

        // 按任务完成顺序收集所有分块结果
        for try await chunkResult in group {
            resultWriteQueue.sync {
                aggregatedResults.append(chunkResult)
            }
        }
    }

    // 如果需要保证结果顺序和传入ID顺序一致，可在此处添加排序逻辑
    // 如果需要将多个分块结果合并为单个模型，也在此处处理
    return aggregatedResults
}

• 如果你不需要控制请求并发速度（比如接口没有频率限制），可以删掉信号量相关的代码，所有分块会并发发起请求，整体响应速度更快。
• 如果业务要求请求失败时整体终止，现有逻辑已经满足：任意一个分块请求抛出错误，TaskGroup会自动取消剩余所有请求，把错误向外抛出。
• 如果你需要部分成功的容错逻辑，可以在requestSingleChunk调用处加do-catch，把失败的分块结果做特殊标记，不会中断其他请求。

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