Swift非结构化任务随机未执行问题求助

你遇到的问题是在<AsyncOperation>子类中，API回调后创建的非结构化Task随机不执行——能打印"starting unstructured task"，但"in unstructured task"不输出。核心原因是Task的生命周期没有和AsyncOperation实例绑定，导致操作实例被提前释放时，Task被系统取消或销毁。

具体来说：

• AsyncOperation完成后（调用finish()）会被操作队列回收释放，如果Task还没来得及调度执行，或者执行过程中操作实例被释放，Task会因为失去上下文而终止。
• 虽然你在回调里用了[weak self]，但Task本身没有被任何对象强引用，当操作实例被释放时，Task可能被系统自动取消。

解决方案 #

1. 给Task添加强引用，绑定到AsyncOperation生命周期 #

在你的<AsyncOperation>子类中添加一个属性持有Task，确保Task完成前操作实例不会被释放：

class YourAsyncOperation: AsyncOperation {
    // 添加属性存储Task引用
    private var storageTask: Task<Void, Never>?
    
    func fetchUpdatedObjectsFromServer(completion: @escaping ((Bool)->())) {
        self.apiService().fetchUpdatedObjects(withIds: self.objIds) { [weak self] err, responseObj in
            guard let self = self else { return }
            
            if let _error = err {
                print(_error)
                completion(false)
            } else {
                print("starting unstructured task")
                // 将Task赋值给实例属性，保持强引用
                self.storageTask = Task {
                    print("in unstructured task")
                    await self.storeObjectsInDB()
                    completion(true)
                    // Task完成后释放引用
                    self.storageTask = nil
                }
            }
        }
    }
    
    // 其他代码...
}

2. 确保AsyncOperation的状态正确实现 #

自定义AsyncOperation必须严格遵循KVO规范更新isExecuting和isFinished属性，否则操作队列可能错误地认为操作已完成，提前释放实例。示例实现：

class AsyncOperation: Operation {
    private var _isExecuting = false
    override var isExecuting: Bool {
        get { _isExecuting }
        set {
            willChangeValue(forKey: "isExecuting")
            _isExecuting = newValue
            didChangeValue(forKey: "isExecuting")
        }
    }
    
    private var _isFinished = false
    override var isFinished: Bool {
        get { _isFinished }
        set {
            willChangeValue(forKey: "isFinished")
            _isFinished = newValue
            didChangeValue(forKey: "isFinished")
        }
    }
    
    override var isAsynchronous: Bool { true }
    
    override func start() {
        if isCancelled {
            isFinished = true
            return
        }
        isExecuting = true
        main()
    }
    
    func finish() {
        isExecuting = false
        isFinished = true
    }
}

3. 处理Task内的异常情况 #

如果storeObjectsInDB()可能抛出异常，建议添加错误处理，避免Task因错误终止而未调用completion(true)，导致操作无法正常finish：

self.storageTask = Task {
    print("in unstructured task")
    do {
        try await self.storeObjectsInDB()
        completion(true)
    } catch {
        print("存储数据库失败: \(error)")
        completion(false)
    }
    self.storageTask = nil
}

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