name: swift-actor-persistence description: 使用Swift Actors实现线程安全的数据持久化——结合内存缓存与文件存储，通过设计消除数据竞争。

使用Swift Actors实现线程安全持久化

使用Swift actors构建线程安全数据持久化层的模式。结合内存缓存与文件存储，利用actor模型在编译时消除数据竞争。

何时使用

在Swift 5.5+中构建数据持久化层
需要对共享可变状态进行线程安全访问
希望消除手动同步（锁、DispatchQueues）
构建具有本地存储的离线优先应用

核心模式

基于Actor的存储库

Actor模型保证串行访问——无数据竞争，由编译器强制执行。

public actor LocalRepository<T: Codable & Identifiable> where T.ID == String {
    private var cache: [String: T] = [:]
    private let fileURL: URL

    public init(directory: URL = .documentsDirectory, filename: String = "data.json") {
        self.fileURL = directory.appendingPathComponent(filename)
        // 初始化期间同步加载（actor隔离尚未激活）
        self.cache = Self.loadSynchronously(from: fileURL)
    }

    // MARK: - 公共API

    public func save(_ item: T) throws {
        cache[item.id] = item
        try persistToFile()
    }

    public func delete(_ id: String) throws {
        cache[id] = nil
        try persistToFile()
    }

    public func find(by id: String) -> T? {
        cache[id]
    }

    public func loadAll() -> [T] {
        Array(cache.values)
    }

    // MARK: - 私有方法

    private func persistToFile() throws {
        let data = try JSONEncoder().encode(Array(cache.values))
        try data.write(to: fileURL, options: .atomic)
    }

    private static func loadSynchronously(from url: URL) -> [String: T] {
        guard let data = try? Data(contentsOf: url),
              let items = try? JSONDecoder().decode([T].self, from: data) else {
            return [:]
        }
        return Dictionary(uniqueKeysWithValues: items.map { ($0.id, $0) })
    }
}

使用方法

由于actor隔离，所有调用自动变为异步：

let repository = LocalRepository<Question>()

// 读取——从内存缓存快速O(1)查找
let question = await repository.find(by: "q-001")
let allQuestions = await repository.loadAll()

// 写入——更新缓存并以原子方式持久化到文件
try await repository.save(newQuestion)
try await repository.delete("q-001")

与@Observable ViewModel结合使用

@Observable
final class QuestionListViewModel {
    private(set) var questions: [Question] = []
    private let repository: LocalRepository<Question>

    init(repository: LocalRepository<Question> = LocalRepository()) {
        self.repository = repository
    }

    func load() async {
        questions = await repository.loadAll()
    }

    func add(_ question: Question) async throws {
        try await repository.save(question)
        questions = await repository.loadAll()
    }
}

关键设计决策

决策	理由
Actor（非类+锁）	编译器强制的线程安全，无需手动同步
内存缓存+文件持久化	从缓存快速读取，持久化写入磁盘
初始化期间同步加载	避免异步初始化的复杂性
按ID键控的字典	通过标识符进行O(1)查找
泛型支持`Codable & Identifiable`	可在任何模型类型中重用
原子文件写入（`.atomic`）	防止崩溃时部分写入

最佳实践

对跨越actor边界的所有数据使用Sendable类型
保持actor的公共API最小化——仅公开领域操作，而非持久化细节
使用.atomic写入以防止应用在写入中途崩溃时数据损坏
在init中同步加载——异步初始化器为本地文件增加了复杂性而收益甚微
与@Observable ViewModels结合以实现响应式UI更新

应避免的反模式

在新Swift并发代码中使用DispatchQueue或NSLock而非actors
将内部缓存字典暴露给外部调用者
在不验证的情况下使文件URL可配置
忘记所有actor方法调用都是await——调用者必须处理异步上下文
使用nonisolated绕过actor隔离（违背初衷）

适用场景

iOS/macOS应用中的本地数据存储（用户数据、设置、缓存内容）
稍后同步到服务器的离线优先架构
应用多个部分并发访问的任何共享可变状态
用现代Swift并发替换基于DispatchQueue的遗留线程安全代码