1. DispatchTime和DispatchWallTime的區(qū)別？
例如: 從現(xiàn)在開始,1小時(shí)之后是觸發(fā)某個(gè)事件
DispatchTime函數(shù)創(chuàng)建的是一個(gè)相對(duì)的時(shí)間, 參考的是當(dāng)前系統(tǒng)的時(shí)鐘铸本。當(dāng) device 進(jìn)入休眠之后,系統(tǒng)的時(shí)鐘也會(huì)進(jìn)入休眠狀態(tài)，事件的實(shí)際觸發(fā)是從喚醒 device 的時(shí)刻繼續(xù)計(jì)時(shí)的涂籽。
DispatchWallTime創(chuàng)建的是一個(gè)絕對(duì)的時(shí)間點(diǎn),一旦創(chuàng)建就表示從這個(gè)時(shí)間點(diǎn)開始,1小時(shí)之后觸發(fā)事件,假如 device 休眠了10分鐘,當(dāng)再次喚醒 device 的時(shí)候不會(huì)受到 device 是否進(jìn)入休眠影響能颁。
DispatchQueue.main.asyncAfter(deadline: .now() + 2) {
print("2秒后執(zhí)行")
}
DispatchQueue.main.asyncAfter(wallDeadline: .now() + 2) {
print("2秒后執(zhí)行")
}
2. 串行、并行骨稿、全局隊(duì)列創(chuàng)建
let serialQueue = DispatchQueue(label: "com.serial.xxx")
let concurrentQueue = DispatchQueue(label: "com.concurrent.xxx", attributes: [.concurrent])
let globalQueue = DispatchQueue.global()
let mianQueue = DispatchQueue.mian
3. 同步鳖目、異步任務(wù)執(zhí)行
queue.async {
print("異步")
}
queue.sync {
print("同步")
}
4. DispatchWorkItem的使用
上面的同步扮叨、異步任務(wù)是包裝在closure的，其實(shí)初始化DispatchWorkItem作為任務(wù)领迈。如果需要對(duì)任務(wù)的狀態(tài)進(jìn)行監(jiān)聽和控制可以使用它彻磁，如下：
let item = DispatchWorkItem {
print("DispatchWorkItem----")
}
queue.async(execute: item)
item.notify(queue: DispatchQueue.main) {
print("item已經(jīng)執(zhí)行完了")
}
5. 定時(shí)器
var globalTimer: DispatchSourceTimer?
func testGCDTimer() {
let queue = DispatchQueue.init(label: "zlq")
let timer = DispatchSource.makeTimerSource(queue: queue)
timer.setEventHandler {// timer到時(shí)時(shí)觸發(fā)block
print("timer event handler---")
}
timer.setCancelHandler {// timer取消時(shí)回調(diào)
print("timer cancle---")
}
let timerItem = DispatchWorkItem {
print("timerItem")
}
print("timer初始化---")
// deadline是第一次觸發(fā)時(shí)間，后續(xù)每隔repeating時(shí)間重復(fù)一次狸捅，如果只執(zhí)行一次則不需要repeating參數(shù)
timer.schedule(deadline: .now() + 1, repeating: 2)
globalTimer = timer
// 啟動(dòng)定時(shí)器
timer.resume()
// 10秒后取消timer
DispatchQueue.main.asyncAfter(deadline: .now() + 10) {
globalTimer?.cancel()
globalTimer = nil
}
}
6. 組隊(duì)列
比較適用的場景：多個(gè)異步任務(wù)衷蜓，需要在任務(wù)都完成時(shí)執(zhí)行刷新邏輯。
方法一：
//創(chuàng)建隊(duì)列組常量(這是個(gè)全局常量)
let group = DispatchGroup()
// 任務(wù)1
let queue = DispatchQueue.global()
self.group.enter()
queue.async {
self.group.leave() //不管成功與否都要leave()操作,方便后面的請(qǐng)求繼續(xù)進(jìn)行
}
// 任務(wù)2
self.group.enter()
queue.async {
self.group.leave()
}
// 組隊(duì)列中的人物都執(zhí)行完畢了會(huì)來到這里
group.notify(queue: DispatchQueue.main) {
self.tableView.reloadData()
}
方法二：
let group = DispatchGroup()
let queue = DispatchQueue(label: "com.concurrent.zlq", attributes: [.concurrent])
func testGroup() {
queue.async(group: group) {
usleep(1000)
print("任務(wù)一")
}
queue.async(group: group) {
usleep(500)
print("任務(wù)二")
}
group.notify(queue: DispatchQueue.main) {
print("group.notify===thread=\(Thread.current)")
}
}
7. 柵欄任務(wù)
func testGCDBarrier() {
let queue = DispatchQueue(label: "com.zlq.concurrent", attributes: .concurrent)
for i in 1..<100 {
queue.async {
print("并發(fā)隊(duì)列異步任務(wù)\(i)", Thread.current)
if i % 10 == 0 {
Thread.sleep(forTimeInterval: 1)
queue.async {
print("并發(fā)隊(duì)列異步任務(wù)\(i)==\(i)")
}
}
}
}
// 柵欄函數(shù)的closure任務(wù)會(huì)等queue中前面的所有任務(wù)執(zhí)行完再執(zhí)行尘喝，
// 同時(shí)比柵欄任務(wù)更晚添加到queue中的任務(wù)需要等柵欄任務(wù)執(zhí)行完才會(huì)執(zhí)行磁浇。
queue.async(flags: .barrier) {
Thread.sleep(forTimeInterval: 5)
}
print("柵欄函數(shù)異步任務(wù)下一步") // 這一步不需要柵欄函數(shù)執(zhí)行后才執(zhí)行
}
8. 信號(hào)量
需要GCD控制最大并發(fā)數(shù)量的時(shí)候，使用信號(hào)量是比較合適的朽褪。
let semaphore = DispatchSemaphore(value: 2)// 最大并發(fā)數(shù)=2
func testSemaphore() {
let queue = DispatchQueue(label: "com.zlq.concurrent", attributes: .concurrent)
queue.async {
// 等待信號(hào)量置吓，信號(hào)量>1或者等待時(shí)間超過5秒時(shí)可以執(zhí)行
let result = semaphore.wait(timeout: .now() + 5)
if result == .success {
print("執(zhí)行任務(wù)一：-----")
sleep(6)
} else {
print("任務(wù)一：等待超時(shí)-----")
}
}
queue.async {
// 等待信號(hào)量，信號(hào)量>1或者等待時(shí)間超過5秒時(shí)可以執(zhí)行
let result = semaphore.wait(timeout: .now() + 5)
// 執(zhí)行時(shí)信號(hào)量-1
if result == .success {
print("執(zhí)行任務(wù)二：-----")
sleep(6)
semaphore.signal() // 信號(hào)量+1
} else {
print("任務(wù)二：等待超時(shí)-----")
}
}
// 任務(wù)一鞍匾、二因?yàn)橛行盘?hào)量可以直接執(zhí)行交洗，任務(wù)三需等待信號(hào)量.
// 下面的任務(wù)三在等待5秒后，超時(shí)執(zhí)行
queue.async {
// 等待信號(hào)量橡淑，信號(hào)量>1或者等待時(shí)間超過5秒時(shí)可以執(zhí)行
let result = semaphore.wait(timeout: .now() + 5)
// 執(zhí)行時(shí)信號(hào)量-1
if result == .success {
print("執(zhí)行任務(wù)三：-----")
sleep(6)
semaphore.signal() // 信號(hào)量+1
} else {
print("任務(wù)三：等待超時(shí)-----")
}
}
}
9. OC中的Dispatch_once怎么實(shí)現(xiàn)？
Swift-實(shí)現(xiàn)dispatch_once效果
全局變量的初始化閉包中寫只執(zhí)行一次的代碼
let dispatchOnce: () = {
print("dispatchOnce-------")
}()
// 調(diào)用一次
_ = dispatchOnce
10. 判斷當(dāng)前是否主隊(duì)列
因?yàn)橹麝?duì)列中任務(wù)一定是主線程執(zhí)行咆爽，但是主線程執(zhí)行的任務(wù)有可能是非主隊(duì)列中的梁棠，而有的情況下是要求主隊(duì)列 + 主線程執(zhí)行，比如：
在 ReactiveCocoa 的一個(gè) issue里提到在MapKit 中的 MKMapView 有個(gè)
addOverlay方法斗埂，這個(gè)方法不僅要在主線程中執(zhí)行符糊，而且要把這個(gè)操作加到主隊(duì)列中才可以，并且后來 Apple DTS 也承認(rèn)了這是一個(gè)bug呛凶。
// OC版本男娄，SDWebImage中的宏
// 判斷回調(diào)到主線程執(zhí)行的方式：dispatch_queue_get_label
#ifndef dispatch_main_async_safe
#define dispatch_main_async_safe(block)\
if (dispatch_queue_get_label(DISPATCH_CURRENT_QUEUE_LABEL) == dispatch_queue_get_label(dispatch_get_main_queue())) {\
block();\
} else {\
dispatch_async(dispatch_get_main_queue(), block);\
}
#endif
// Swift版本，以下RxSwift中的方式:
// 判斷當(dāng)前執(zhí)行的上下文中是否存在關(guān)聯(lián)key的值，該key只設(shè)定在主隊(duì)列的上下文中
extension DispatchQueue {
// DispatchSpecificKey: 與調(diào)度隊(duì)列上的特定上下文值關(guān)聯(lián)的鍵模闲。
private static var token: DispatchSpecificKey<()> = {
let key = DispatchSpecificKey<()>()
DispatchQueue.main.setSpecific(key: key, value: ())
return key
}()
static var isMain: Bool {
// getSpecific:返回當(dāng)前執(zhí)行的上下文關(guān)聯(lián)key對(duì)應(yīng)的值
DispatchQueue.getSpecific(key: token) != nil
}
}
