Swift数组高阶函数闭包需async时的解决方案求助

针对Swift 6中数组无法直接使用异步闭包进行filter的问题，这里提供几种更优雅的实现方式：

1. 并行批量处理（高效优先） #

利用TaskGroup并行执行所有异步判断，一次性获取结果后再过滤，适合判断操作独立且耗时的场景：

// 并行获取每个歌曲的下载状态
let downloadStates = await withTaskGroup(of: (SubsonicSong, Bool).self) { group in
    for song in services.currentPlaylist.list {
        group.addTask {
            (song, await services.download.isDownloaded(song: song))
        }
    }
    // 收集所有任务结果
    return await group.reduce(into: []) { $0.append($1) }
}

// 根据状态过滤出已下载歌曲
let result = downloadStates.filter(\.1).map(\.0)

2. 封装异步Filter扩展（复用优先） #

给Array扩展异步版本的filter方法，以后可以直接像同步filter一样调用：

顺序执行版本（逻辑与原for循环一致） #

extension Array {
    func asyncFilter(_ isIncluded: (Element) async throws -> Bool) async rethrows -> [Element] {
        var filteredElements = [Element]()
        for element in self {
            if try await isIncluded(element) {
                filteredElements.append(element)
            }
        }
        return filteredElements
    }
}

// 使用示例
let result = await services.currentPlaylist.list.asyncFilter {
    await services.download.isDownloaded(song: $0)
}

并行执行版本（效率优化） #

如果需要更高效率，可以在扩展中结合TaskGroup实现并行处理：

extension Array {
    func asyncFilterParallel(_ isIncluded: @escaping (Element) async throws -> Bool) async rethrows -> [Element] {
        try await withThrowingTaskGroup(of: (Element, Bool).self) { group in
            for element in self {
                group.addTask {
                    (element, try await isIncluded(element))
                }
            }
            return try await group.reduce(into: []) { accumulator, item in
                if item.1 {
                    accumulator.append(item.0)
                }
            }
        }
    }
}

// 使用示例
let result = await services.currentPlaylist.list.asyncFilterParallel {
    await services.download.isDownloaded(song: $0)
}

为什么原写法报错？ #

标准库的filter是同步方法，仅接受同步闭包作为参数，而调用actor的隔离方法必须使用await，导致闭包变为异步类型，无法匹配同步参数要求。因此必须通过上述方式实现异步过滤逻辑。

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