1. DispatchTime和DispatchWallTime的區(qū)別？
例如: 從現(xiàn)在開始,1小時之后是觸發(fā)某個事件
DispatchTime函數(shù)創(chuàng)建的是一個相對的時間, 參考的是當前系統(tǒng)的時鐘。當 device 進入休眠之后,系統(tǒng)的時鐘也會進入休眠狀態(tài)，事件的實際觸發(fā)是從喚醒 device 的時刻繼續(xù)計時的。
DispatchWallTime創(chuàng)建的是一個絕對的時間點,一旦創(chuàng)建就表示從這個時間點開始,1小時之后觸發(fā)事件,假如 device 休眠了10分鐘,當再次喚醒 device 的時候不會受到 device 是否進入休眠影響。
DispatchQueue.main.asyncAfter(deadline: .now() + 2) {
print("2秒后執(zhí)行")
}
DispatchQueue.main.asyncAfter(wallDeadline: .now() + 2) {
print("2秒后執(zhí)行")
}
2. 串行、并行、全局隊列創(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的，其實初始化DispatchWorkItem作為任務(wù)。如果需要對任務(wù)的狀態(tài)進行監(jiān)聽和控制可以使用它，如下：
let item = DispatchWorkItem {
print("DispatchWorkItem----")
}
queue.async(execute: item)
item.notify(queue: DispatchQueue.main) {
print("item已經(jīng)執(zhí)行完了")
}
5. 定時器
var globalTimer: DispatchSourceTimer?
func testGCDTimer() {
let queue = DispatchQueue.init(label: "zlq")
let timer = DispatchSource.makeTimerSource(queue: queue)
timer.setEventHandler {// timer到時時觸發(fā)block
print("timer event handler---")
}
timer.setCancelHandler {// timer取消時回調(diào)
print("timer cancle---")
}
let timerItem = DispatchWorkItem {
print("timerItem")
}
print("timer初始化---")
// deadline是第一次觸發(fā)時間，后續(xù)每隔repeating時間重復(fù)一次，如果只執(zhí)行一次則不需要repeating參數(shù)
timer.schedule(deadline: .now() + 1, repeating: 2)
globalTimer = timer
// 啟動定時器
timer.resume()
// 10秒后取消timer
DispatchQueue.main.asyncAfter(deadline: .now() + 10) {
globalTimer?.cancel()
globalTimer = nil
}
}
6. 組隊列
比較適用的場景：多個異步任務(wù)，需要在任務(wù)都完成時執(zhí)行刷新邏輯。
方法一：
//創(chuàng)建隊列組常量(這是個全局常量)
let group = DispatchGroup()
// 任務(wù)1
let queue = DispatchQueue.global()
self.group.enter()
queue.async {
self.group.leave() //不管成功與否都要leave()操作,方便后面的請求繼續(xù)進行
}
// 任務(wù)2
self.group.enter()
queue.async {
self.group.leave()
}
// 組隊列中的人物都執(zhí)行完畢了會來到這里
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ā)隊列異步任務(wù)\(i)", Thread.current)
if i % 10 == 0 {
Thread.sleep(forTimeInterval: 1)
queue.async {
print("并發(fā)隊列異步任務(wù)\(i)==\(i)")
}
}
}
}
// 柵欄函數(shù)的closure任務(wù)會等queue中前面的所有任務(wù)執(zhí)行完再執(zhí)行，
// 同時比柵欄任務(wù)更晚添加到queue中的任務(wù)需要等柵欄任務(wù)執(zhí)行完才會執(zhí)行。
queue.async(flags: .barrier) {
Thread.sleep(forTimeInterval: 5)
}
print("柵欄函數(shù)異步任務(wù)下一步") // 這一步不需要柵欄函數(shù)執(zhí)行后才執(zhí)行
}
8. 信號量
需要GCD控制最大并發(fā)數(shù)量的時候，使用信號量是比較合適的。
let semaphore = DispatchSemaphore(value: 2)// 最大并發(fā)數(shù)=2
func testSemaphore() {
let queue = DispatchQueue(label: "com.zlq.concurrent", attributes: .concurrent)
queue.async {
// 等待信號量，信號量>1或者等待時間超過5秒時可以執(zhí)行
let result = semaphore.wait(timeout: .now() + 5)
if result == .success {
print("執(zhí)行任務(wù)一：-----")
sleep(6)
} else {
print("任務(wù)一：等待超時-----")
}
}
queue.async {
// 等待信號量，信號量>1或者等待時間超過5秒時可以執(zhí)行
let result = semaphore.wait(timeout: .now() + 5)
// 執(zhí)行時信號量-1
if result == .success {
print("執(zhí)行任務(wù)二：-----")
sleep(6)
semaphore.signal() // 信號量+1
} else {
print("任務(wù)二：等待超時-----")
}
}
// 任務(wù)一、二因為有信號量可以直接執(zhí)行，任務(wù)三需等待信號量.
// 下面的任務(wù)三在等待5秒后，超時執(zhí)行
queue.async {
// 等待信號量，信號量>1或者等待時間超過5秒時可以執(zhí)行
let result = semaphore.wait(timeout: .now() + 5)
// 執(zhí)行時信號量-1
if result == .success {
print("執(zhí)行任務(wù)三：-----")
sleep(6)
semaphore.signal() // 信號量+1
} else {
print("任務(wù)三：等待超時-----")
}
}
}
9. OC中的Dispatch_once怎么實現(xiàn)？
全局變量的初始化閉包中寫只執(zhí)行一次的代碼
let dispatchOnce: () = {
print("dispatchOnce-------")
}()
// 調(diào)用一次
_ = dispatchOnce
10. 判斷當前是否主隊列
因為主隊列中任務(wù)一定是主線程執(zhí)行，但是主線程執(zhí)行的任務(wù)有可能是非主隊列中的，而有的情況下是要求主隊列 + 主線程執(zhí)行，比如：
在 ReactiveCocoa 的一個 issue里提到在MapKit 中的 MKMapView 有個
addOverlay方法，這個方法不僅要在主線程中執(zhí)行，而且要把這個操作加到主隊列中才可以，并且后來 Apple DTS 也承認了這是一個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中的方式:
// 判斷當前執(zhí)行的上下文中是否存在關(guān)聯(lián)key的值，該key只設(shè)定在主隊列的上下文中
extension DispatchQueue {
// DispatchSpecificKey: 與調(diào)度隊列上的特定上下文值關(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:返回當前執(zhí)行的上下文關(guān)聯(lián)key對應(yīng)的值
DispatchQueue.getSpecific(key: token) != nil
}
}
