使用Concurrent Dispatch Group进行线程安全读/写阵列访问[重复]

Posted

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了使用Concurrent Dispatch Group进行线程安全读/写阵列访问[重复]相关的知识,希望对你有一定的参考价值。

这个问题在这里已有答案:

我正在开发一个照片编辑应用程序。我正在为我的用户提供将多个资源导入编辑View Controller的选项。我正在为所有“PHAsset-> Asset fetching”调用创建一个Dispatch Group。 每次调用PHAsset获取请求完成块时,我需要将获取的资产append放入Mutable Array,并按导入资产的数量更新UI(1/3导入| 2/3导入等)。 因为Swift Mutable Arrays不是线程安全的,有时我会崩溃。我想完成处理程序从多个线程调用,导致某种死锁。

使用Concurrent Dispatch Group处理线程安全读/写阵列访问的正确方法是什么?

var assets = [Asset]()

func getAssetsFromPHAssets() {

    let dispatchGroup: DispatchGroup = DispatchGroup()

    for phAsset in phAssets {

        dispatchGroup.enter() // Enter group for each asset

        PHImageManager.default().requestPlayerItem(forVideo: phAsset, options: nil, resultHandler: { (item, info) in

            let asset = Asset(playerItem: item, position: 0)
            self.assets.append(asset)

            DispatchQueue.main.async {
                self.lblImport.text = "Importing (self.assets.count)/3"
            }

            dispatchGroup.leave() // Leave group
        })
    }

    dispatchGroup.notify(queue: DispatchQueue.main, execute: {
            print("finished importing")
        })
}
答案

我建议在主线程中添加新资产:

let asset = Asset(playerItem: item, position: 0)

DispatchQueue.main.async {
    self.assets.append(asset)
    self.lblImport.text = "Importing (self.assets.count)/3"
}

也许 - 但这取决于你在notify关闭中做了什么 - 你还应该将dispatchGroup.leave()调用移动到主队列中。

以上是关于使用Concurrent Dispatch Group进行线程安全读/写阵列访问[重复]的主要内容,如果未能解决你的问题,请参考以下文章

GCD

GCD dispatch_apply基本使用

dispatch_barrier_async

dispatch_queue_create、dispatch_retain、dispatch_release函数的使用

OC 线程操作 - GCD队列组

多线程CGD调度组原理