Swift Actor Persistence

affaan-m/ECC/docs/ja-JP/skills/swift-actor-persistence

作者 affaan-mef648e01899ba3e8dc6371642deaaf64b4477775无许可证275K 个星标收录于 2026年10月9日更新于 2026年10月9日仓库4天前更新

Swiftでactorを使用してスレッドセーフなデータ永続化を実装する——メモリキャッシュとファイルバックドストレージを組み合わせ、設計によってデータ競合を排除する。

仅含说明Software Development

AI 生成的概览

使用 actor 构建线程安全的 Swift 数据持久化模式，将内存缓存与文件存储相结合。

功能: 该技能介绍一种基于 Swift actor 的仓库模式，用于线程安全的本地持久化。它给出一个通用的 LocalRepository 类型，在内存中维护字典缓存并以原子方式写入 JSON 文件，磁盘写入失败时回滚缓存。内容还包括异步调用方的使用方式、与 @Observable 视图模型的集成，以及设计取舍、最佳实践和反模式。
适用场景: 适用于构建 Swift 5.5 及以上版本的持久化层，并需要对共享可变状态进行线程安全访问的场景。适合 iOS 或 macOS 本地存储、离线优先应用，以及用 Swift 并发替代手动加锁或基于 DispatchQueue 的同步。
运行要求: 需要 Swift 5.5 或更高版本，并支持 actor 模型与 Swift 并发。不包含脚本、依赖包、凭据或网络访问；该技能仅提供说明与代码示例。

スレッドセーフな永続化のための Swift Actor

Swiftのactorを使用してスレッドセーフなデータ永続化レイヤーを構築するパターン。メモリキャッシュとファイルバックドストレージを組み合わせ、actorモデルを活用してコンパイル時にデータ競合を排除する。

起動条件

Swift 5.5以降でデータ永続化レイヤーを構築する場合
共有可変状態へのスレッドセーフアクセスが必要な場合
手動の同期（ロック、DispatchQueue）を排除したい場合
ローカルストレージを持つオフラインファースとアプリを構築する場合

コアパターン

Actorベースのリポジトリ

Actorモデルはシリアライズされたアクセスを保証する——コンパイラによって強制されるデータ競合なし。

swift

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)        // Synchronous load during init (actor isolation not yet active)        self.cache = Self.loadSynchronously(from: fileURL)    }
    // MARK: - Public API
    public func save(_ item: T) throws {        let previous = cache[item.id]        cache[item.id] = item        do {            try persistToFile()        } catch {            // ディスク書き込み失敗時はキャッシュをロールバックして整合性を維持            cache[item.id] = previous            throw error        }    }
    public func delete(_ id: String) throws {        let previous = cache[id]        cache[id] = nil        do {            try persistToFile()        } catch {            // ディスク書き込み失敗時はキャッシュをロールバックして整合性を維持            cache[id] = previous            throw error        }    }
    public func find(by id: String) -> T? {        cache[id]    }
    public func loadAll() -> [T] {        Array(cache.values)    }
    // MARK: - Private
    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) })    }}

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)        // Synchronous load during init (actor isolation not yet active)        self.cache = Self.loadSynchronously(from: fileURL)    }
    // MARK: - Public API
    public func save(_ item: T) throws {        let previous = cache[item.id]        cache[item.id] = item        do {            try persistToFile()        } catch {            // ディスク書き込み失敗時はキャッシュをロールバックして整合性を維持            cache[item.id] = previous            throw error        }    }
    public func delete(_ id: String) throws {        let previous = cache[id]        cache[id] = nil        do {            try persistToFile()        } catch {            // ディスク書き込み失敗時はキャッシュをロールバックして整合性を維持            cache[id] = previous            throw error        }    }
    public func find(by id: String) -> T? {        cache[id]    }
    public func loadAll() -> [T] {        Array(cache.values)    }
    // MARK: - Private
    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の分離により、すべての呼び出しは自動的に非同期になる：

swift

let repository = LocalRepository<Question>()
// Read — fast O(1) lookup from in-memory cachelet question = await repository.find(by: "q-001")let allQuestions = await repository.loadAll()
// Write — updates cache and persists to file atomicallytry await repository.save(newQuestion)try await repository.delete("q-001")

let repository = LocalRepository<Question>()
// Read — fast O(1) lookup from in-memory cachelet question = await repository.find(by: "q-001")let allQuestions = await repository.loadAll()
// Write — updates cache and persists to file atomicallytry await repository.save(newQuestion)try await repository.delete("q-001")

@Observable ViewModel との組み合わせ

swift

@Observablefinal 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()    }}

@Observablefinal 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のパブリックなアビリティを最小化する —— 永続化の詳細ではなく、ドメイン操作のみを公開する
.atomic 書き込みを使用する —— 書き込み中のアプリクラッシュによるデータ破損を防ぐ
init で同期的にロードする —— 非同期イニシャライザはローカルファイルに対するわずかな利点のために複雑さが増す
@Observable ViewModelと組み合わせる —— リアクティブなUI更新を実現する

避けるべきアンチパターン

Swiftの新しい並行処理コードでActorの代わりに DispatchQueue または NSLock を使用する
内部のキャッシュ辞書を外部の呼び出し元に公開する
初期化後にファイルURLを外部から変更可能にする（初期化時のみ設定を許可すること）
すべてのActor メソッド呼び出しが await であることを忘れる——呼び出し元は非同期コンテキストを処理する必要がある
Actor の分離をバイパスするために nonisolated を使用する（本末転倒）

使用場面

iOS/macOSアプリのローカルデータストレージ（ユーザーデータ、設定、キャッシュコンテンツ）
後でサーバーと同期するオフラインファーストアーキテクチャ
アプリの複数の部分から並行アクセスされる共有可変状態
DispatchQueue ベースのレガシーなスレッド安全機構を最新のSwift並行処理に置き換える

来源与署名

来源：affaan-m/ECC位于docs/ja-JP/skills/swift-actor-persistence提交ef648e0

许可证：无许可证

内容归原作者所有。SourceWeft 从公开仓库中收录这些内容。

举报或申请下架

Swift Actor Persistence

スレッドセーフな永続化のための Swift Actor

起動条件

コアパターン

Actorベースのリポジトリ

使い方

@Observable ViewModel との組み合わせ

重要な設計上の決定

ベストプラクティス

避けるべきアンチパターン

使用場面

来源与署名

更多来自 affaan-m/ECC 的技能

Unified Notifications Ops

Verification Loop

Ui To Vue

Unified Memory

Visa Doc Translate

Team Builder

更多Software Development技能

Playground

M5 Onboard

Cardputer Buddy

Web Design Guidelines

Vercel React Native Skills

Vercel React Best Practices