【Xcode/SwiftUI】今更だけど、DispatchQueueを復習してみる

// MARK: - 直列キュー（Serial Queue）例
let serialQueue = DispatchQueue(label: "com.taro.serial")

serialQueue.async {
    print("🔥 Task 1")
}
serialQueue.async {
    print("🔥 Task 2")
}
serialQueue.async {
    print("🔥 Task 3")
}

// 出力順番：
// 🔥 Task 1
// 🔥 Task 2
// 🔥 Task 3

// MARK: - 並列キュー（Concurrent Queue）例
// Point: 並列キューでは順番は保証されないけど、複数のタスクが同時に実行されるから処理は速い。
let concurrentQueue = DispatchQueue(label: "com.bigbro.concurrent", attributes: .concurrent)

concurrentQueue.async {
    print("🚀 Task A")
}
concurrentQueue.async {
    print("🚀 Task B")
}
concurrentQueue.async {
    print("🚀 Task C")
}

// 出力順番（例）：
// 🚀 Task B
// 🚀 Task A
// 🚀 Task C
// （順番バラバラになる可能性大）

// MARK: - 同期（sync）の例
// Point: .sync はブロックが終わるまで次の行に進まない。
print("🔹 Start")

DispatchQueue.global().sync {
    print("🔹 Inside sync block")
}

print("🔹 End")

// 実行順：
// 🔹 Start
// 🔹 Inside sync block
// 🔹 End

// MARK: - 非同期（async）の例
// Point: .async は投げっぱなしなので、次の処理がすぐ動く。UI処理では基本こっちを使う。
print("🔸 Start")

DispatchQueue.global().async {
    print("🔸 Inside async block")
}

print("🔸 End")

// 実行順：
// 🔸 Start
// 🔸 End
// 🔸 Inside async block

// ☠️ 注意: メインスレッドで sync すると死ぬ
// NG例：メインスレッドでメインキューにsync
DispatchQueue.main.sync {
    print("❌ これはデッドロックします")
}

DispatchQueue.main.async {
    // ✅ UIの更新はここで
    self.text = "ロード完了！"
}

// SwiftUIなら .task 内でもこれやる必要がある場面ある（例：非同期API→UI反映）。

DispatchQueue.global(qos: .userInitiated).async {
    let result = heavyCalculation()

    DispatchQueue.main.async {
        // ✅ メインスレッドでUI更新
        self.output = result
    }
}

let work = DispatchWorkItem {
    print("🧱 実行された処理")
}

DispatchQueue.global().async(execute: work)

// キャンセル可能
let work = DispatchWorkItem {
    if work.isCancelled {
        print("🙅‍♂️ キャンセルされました")
        return
    }
    print("✅ 実行される処理")
}

DispatchQueue.global().async(execute: work)

// 何かの条件でキャンセル
work.cancel()

// 処理後に通知
let task = DispatchWorkItem {
    print("🔧 重い処理完了")
}

DispatchQueue.global().async(execute: task)

// これで非同期処理→完了→UI更新がキレイに書ける
task.notify(queue: .main) {
    print("🎉 UI更新など通知処理")
}

struct ContentView: View {
    @State private var result: String = "読み込み中..."

    var body: some View {
        VStack {
            Text(result)
                .padding()

            Button("重い処理開始") {
                loadHeavyStuff()
            }
        }
    }

    func loadHeavyStuff() {
        // バックグラウンドで重い処理
        DispatchQueue.global(qos: .userInitiated).async {
            let data = heavyCalculation()

            // メインスレッドでUI更新
            DispatchQueue.main.async {
                result = data
            }
        }
    }

    func heavyCalculation() -> String {
        sleep(2) // 仮に重い処理として2秒待機
        return "処理完了！"
    }
}

Text("読み込み中…")
    .task {
        let result = await loadData()
        text = result
    }

// ❌ UI更新をバックグラウンドスレッドでやってしまう
DispatchQueue.global().async {
    self.text = "更新しちゃうよ"
}

// ✅ 正しいやり方
DispatchQueue.global().async {
    let result = loadStuff()

    DispatchQueue.main.async {
        self.text = result // UIは必ずメインスレッドで！
    }
}

// 見やすい非同期コード
func fetch() async {
    let data = await fetchData()
    let image = await processImage(data)
    await updateUI(image)
}

actor Counter {
    private var count = 0

    func increment() {
        count += 1
    }

    func get() -> Int {
        return count
    }
}

@MainActor
class ViewModel: ObservableObject {
    @Published var message = ""

    func update() {
        Task {
            let result = await fetchMessage()
            message = result // ✅ これはメインスレッド確定
        }
    }
}