美文网首页
多线程之1-GCD(DispatchQueue)

多线程之1-GCD(DispatchQueue)

作者: 栋柠柒 | 来源:发表于2021-11-21 15:26 被阅读0次

GCD的特点

GCD会自动利用更多的CPU内核

GCD自动管理线程的生命周期(创建线程,调度任务,销毁线程等)

只需要告诉 GCD 想要如何执行什么任务,不需要编写任何线程管理代码

1.GCD 相关概念

任务(block):就是需要执行的代码块,以block 的方式呈现。
同步(sync): 在当前线程中执行,会阻塞当前线程,不会开启新的线程,所以只能一次执行一个任务,前一个任务执行完毕,当前线程才会执行后一个任务
异步(async):不阻塞当前线程,由GCD 决定是否开启新的线程
队列(queue):装载待执行任务的一种队形结构,和排队上车一样,先进先出。GCD 中有两种队列结构:串行队列和并发队列。
串行队列(serialQueue):队列中的任务只能按顺序依次执行。
并发队列(conCurrentQueue):队列中的任务可以多个同时执行,在async 下是真正的并发,在sync 下依然是串行,因为只有一条线程可用。
GCD是将要执行的代码加入队列中(串行队列或并发队列),然后指定运行方式(同步执行或异步执行)

2.创建队列

GCD 需要把代码块放到队列中,队列又分串行队列和并发队列。
第一个参数 label 是队列的标识符,可以为空,第二个attributes 是表示串行或者并发队列。默认为串行队列,.concurren 表示并发队列。

// 串行队列
 let serialQueue = DispatchQueue(label: "dispatchSeralQueue")
//并发队列
 let conCurrentQueue = DispatchQueue(label: "dispatchConcurrentQueue", attributes: .concurrent)

除了自定义的队列,系统还我们提供了两个队列
主队列,主队列是一个并发队列。

DispatchQueue.main.async {
            
}

全局队列,是一个并发队列

 DispatchQueue.global().async {
            
 }

3.GCD使用

队列和同步异步之间有多种组合方式
1.串行同步
2.串行异步
3.并发同步
4.并发异步
5.主队列同步
6.主队列异步

  • 串行同步
let seralQueue = DispatchQueue(label: "dispatchSeralQueue")
        seralQueue.sync {
            for i in 0...3 {
                debugPrint("queueTest seralQueue1: \(Thread.current), \(i)")
            }
        }
        seralQueue.sync {
            for i in 0...3 {
                debugPrint("queueTest seralQueue2: \(Thread.current), \(i)")
            }
        }
"queueTest seralQueue1: <_NSMainThread: 0x600003db08c0>{number = 1, name = main}, 0"
"queueTest seralQueue1: <_NSMainThread: 0x600003db08c0>{number = 1, name = main}, 1"
"queueTest seralQueue1: <_NSMainThread: 0x600003db08c0>{number = 1, name = main}, 2"
"queueTest seralQueue1: <_NSMainThread: 0x600003db08c0>{number = 1, name = main}, 3"
"queueTest seralQueue2: <_NSMainThread: 0x600003db08c0>{number = 1, name = main}, 0"
"queueTest seralQueue2: <_NSMainThread: 0x600003db08c0>{number = 1, name = main}, 1"
"queueTest seralQueue2: <_NSMainThread: 0x600003db08c0>{number = 1, name = main}, 2"
"queueTest seralQueue2: <_NSMainThread: 0x600003db08c0>{number = 1, name = main}, 3"

结果,顺序执行,都在主线程

  • 串行异步
let seralQueue = DispatchQueue(label: "dispatchSeralQueue")
        seralQueue.async {
            for i in 0...3 {
                debugPrint("queueTest seralQueue1: \(Thread.current), \(i)")
            }
        }
        seralQueue.async {
            for i in 0...3 {
                debugPrint("queueTest seralQueue2: \(Thread.current), \(i)")
            }
        }
"queueTest seralQueue1: <NSThread: 0x6000030d2c40>{number = 6, name = (null)}, 0"
"queueTest seralQueue1: <NSThread: 0x6000030d2c40>{number = 6, name = (null)}, 1"
"queueTest seralQueue1: <NSThread: 0x6000030d2c40>{number = 6, name = (null)}, 2"
"queueTest seralQueue1: <NSThread: 0x6000030d2c40>{number = 6, name = (null)}, 3"
"queueTest seralQueue2: <NSThread: 0x6000030d2c40>{number = 6, name = (null)}, 0"
"queueTest seralQueue2: <NSThread: 0x6000030d2c40>{number = 6, name = (null)}, 1"
"queueTest seralQueue2: <NSThread: 0x6000030d2c40>{number = 6, name = (null)}, 2"
"queueTest seralQueue2: <NSThread: 0x6000030d2c40>{number = 6, name = (null)}, 3"

结果不在主线程,但是依然是顺序执行

  • 并发同步
let conCurrentQueue = DispatchQueue(label: "dispatchConcurrentQueue", attributes: .concurrent)
        conCurrentQueue.sync {
            for i in 0...3 {
                debugPrint("queueTest conCurrentQueue1: \(Thread.current), \(i)")
            }
        }
        conCurrentQueue.sync {
            for i in 0...3 {
                debugPrint("queueTest conCurrentQueue2: \(Thread.current), \(i)")
            }
        }
"queueTest conCurrentQueue1: <_NSMainThread: 0x600000648380>{number = 1, name = main}, 0"
"queueTest conCurrentQueue1: <_NSMainThread: 0x600000648380>{number = 1, name = main}, 1"
"queueTest conCurrentQueue1: <_NSMainThread: 0x600000648380>{number = 1, name = main}, 2"
"queueTest conCurrentQueue1: <_NSMainThread: 0x600000648380>{number = 1, name = main}, 3"
"queueTest conCurrentQueue2: <_NSMainThread: 0x600000648380>{number = 1, name = main}, 0"
"queueTest conCurrentQueue2: <_NSMainThread: 0x600000648380>{number = 1, name = main}, 1"
"queueTest conCurrentQueue2: <_NSMainThread: 0x600000648380>{number = 1, name = main}, 2"
"queueTest conCurrentQueue2: <_NSMainThread: 0x600000648380>{number = 1, name = main}, 3"

在主线程,顺序执行

  • 并发异步
let conCurrentQueue = DispatchQueue(label: "dispatchConcurrentQueue", attributes: .concurrent)
        conCurrentQueue.async {
            for i in 0...3 {
                debugPrint("queueTest conCurrentQueue1: \(Thread.current), \(i)")
            }
        }
        conCurrentQueue.async {
            for i in 0...3 {
                debugPrint("queueTest conCurrentQueue2: \(Thread.current), \(i)")
            }
        }
"queueTest conCurrentQueue2: <NSThread: 0x600003bf2900>{number = 4, name = (null)}, 0"
"queueTest conCurrentQueue1: <NSThread: 0x600003b98240>{number = 6, name = (null)}, 0"
"queueTest conCurrentQueue2: <NSThread: 0x600003bf2900>{number = 4, name = (null)}, 1"
"queueTest conCurrentQueue1: <NSThread: 0x600003b98240>{number = 6, name = (null)}, 1"
"queueTest conCurrentQueue2: <NSThread: 0x600003bf2900>{number = 4, name = (null)}, 2"
"queueTest conCurrentQueue1: <NSThread: 0x600003b98240>{number = 6, name = (null)}, 2"
"queueTest conCurrentQueue2: <NSThread: 0x600003bf2900>{number = 4, name = (null)}, 3"
"queueTest conCurrentQueue1: <NSThread: 0x600003b98240>{number = 6, name = (null)}, 3"

任务同时进行,开启多个线程。

 DispatchQueue.global().async {
            // 模拟耗时操作
            Thread.sleep(forTimeInterval: 10)
            DispatchQueue.main.async {
                // 在主队列插入一个任务更新UI
            }
        }

-GCD 栅栏函数
当任务需要异步进行,但是这些任务需要分成两组来执行,第一组完成之后才能进行第二组的操作。这时候就用了到GCD的栅栏方法:

let dispathGroup = DispatchGroup()
        let dispatchConcurrentQueue = DispatchQueue(label: "dispatchConcurrentQueue", attributes: .concurrent)
        dispatchConcurrentQueue.async {
            for i in 0...3 {
                debugPrint("dispatchConcurrentQueue action1 \(i) at \(Thread.current)")
            }
            
        }
        dispatchConcurrentQueue.async {
            for i in 0...3 {
                debugPrint("dispatchConcurrentQueue action2 \(i) at \(Thread.current)")
            }
            
        }
        dispatchConcurrentQueue.async(group: dispathGroup, qos: .default, flags: .barrier) {
            debugPrint("dispatchConcurrentQueue barrier")
        }
        dispatchConcurrentQueue.async {
            for i in 0...3 {
                debugPrint("dispatchConcurrentQueue action3 \(i) at \(Thread.current)")
            }
            
        }
        dispatchConcurrentQueue.async {
            for i in 0...3 {
                debugPrint("dispatchConcurrentQueue action4 \(i) at \(Thread.current)")
            }
            
        }
"dispatchConcurrentQueue action2 0 at <NSThread: 0x6000002ab200>{number = 7, name = (null)}"
"dispatchConcurrentQueue action1 0 at <NSThread: 0x6000002aa580>{number = 4, name = (null)}"
"dispatchConcurrentQueue action2 1 at <NSThread: 0x6000002ab200>{number = 7, name = (null)}"
"dispatchConcurrentQueue action1 1 at <NSThread: 0x6000002aa580>{number = 4, name = (null)}"
"dispatchConcurrentQueue action2 2 at <NSThread: 0x6000002ab200>{number = 7, name = (null)}"
"dispatchConcurrentQueue action2 3 at <NSThread: 0x6000002ab200>{number = 7, name = (null)}"
"dispatchConcurrentQueue action1 2 at <NSThread: 0x6000002aa580>{number = 4, name = (null)}"
"dispatchConcurrentQueue action1 3 at <NSThread: 0x6000002aa580>{number = 4, name = (null)}"
"dispatchConcurrentQueue barrier"
"dispatchConcurrentQueue action3 0 at <NSThread: 0x6000002ab200>{number = 7, name = (null)}"
"dispatchConcurrentQueue action4 0 at <NSThread: 0x6000002aa580>{number = 4, name = (null)}"
"dispatchConcurrentQueue action3 1 at <NSThread: 0x6000002ab200>{number = 7, name = (null)}"
"dispatchConcurrentQueue action4 1 at <NSThread: 0x6000002aa580>{number = 4, name = (null)}"
"dispatchConcurrentQueue action3 2 at <NSThread: 0x6000002ab200>{number = 7, name = (null)}"
"dispatchConcurrentQueue action4 2 at <NSThread: 0x6000002aa580>{number = 4, name = (null)}"
"dispatchConcurrentQueue action3 3 at <NSThread: 0x6000002ab200>{number = 7, name = (null)}"
"dispatchConcurrentQueue action4 3 at <NSThread: 0x6000002aa580>{number = 4, name = (null)}"
  • GCD 延迟执行
func dispatchAfter() {
        debugPrint("\(Date())")
        DispatchQueue.global().asyncAfter(deadline: .now() + 2) {
            debugPrint("等了2 s\(Date())")
        }
    }
"2021-11-21 07:22:25 +0000"
"等了2 s2021-11-21 07:22:27 +0000"
  • DispatchGroup
func dispatchGroupNotify() {
        let dispatchGroup = DispatchGroup()
        let seralQueue = DispatchQueue(label: "dispatchSeralSync")
        seralQueue.async(group: dispatchGroup, execute: DispatchWorkItem(block: {
            print("dispatchGroup do\(Thread.current)")
        }))
        seralQueue.async(group: dispatchGroup, execute: DispatchWorkItem(block: {
            print("dispatchGroup do1\(Thread.current)")
        }))
        dispatchGroup.notify(queue: DispatchQueue.main, work: DispatchWorkItem(block: {
            print("dispatchGroup.notify(queue: DispatchQueue.main\(Thread.current)")
        }))
    }
dispatchGroup do<NSThread: 0x6000016acbc0>{number = 4, name = (null)}
dispatchGroup do1<NSThread: 0x6000016acbc0>{number = 4, name = (null)}
dispatchGroup.notify(queue: DispatchQueue.main<_NSMainThread: 0x6000016e81c0>{number = 1, name = main}

相关文章

  • 多线程之1-GCD(DispatchQueue)

    GCD的特点 GCD会自动利用更多的CPU内核 GCD自动管理线程的生命周期(创建线程,调度任务,销毁线程等) 只...

  • 多线程分析之DispatchQueue

    https://juejin.im/post/5c4932056fb9a049ac7982e2

  • 多线程

    参考文章:iOS多线程--彻底学会多线程之『GCD』Swift 3.0 GCD和DispatchQueue 使用解...

  • iOS多线程总结1-GCD

    iOS多线程编程 写在前面,欢迎互相交流,欢迎指出错误; 基本概念 进程:计算机中的程序关于某数据集合上的一次运行...

  • iOS-多线程1-GCD

    首先看一下iOS中多线程的实现方案 这些多线程方案的底层都是依赖pthread NSThread线程生命周期是程序...

  • Swift补充- 多线程(DispatchQueue & Dis

    目录 DispatchQueue DispatchWorkItem 1 DispatchQueue 队列 asyn...

  • DispatchQueue

    DispatchQueue 分为串行和并发,它的完整初始化方法为:DispatchQueue.init(label...

  • GCD全集

    (一)GCD的API 1.DispatchQueue (1).DispatchQueue 先进先出FIFO (2)...

  • GCD 在 Swift 中的用法

    DispatchQueue Swift 中,对 GCD 语法进行了彻底改写。引入了 DispatchQueue 这...

  • Telegram开源项目之DispatchQueue

    DispatchQueue介绍 在特定的线程(单线程)下串行执行的任务队列 DispatchQueue作用 在特定...

网友评论

      本文标题:多线程之1-GCD(DispatchQueue)

      本文链接:https://www.haomeiwen.com/subject/lvzptrtx.html