Swift Concurrencyでのスケジュール処理を考える / Mobile Act OSAKA 17

Mobile Act OSAKA 17
https://mobileact.connpass.com/event/374447/

1. Swift Concurrencyでの スケジュール処理を考える id:yutailang0119 / @yutailang0119 2025/11/28 Mobile Act Osaka 17 1
2. yutailang0119 • 株式会社はてな ◦ @京都オフィス ◦ アプリケーションエンジニア ◦ サービスプラットフォームチーム • try! Swift Tokyo Organizer ◦ 2026チケット販売中 • AVP座談会 🥽 2
3. 3 Swift Concurrencyの スケジュール処理といえば？
4. 4 https://zenn.dev/treastrain/articles/a78b5f892f4654
5. 🔁 Swift Concurrency 時代の 「n秒ごとに処理を実行する」 • AsyncTimerSequence • AsyncStream + Task.sleep • ... 5
6. 6 「n秒ごとに処理を実行する」 = タスク開始時点で 全ての時機が決まっている
7. 7 今回のお題
8. 今回のお題 8 • タスク⓪後、タスク ①の時機が決まる ◦ タスク①の実行を予約 • タスク①後、タスク ②の時機が決まる ◦ 処理②の実行を予約 • …
9. 9 https://fortee.jp/iosdc-japan-2025/proposal/292e2ec3-d74b-49a6-a8cb-63c2883d589e
10. Smart Device Management API 10 • WebRTCセッションの確立 ◦ sdm.devices.commands.CameraLiveStream.GenerateWebRtcStream ◦ ライブストリームのセッション有効期間は5分 ◦ レスポンスに expiresAt がやってくる • セッションを延長可能 ◦ sdm.devices.commands.CameraLiveStream.ExtendWebRtcStream
11. Smart Device Management API 11 • WebRTCセッションの確立 ◦ sdm.devices.commands.CameraLiveStream.GenerateWebRtcStream ◦ ライブストリームのセッション有効期間は5分 ◦ レスポンスに expiresAt がやってくる • セッションを延長可能 ◦ sdm.devices.commands.CameraLiveStream.ExtendWebRtcStream
12. 今回のお題 12 • セッション確立後、延長タスク ①の時機が決まる ◦ 延長処理①の実行を予約 • 延長処理①後、延長タスク ②の時機が決まる ◦ 延長処理②の実行を予約 • …
13. 13 今回のお題 「Task終了時に次Taskを予約」
14. 14 TaskScheduler
15. TaskScheduler 15 actor TaskScheduler { private let task: Task<Void, Error> init(first: Date?) { task = Task { var _next = first while let next = _next { let interval = max(0, next.timeIntervalSinceNow) try await Task.sleep(nanoseconds: UInt64(interval * 1_000_000_000)) try Task.checkCancellation() ... let response = try await client.request(for: request) _next = response.results.expiresAt } } } }
16. TaskScheduler (汎用化) 16 actor TaskScheduler { private let task: Task<Void, Error> init(first: Date?, action: @escaping @Sendable () async throws -> Date?) { task = Task { var _next = first while let next = _next { let interval = max(0, next.timeIntervalSinceNow) try await Task.sleep(nanoseconds: UInt64(interval * 1_000_000_000)) try Task.checkCancellation() _next = try await action() } } } }
17. TaskScheduler 17 • Task内部キャンセルはErrorで表現 • 外からのキャンセルも可能にする ◦ task.cancel() ◦ セッションを止めたら、延長予約もキャンセル • 実際には expiresAt に実行では遅い ◦ expiresAt?.addingTimeInterval(-60)
18. 18 まとめ
19. まとめ 19 • スケジューリング用途によって手法は異なる ◦ タスク開始時点で全ての時機が決まっている ◦ 処理後に次のタスク実行タイミングが決まる • Swift ConcurrencyでのScheduler (Worker) 処理を紹介