SwiftUI：按计划在后台更新模型

核心问题修正与实现思路 #

原代码存在三个关键问题：固定间隔无法动态调整、未订阅Timer触发更新、后台线程处理逻辑缺失。以下是符合需求的完整实现：

import Combine
import SwiftUI

// 假设CoolData是自定义数据类型
struct CoolData {
    var value: Int = 0
}

class MyModel: ObservableObject {
    static let shared = MyModel()
    
    @Published var coolData1: CoolData = CoolData()
    @Published var coolData2: CoolData = CoolData()
    @Published var coolData3: CoolData = CoolData()
    
    // 存储订阅，用于取消定时器
    private var timerCancellable: AnyCancellable?
    // 后台队列，用于执行模型更新逻辑
    private let backgroundQueue = DispatchQueue(label: "com.yourapp.modelupdate", qos: .background)
    
    // 根据模型状态动态计算更新间隔（0.5-5秒）
    private var currentUpdateInterval: TimeInterval {
        // 这里替换成你的实际状态判断逻辑，示例用随机值模拟
        return TimeInterval.random(in: 0.5...5)
    }
    
    func runModel() {
        // 先取消已有订阅，避免重复启动
        timerCancellable?.cancel()
        
        // 创建动态间隔的定时器序列
        timerCancellable = Timer.publish(every: currentUpdateInterval, on: .main, in: .common)
            .autoconnect()
            // 每次定时器触发后，切换到后台队列执行更新
            .receive(on: backgroundQueue)
            // 执行模型更新，然后重新生成下一个定时器（动态调整间隔）
            .flatMap { [weak self] _ -> AnyPublisher<Date, Never> in
                guard let self = self else { return Empty().eraseToAnyPublisher() }
                self.updateModel()
                return Timer.publish(every: self.currentUpdateInterval, on: .main, in: .common)
                    .autoconnect()
                    .eraseToAnyPublisher()
            }
            .sink(receiveValue: { _ in })
            .eraseToAnyPublisher()
    }
    
    func pauseModel() {
        timerCancellable?.cancel()
        timerCancellable = nil
    }
    
    private func updateModel() {
        // 在后台执行模型更新逻辑
        let updatedData1 = self.update(coolData1)
        let updatedData2 = self.update(coolData2)
        let updatedData3 = self.update(coolData3)
        
        // 切回主线程更新@Published属性（必须在主线程，否则SwiftUI视图不刷新）
        DispatchQueue.main.async {
            self.coolData1 = updatedData1
            self.coolData2 = updatedData2
            self.coolData3 = updatedData3
        }
    }
    
    // 模拟单个CoolData的更新逻辑
    private func update(_ data: CoolData) -> CoolData {
        var newData = data
        newData.value += 1
        return newData
    }
}

关键细节说明 #

• 动态间隔处理：通过currentUpdateInterval根据模型状态返回0.5-5秒的间隔，每次定时器触发后重新计算下一次间隔，实现动态调整。
• 后台执行更新：用receive(on: backgroundQueue)将更新逻辑切换到后台队列，避免阻塞主线程影响UI响应。
• 主线程更新@Published：@Published属性的变更必须在主线程执行，所以更新后通过DispatchQueue.main.async赋值，确保SwiftUI视图能自动重绘。
• 订阅管理：用AnyCancellable存储定时器订阅，pauseModel()直接取消并置空，实现暂停功能。
• 避免重复启动：runModel()先取消已有订阅，防止多次调用导致多个定时器同时运行。

内容的提问来源于stack exchange，提问作者Productions