Swift 并发模型

两个时代的并发：ELF vs async/await

Vapor 4 发布于 Swift Concurrency（async/await、Actor）成熟之前，因此其早期 API 大量使用 EventLoopFuture（简称 ELF）。随着 Swift 5.5 引入原生并发，Vapor 4 也逐步提供了 async/await 版本的 API，两者可以共存。

理解两者的区别，不只是语法偏好，更是运行时模型的差异：ELF 是基于回调的 Future/Promise 模式，链式调用（flatMap、map）在编译期难以发现所有问题；async/await 则将异步代码写成同步风格，借助 Swift 的结构化并发（Structured Concurrency）和编译器检查，大大降低了犯错的概率。

核心概念词典

ELF 与 async/await 对比示例

下面用同一个"查询用户及其文章"的场景，分别展示 ELF 和 async/await 两种写法，直观感受可读性差异：

// ── ELF 写法（Vapor 旧式 API）──────────────────────────
app.get("users", ":id", "posts") { req -> EventLoopFuture<[PostResponse]> in
    let userID = try req.parameters.require("id", as: UUID.self)

    return User.find(userID, on: req.db)          // EventLoopFuture<User?>
        .unwrap(or: Abort(.notFound))             // 解包 Optional
        .flatMap { user in                         // 链接下一个 Future
            user.$posts.query(on: req.db)
                .filter(\.$published == true)
                .all()
        }
        .map { posts in                            // 转换结果
            posts.map { PostResponse(from: $0) }
        }
}

// ── async/await 写法（推荐）──────────────────────────────
app.get("users", ":id", "posts") { req async throws -> [PostResponse] in
    let userID = try req.parameters.require("id", as: UUID.self)

    guard let user = try await User.find(userID, on: req.db) else {
        throw Abort(.notFound)
    }

    let posts = try await user.$posts.query(on: req.db)
        .filter(\.$published == true)
        .all()

    return posts.map { PostResponse(from: $0) }
}

并发执行多个异步操作

async/await 的顺序写法默认是串行的——每个 await 等前一个完成再继续。如果几个操作相互独立，用 async let 或 withTaskGroup 可以并行执行，减少总耗时：

// 串行（慢）：两次数据库查询依次执行，总耗时 = A + B
let user  = try await User.find(userID, on: db)
let posts = try await Post.query(on: db).filter(\.$published==true).all()

// 并行（快）：两个查询同时发起，总耗时 = max(A, B)
async let userFetch  = User.find(userID, on: db)
async let postsFetch = Post.query(on: db).filter(\.$published==true).all()
let (user, posts) = try await (userFetch, postsFetch)

// TaskGroup：并行处理动态数量的任务
let enrichedPosts = try await withThrowingTaskGroup(of: EnrichedPost.self) { group in
    for post in posts {
        group.addTask {
            let comments = try await post.$comments.query(on: db).count()
            return EnrichedPost(post: post, commentCount: comments)
        }
    }
    var results: [EnrichedPost] = []
    for try await result in group {
        results.append(result)
    }
    return results
}

多请求并发处理模型