NSProgress 何时移除观察者

Question

NSProgress 是一个有用的类，用于跟踪跨队列的进度。它依赖于观察“fractionCompleted”属性。但是你应该什么时候/如何移除观察者呢？我尝试了dispatch_group和dispatch_barrier，但在所有工作完成之前观察者仍然被删除。

这是我到目前为止的代码。

override func observeValueForKeyPath(keyPath: String!,
    ofObject object: AnyObject!,
    change: [NSObject : AnyObject]!,
    context: UnsafeMutablePointer<Void>)
{
    if keyPath == "fractionCompleted"
    {
        progressBar.doubleValue = (object as NSProgress).fractionCompleted
        println((object as NSProgress).localizedDescription)
    }
    else
    {
        super.observeValueForKeyPath(keyPath, ofObject: object, change: change, context: context)
    }
}


var overallProgress : NSProgress?
@IBAction func start(sender: AnyObject)
{
    overallProgress = NSProgress(totalUnitCount: 100)
    overallProgress?.cancellable = true
    overallProgress?.cancellationHandler = {() -> () in
        println("cancelled")
    }
    overallProgress?.addObserver(self,
        forKeyPath: "fractionCompleted",
        options: (.Initial | .New),
        context: nil)

    var dispatchGroup = dispatch_group_create()

    dispatch_group_async(dispatchGroup, dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0)) {


    //dispatch_async(dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0)) 

  { [unowned self] in

        if !(self.overallProgress?.cancelled ?? false)
        {
            self.overallProgress?.becomeCurrentWithPendingUnitCount(50)
            self.doWork(2)
            self.overallProgress?.resignCurrent()
        }

        if !(self.overallProgress?.cancelled ?? false)
        {
            self.overallProgress?.becomeCurrentWithPendingUnitCount(50)
            self.doWork(1)
            self.overallProgress?.resignCurrent()
        }

    }

    dispatch_group_notify(dispatchGroup, dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0)){
        dispatch_async(dispatch_get_main_queue()) {
            println("remove")
            self.overallProgress?.removeObserver(self, forKeyPath: "fractionCompleted")
        }
    }

  //    dispatch_barrier_async(dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0)) {
 //dispatch_async(dispatch_get_main_queue()) {
 //println("remove")
 //self.overallProgress?.removeObserver(self, forKeyPath: "fractionCompleted")
 //         }
 //     }
}


@IBAction func cancel(sender: AnyObject)
{
    overallProgress?.cancel()
}


func doWork(sleeptime : UInt32)
{
    let privateProgess = NSProgress(totalUnitCount: 5)
    dispatch_async(dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0)) { [unowned self] in
        for index : Int64 in 0...5
        {
            sleep(sleeptime)
            privateProgess.completedUnitCount = index
        }
    }
}

Answer 1

doWork

中的工作与您在

dispatch_group

中调度的工作不在同一个

start

中。如果您希望

dispatch_group_notify

在所有工作完成后发生，那么

doWork

也需要使用

dispatch_group_async

来分派内部工作。否则，对

doWork

的两次调用将立即返回，然后组中唯一的块将完成，导致您的

dispatch_group_notify

块立即执行。最简单的方法可能是向

doWork

添加一个参数以传入

dispatch_group_t

，以便内部工作也可以作为该组的一部分完成。