Swift异步任务组：无需返回值时如何等待所有任务完成？

你可以直接利用Swift的withThrowingTaskGroup（如果异步方法可能抛出）或withTaskGroup（无抛出），配合顶层Task的.value属性阻塞同步代码，无需依赖信号量。核心思路是在任务组中批量添加异步任务，等待所有任务完成后再让同步代码继续执行。

示例代码 #

override func main() {
    guard !isCancelled else { return }

    // 替换成你实际需要处理的任务数据源
    let taskItems = ["file1", "file2", "file3"]

    do {
        // 用Task.value()阻塞当前同步线程，直到内部异步任务全部完成
        try Task {
            try await withThrowingTaskGroup(of: Void.self) { group in
                for item in taskItems {
                    guard !self.isCancelled else {
                        group.cancelAll()
                        break
                    }
                    // 给任务组添加异步任务，无需处理返回值
                    group.addTask {
                        // 调用你的长时间异步写入方法
                        try await self.performDiskWrite(for: item)
                    }
                }
                // 等待组内所有任务完成
                try await group.waitForAll()
            }
        }.value
    } catch {
        // 处理任务取消或异步方法抛出的错误
        print("任务执行失败：\(error)")
    }
}

// 模拟你的异步磁盘写入方法
private func performDiskWrite(for item: String) async throws {
    // 模拟耗时操作
    try await Task.sleep(nanoseconds: 1_500_000_000)
    print("完成写入：\(item)")
}

关键说明 #

• 任务组泛型设为Void.self：明确表示不需要任务返回值，贴合你的场景
• group.waitForAll()：专门用于等待组内所有任务完成，无需像map/combine那样收集结果
• Task.value：顶层任务的这个属性会同步阻塞当前线程，直到异步逻辑执行完毕，完美适配NSOperation的同步main方法需求
• 取消兼容：加入NSOperation的取消检查，一旦操作被取消，立即取消所有未完成的异步任务，避免无效工作

这个方案比信号量实现更简洁，利用Swift Concurrency原生机制管理并行任务，减少手动维护同步状态的出错概率。

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