Swift學習之常用的GCD

一紫新、GCD常用的隊列和函數(shù)

  • 串行隊列: 讓任務一個接著一個執(zhí)行(一個任務)
    let serialQue = DispatchQueue(label: “”)

  • 并發(fā)隊列: 可以讓多個任務并發(fā)同時執(zhí)行(自動開啟多個線程)达箍,但需注意的是并發(fā)功能只有在.async函數(shù)才有效废酷。let concurrenceQueue = DispatchQueue(label: "", qos: .default, attributes: DispatchQueue.Attributes.concurrent)

  • 全局并行隊列 : let globalQueue = DispatchQueue.global()

  • 主隊列: let mainQueUe = DispatchQueue.main

   異步的方式執(zhí)行任務
   serialQue.async {}
        
   同步的方式執(zhí)行任務
   serialQue.sync { }
截屏2021-10-19 上午10.14.53.png

使用sync函數(shù)往當前串行隊列中添加任務栅屏,會卡住當前的串行隊列(產(chǎn)生死鎖)常見下面2個例子。

例子1:

        let serialQue = DispatchQueue(label: “”)
        serialQue.sync {
            serialQue.sync{
                 print("同步任務”)
            }
        }

例子2:

import UIKit

class ViewController: UIViewController {

    override func viewDidLoad() {
        super.viewDidLoad()
        // Do any additional setup after loading the view.
        
        DispatchQueue.main.sync {
    
            print("同步任務")
        }
    }
}

二、DispatchWorkItem

DispatchWorkItem 到底是個什么呢?通俗的來說犬金,DispatchWorkItem 就是 GCD 里面常說的一段待執(zhí)行的任務,更直白一點,它本質(zhì)只是一個等待執(zhí)行的代碼塊而已晚顷,可以在任意一個隊列上被調(diào)用峰伙。

   let workItem = DispatchWorkItem {
            print("執(zhí)行任務一")
        }
        
        DispatchQueue.global().async(execute: workItem)

        workItem.notify(queue: DispatchQueue.main) {
            print("任務執(zhí)行完回到主隊列刷新UI")
        }
    workItem.cancel()
  • workItem的閉包里面是封裝的任務
  • notify是執(zhí)行完任務在某個隊列做一些事情,這里直接回歸到主隊列该默。
  • cancel取消任務

三瞳氓、延遲執(zhí)行

  let workItem = DispatchWorkItem {
            print("延遲10s執(zhí)行任務")
        }
       
   DispatchQueue.global().asyncAfter(deadline: DispatchTime.now()+10, execute: workItem)

  DispatchQueue.global().asyncAfter(deadline: DispatchTime.now()+3) {
            print("延遲3s執(zhí)行任務")
      }

四、柵欄函數(shù)

 let concurrenceQueue = DispatchQueue(label: "", qos: .default, attributes: DispatchQueue.Attributes.concurrent)
        concurrenceQueue.async {
            sleep(10)
            print("任務一")
        }
        concurrenceQueue.async {
            sleep(20)
            print("任務二")
        
        }
        
        concurrenceQueue.async(flags: .barrier) {
            print("柵欄任務結(jié)束")
        }
        
        concurrenceQueue.async {
            print("任務三")
        }

這個例子就是任務一栓袖、任務二顿膨、任務三的任務中添加了柵欄,會導致任務三被隔離叽赊,任務、任務二任務完成之后才會去執(zhí)行任務三

五必搞、隊列組

        let concurrenceQueue = DispatchQueue(label: "", qos: .default, attributes: DispatchQueue.Attributes.concurrent)
        let group = DispatchGroup()
        group.enter()
        group.enter()
        concurrenceQueue.async(group: group) {
            print("任務一")
            group.leave()
        };
        
        concurrenceQueue.async(group: group) {
            print("任務二")
            group.leave()
        };
        
        group.notify(queue: DispatchQueue.main) {
            print("所有任務結(jié)束")
        }

六必指、信號量

1、控制線程的最大并發(fā)數(shù)量

class ViewController: UIViewController {
    var semaphore:DispatchSemaphore?

    override func viewDidLoad() {
        super.viewDidLoad()
       
        semaphore = DispatchSemaphore(value: 3)
        
        for  _ in 0...10 {
            let thread = Thread(target: self, selector: #selector(test), object: nil)
            thread.start()
        }
    }

  @objc  func test(){
        semaphore?.wait()
         sleep(10)
        print("測試")
        semaphore?.signal()
    }

}

2恕洲、保證線程安全(控制線程的最大并發(fā)數(shù)量為1)

class ViewController: UIViewController {
    var semaphore:DispatchSemaphore?
    var array:[Any] = Array()
    override func viewDidLoad() {
        super.viewDidLoad()
       
       semaphore = DispatchSemaphore(value: 1)
        
        for  _ in 0...10000 {
            let thread = Thread(target: self, selector: #selector(test), object: nil)
            thread.start()
        }
    }

  @objc  func test(){
      semaphore?.wait()
      array.append(2)
      print("測試")
      semaphore?.signal()
    }
}

3塔橡、線程同步

    var semaphore:DispatchSemaphore?
    var array:[Any] = Array()
    override func viewDidLoad() {
        super.viewDidLoad()
       
       semaphore = DispatchSemaphore(value: 0)
        self.request1()
        semaphore?.wait()
        self.request2()
 }

    func request1(){
        
        DispatchQueue.global().asyncAfter(deadline: DispatchTime.now() + Double.random(in: 0...5)
        ) {
        
                self.semaphore?.signal()
               print("request1")
            }
        }
    func request2(){
        
        DispatchQueue.global().asyncAfter(deadline: DispatchTime.now() +  Double.random(in: 0...5)
          ) {

                print("request2")
        }
       }
    }

這樣就保證了request1執(zhí)行完后才能執(zhí)行request2

4、多線程依賴

假如request1霜第、request2請求完之后葛家,再請求request3我們就可以這樣

class ViewController: UIViewController {
    var semaphore:DispatchSemaphore?
    var group:DispatchGroup?
    var array:[Any] = Array()
    override func viewDidLoad() {
        super.viewDidLoad()
       
        let group = DispatchGroup()
        self.group = group
  
        
        let semophore = DispatchSemaphore.init(value: 0)
        self.semaphore = semophore
        
        let queue = DispatchQueue.global()
  
        queue.async(group: group, execute: {
            self.request1()
            semophore.wait()
        })
        queue.async(group: group, execute: {
            self.request2()
            semophore.wait()
        })
        
        group.notify(queue: queue) {
            self.request3()
        }

 }

    func request1(){
        
        DispatchQueue.global().asyncAfter(deadline: DispatchTime.now() + Double.random(in: 0...5)
        ) {
        
            DispatchQueue.main.async {
                self.semaphore?.signal()
                print("request1")
            }
          }
        }
    func request2(){
        
        DispatchQueue.global().asyncAfter(deadline: DispatchTime.now() +  Double.random(in: 0...5)
          ) {
                
            DispatchQueue.main.async {
                self.semaphore?.signal()
                print("request2")
            }
        }
       }
    
    func request3(){
        
        DispatchQueue.global().asyncAfter(deadline: DispatchTime.now() +  Double.random(in: 0...5)
          ) {
                
            DispatchQueue.main.async {
                print("request3")
            }
        }
       }

    }

或者這樣

class ViewController: UIViewController {
    var semaphore:DispatchSemaphore?
    var group:DispatchGroup?
    var array:[Any] = Array()
    override func viewDidLoad() {
        super.viewDidLoad()
       
        let group = DispatchGroup()
        self.group = group
  
        
        let semophore = DispatchSemaphore.init(value: 0)
        self.semaphore = semophore
        
        let queue = DispatchQueue.global()
  
        queue.async(group: group, execute: {
            self.request1()
        })
        queue.async(group: group, execute: {
            self.request2()
        })
        group.notify(queue: queue) {
            semophore.wait()
            semophore.wait()
            self.request3()
        }

 }

    func request1(){
        
        DispatchQueue.global().asyncAfter(deadline: DispatchTime.now() + Double.random(in: 0...5)
        ) {
        
            DispatchQueue.main.async {
                self.semaphore?.signal()
                print("request1")
            }
          }
        }
    func request2(){
        
        DispatchQueue.global().asyncAfter(deadline: DispatchTime.now() +  Double.random(in: 0...5)
          ) {
                
            DispatchQueue.main.async {
                self.semaphore?.signal()
                print("request2")
            }
        }
       }
    
    func request3(){
        
        DispatchQueue.global().asyncAfter(deadline: DispatchTime.now() +  Double.random(in: 0...5)
          ) {
                
            DispatchQueue.main.async {
                print("request3")
            }
        }
       }
    }

七、多線程開發(fā)-once

dispatch_once在Swift中已經(jīng)被廢棄泌类,取而代之可以用類型屬性或者全局變量\常量癞谒。

fileprivate let inittask2:Void = {
    print("inittask2")
}()
class Student{
    static let initTask1:Void = {
        print("inittask1")
    }()
}
最后編輯于
?著作權歸作者所有,轉(zhuǎn)載或內(nèi)容合作請聯(lián)系作者
  • 序言:七十年代末,一起剝皮案震驚了整個濱河市刃榨,隨后出現(xiàn)的幾起案子弹砚,更是在濱河造成了極大的恐慌,老刑警劉巖枢希,帶你破解...
    沈念sama閱讀 210,978評論 6 490
  • 序言:濱河連續(xù)發(fā)生了三起死亡事件桌吃,死亡現(xiàn)場離奇詭異,居然都是意外死亡苞轿,警方通過查閱死者的電腦和手機茅诱,發(fā)現(xiàn)死者居然都...
    沈念sama閱讀 89,954評論 2 384
  • 文/潘曉璐 我一進店門,熙熙樓的掌柜王于貴愁眉苦臉地迎上來搬卒,“玉大人瑟俭,你說我怎么就攤上這事⌒憔Γ” “怎么了尔当?”我有些...
    開封第一講書人閱讀 156,623評論 0 345
  • 文/不壞的土叔 我叫張陵,是天一觀的道長。 經(jīng)常有香客問我椭迎,道長锐帜,這世上最難降的妖魔是什么? 我笑而不...
    開封第一講書人閱讀 56,324評論 1 282
  • 正文 為了忘掉前任畜号,我火速辦了婚禮缴阎,結(jié)果婚禮上,老公的妹妹穿的比我還像新娘简软。我一直安慰自己蛮拔,他們只是感情好,可當我...
    茶點故事閱讀 65,390評論 5 384
  • 文/花漫 我一把揭開白布痹升。 她就那樣靜靜地躺著建炫,像睡著了一般。 火紅的嫁衣襯著肌膚如雪疼蛾。 梳的紋絲不亂的頭發(fā)上肛跌,一...
    開封第一講書人閱讀 49,741評論 1 289
  • 那天,我揣著相機與錄音察郁,去河邊找鬼衍慎。 笑死,一個胖子當著我的面吹牛皮钠,可吹牛的內(nèi)容都是我干的稳捆。 我是一名探鬼主播,決...
    沈念sama閱讀 38,892評論 3 405
  • 文/蒼蘭香墨 我猛地睜開眼麦轰,長吁一口氣:“原來是場噩夢啊……” “哼乔夯!你這毒婦竟也來了?” 一聲冷哼從身側(cè)響起款侵,我...
    開封第一講書人閱讀 37,655評論 0 266
  • 序言:老撾萬榮一對情侶失蹤驯嘱,失蹤者是張志新(化名)和其女友劉穎,沒想到半個月后喳坠,有當?shù)厝嗽跇淞掷锇l(fā)現(xiàn)了一具尸體鞠评,經(jīng)...
    沈念sama閱讀 44,104評論 1 303
  • 正文 獨居荒郊野嶺守林人離奇死亡,尸身上長有42處帶血的膿包…… 初始之章·張勛 以下內(nèi)容為張勛視角 年9月15日...
    茶點故事閱讀 36,451評論 2 325
  • 正文 我和宋清朗相戀三年壕鹉,在試婚紗的時候發(fā)現(xiàn)自己被綠了剃幌。 大學時的朋友給我發(fā)了我未婚夫和他白月光在一起吃飯的照片。...
    茶點故事閱讀 38,569評論 1 340
  • 序言:一個原本活蹦亂跳的男人離奇死亡晾浴,死狀恐怖负乡,靈堂內(nèi)的尸體忽然破棺而出,到底是詐尸還是另有隱情脊凰,我是刑警寧澤抖棘,帶...
    沈念sama閱讀 34,254評論 4 328
  • 正文 年R本政府宣布茂腥,位于F島的核電站,受9級特大地震影響切省,放射性物質(zhì)發(fā)生泄漏最岗。R本人自食惡果不足惜,卻給世界環(huán)境...
    茶點故事閱讀 39,834評論 3 312
  • 文/蒙蒙 一朝捆、第九天 我趴在偏房一處隱蔽的房頂上張望般渡。 院中可真熱鬧,春花似錦芙盘、人聲如沸驯用。這莊子的主人今日做“春日...
    開封第一講書人閱讀 30,725評論 0 21
  • 文/蒼蘭香墨 我抬頭看了看天上的太陽蝴乔。三九已至,卻和暖如春驮樊,著一層夾襖步出監(jiān)牢的瞬間淘这,已是汗流浹背。 一陣腳步聲響...
    開封第一講書人閱讀 31,950評論 1 264
  • 我被黑心中介騙來泰國打工巩剖, 沒想到剛下飛機就差點兒被人妖公主榨干…… 1. 我叫王不留,地道東北人钠怯。 一個月前我還...
    沈念sama閱讀 46,260評論 2 360
  • 正文 我出身青樓佳魔,卻偏偏與公主長得像,于是被迫代替她去往敵國和親晦炊。 傳聞我的和親對象是個殘疾皇子鞠鲜,可洞房花燭夜當晚...
    茶點故事閱讀 43,446評論 2 348

推薦閱讀更多精彩內(nèi)容