1. DispatchSemaphore
场景:
- 控制异步操作的最大并发, 如多图下载控制并发, 用户中途取消可以节约流量.
- 异步操作同步执行, 如数据库异步读写, 防止多线程同时操作同一文件.
semaphore: 臂板信号系统, 简称dispatch信号量
核心: 信号量小于0则等待, 否则执行
创建一个semaphore, 并设置初试信号数
public init(value: Int)
发送一个信号, 信号数+1, 线程等待返回0, 否则非0
public func signal() -> Int
等待信号, 信号数-1, 若信号数小于0则等待, 直至信号数不小于0
public func wait()
可以设置等待过期时间, DispatchTime为主板时间CPU时钟计时, DispatchWallTime为实际时间即系统时间, 返回值为成功或超时
public func wait(timeout: DispatchTime) -> DispatchTimeoutResult
public func wait(wallTimeout: DispatchWallTime) -> DispatchTimeoutResult
tip:
线程数大于核数两倍的时候会比较耗性能
2. Dipatch_barrier
场景:
我们有一个并发的队列用来读写数据库。读取操作必须等待多个写入操作完成后才能读取，否则就可能会出现读到的数据不对。
Tip:
Dipatch_barrier现在属性放在了DispatchWorkItemFlags里
let q = DispatchQueue.init(label: "data")
q.async {
//write action
}
q.async {
//write action
}
q.async(flags: DispatchWorkItemFlags.barrier){
//read action
}
barrier_async 与 barrier_sync的异同
-
共同点：
- 都会等待在它前面插入队列的任务（1、2、3）先执行完
- 都会等待他们自己的任务（0）执行完再执行后面的任务（4、5、6）
不共同点：
在将任务插入到queue的时候，barrier_sync需要等待自己的任务（0）结束之后才会继续程序，然后插入被写在它后面的任务（4、5、6），然后执行后面的任务 而barrier_async将自己的任务（0）插入到queue之后，不会等待自己的任务结束，它会继续把后面的任务（4、5、6）插入到queue所以，barrier_async的不等待（异步）特性体现在将任务插入队列的过程，它的等待特性体现在任务真正执行的过程。
