WechatIMG6.jpeg

iOS開發(fā)多線程處理常用GCD，相比NSThread和NSOperation更簡(jiǎn)單 便捷 易懂。Swift語(yǔ)法中對(duì)GCD的API進(jìn)行了精簡(jiǎn)和優(yōu)化 , 所以GCD使用更多城侧。下面對(duì)常用的一些功能學(xué)習(xí)和總結(jié)

Dispatch

**>Dispatch會(huì)自動(dòng)的根據(jù)CPU的使用情況蹦误，創(chuàng)建線程來(lái)執(zhí)行任務(wù)，并且自動(dòng)的運(yùn)行到多核上胚嘲，提高程序的運(yùn)行效率作儿。對(duì)于開發(fā)者來(lái)說(shuō)，在GCD層面是沒(méi)有線程的概念的馋劈，只有隊(duì)列（queue）攻锰、任務(wù)都是以block的方式提交到隊(duì)列上、執(zhí)行方式侣滩，然后GCD會(huì)自動(dòng)的創(chuàng)建線程池去執(zhí)行這些任務(wù)口注。

DispatchQueue

DispatchQueue是一個(gè)類似線程的概念，這里稱作對(duì)列隊(duì)列是一個(gè)FIFO數(shù)據(jù)結(jié)構(gòu)君珠，(意味著先提交到隊(duì)列的任務(wù)會(huì)先開始執(zhí)行) 寝志。DispatchQueue背后是一個(gè)由系統(tǒng)管理的線程池。

let queue = DispatchQueue.init(label: "queue-after")

DispatchQoS

DispatchQoS是服務(wù)質(zhì)量等級(jí)策添，通過(guò)設(shè)置DispatchQueue的QoS材部，您可以指出其重要性，系統(tǒng)會(huì)對(duì)其進(jìn)行優(yōu)先級(jí)排序并相應(yīng)地對(duì)其進(jìn)行調(diào)度唯竹。 由于優(yōu)先級(jí)較高的工作比較低優(yōu)先級(jí)的工作執(zhí)行得更快乐导，資源更多，因此通常比低優(yōu)先級(jí)工作需要更多的能量浸颓。為您的應(yīng)用程序執(zhí)行的工作準(zhǔn)確指定適當(dāng)?shù)?code>QoS類可確保您的應(yīng)用程序具有響應(yīng)性和節(jié)能性物臂。

優(yōu)先級(jí) : userInteractive > userInitiated > default > utility > background > unspecified

   // 設(shè)置隊(duì)列優(yōu)先等級(jí)qos
        let defaultQueue = DispatchQueue.init(label: "QueueQosdefault", qos: .default)
        let initiatedQueue = DispatchQueue.init(label: "QueueInitiated", qos: .userInitiated)

DispatchQueue.Attributes

DispatchQueue.Attributes是隊(duì)列的屬性(結(jié)構(gòu)體)

concurrent 并行的方式運(yùn)行 ，隊(duì)列的所有任務(wù)同時(shí)處理

initiallyInactive 任務(wù)不會(huì)被自動(dòng)執(zhí)行产上，而是需要開發(fā)者手動(dòng)去觸發(fā)

// atrributes 參數(shù)可設(shè)置是數(shù)組 [.initiallyInactive,.concurrent]
let queue = DispatchQueue.init(label: "inactive-Queue", attributes: .initiallyInactive)

DispatchWorkItem

DispatchWorkItem 是一個(gè)代碼塊棵磷，它可以在任意一個(gè)隊(duì)列上被調(diào)用，因此它里面的代碼可以在后臺(tái)運(yùn)行晋涣，也可以在主線程運(yùn)行仪媒。

  //MARK: DispatchWorkItem 派遣工作項(xiàng)目
    func useWorkItem() {
        var value = 10
        // 創(chuàng)建任務(wù)代碼塊
        let workItem = DispatchWorkItem {
            value += 5
        }
        // workItem.perform() 執(zhí)行任務(wù)代碼塊
        let queue = DispatchQueue.global(qos: .utility)
        // 將任務(wù)派發(fā)到隊(duì)列處理
        queue.async(execute: workItem)
        // 給任務(wù)對(duì)象添加通知
        workItem.notify(queue: DispatchQueue.main) {
            print("value = ", value)
        }
}

DispatchSource

DispatchSource 提供了一個(gè)接口，用于監(jiān)視低級(jí)系統(tǒng)對(duì)象谢鹊，如Mach端口算吩，Unix描述符，Unix信號(hào)和VFS節(jié)點(diǎn)佃扼，用于活動(dòng)和提交事件處理程序偎巢，以便在發(fā)生此類活動(dòng)時(shí)調(diào)度隊(duì)列以進(jìn)行異步處理。

DispatchSourceProtocol 基礎(chǔ)協(xié)議兼耀，所有的用到的DispatchSource都實(shí)現(xiàn)了這個(gè)協(xié)議压昼。 幾個(gè)共有的協(xié)議的方法:

activate //激活

suspend //掛起

resume //繼續(xù)

cancel //取消(異步的取消挎扰，會(huì)保證當(dāng)前eventHander執(zhí)行完)

setEventHandler //事件處理邏輯

setCancelHandler //取消時(shí)候的清理邏輯

// 工廠模式 生成不同的Source類型
let timer = DispatchSource.makeTimerSource()

DispatchGroup

DispatchGroup用來(lái)管理一組任務(wù)的執(zhí)行，然后監(jiān)聽(tīng)任務(wù)都完成的事件巢音。(可以使用它提交多個(gè)不同的工作項(xiàng)并跟蹤它們何時(shí)完成遵倦，即使它們可能在不同的隊(duì)列上運(yùn)行。)

enter() 添加事件記錄

leave() 完結(jié)事件記錄

wait() 等待之前提交的任務(wù)完成 返回DispatchTimeoutResult處理結(jié)果(完成 超時(shí))

添加和完結(jié)的記錄相等才會(huì)調(diào)用notify通知方法

注意：?jiǎn)为?dú)enter()添加事件記錄不會(huì)報(bào)錯(cuò)官撼。單獨(dú)leave() 會(huì)報(bào)錯(cuò)梧躺。

 let group = DispatchGroup.init()

        group.enter()
        self.networkTask(parameter: "第一個(gè)請(qǐng)求", costTime: 2) {
            group.leave()
            print("request complate , groud leave \(Date())")
        }

        group.enter()
        self.networkTask(parameter: "第二個(gè)請(qǐng)求", costTime: 4) {
            group.leave()
            print("request complate , groud leave \(Date())")
}

DispatchSemaphore

DispatchSemaphore是通過(guò)信號(hào)量來(lái)控制多個(gè)任務(wù)執(zhí)行對(duì)資源的訪問(wèn)。

 //MARK: 信號(hào)量記錄隊(duì)列任務(wù)
    func dispatchSemaphoreTest(){
        // 設(shè)置信號(hào)量個(gè)數(shù)
        let semaphore = DispatchSemaphore(value: 2)
        let queue = DispatchQueue(label: "dispatchSemaphoreQueue", qos: .default, attributes: .concurrent)

        queue.async {
            semaphore.wait()
            self.testTask(parameter: "1", costTime: 2, complate: {
                semaphore.signal()
            })
        }

        queue.async {
            semaphore.wait()
            self.testTask(parameter: "2", costTime: 2, complate: {
                semaphore.signal()
            })
        }
        // 當(dāng)前型號(hào)量數(shù)是2  任務(wù)數(shù)大于2 需要等之前任務(wù)結(jié)束 信號(hào)量消費(fèi)完 執(zhí)行新的任務(wù)
        queue.async {
            semaphore.wait()
            self.testTask(parameter: "3", costTime: 1, complate: {
                semaphore.signal()
            })
        }
}

DispatchWorkItemFlags barrier

DispatchWorkItemFlags是一個(gè)選項(xiàng)集傲绣，用于配置隊(duì)列的任務(wù)執(zhí)行行為掠哥，包括其服務(wù)質(zhì)量類以及是創(chuàng)建障礙還是生成新的分離線程。

barrier 是設(shè)置柵欄攔截秃诵， 出現(xiàn)攔截時(shí)需要處理完之前的任務(wù), 才能執(zhí)行新的任務(wù)续搀。

  //MARK: 添加barrier 任務(wù)隊(duì)列柵欄處理
    //DispatchWorkItemFlags是一個(gè)選項(xiàng)集
    func addDispatchWorkItemFlagsTest(){
        let concurrentQueue = DispatchQueue(label: "dispatchWorkItemFlags", attributes: .concurrent)
        concurrentQueue.async {
            self.readDataTask(parameter: "3", costTime: 3)
        }

        concurrentQueue.async {
            self.readDataTask(parameter: "3", costTime: 3)
        }
        concurrentQueue.async(flags: .barrier, execute: {
            NSLog("Task from barrier 1 begin")
            sleep(3)
            NSLog("Task from barrier 1 end")
        })

        concurrentQueue.async {
            self.readDataTask(parameter: "3", costTime: 3)
        }
}

demo地址

詳盡總結(jié)