iOS进阶 - GCD总结
前言
Grand Central Dispatch(GCD) 是 Apple 開發的一個多核編程的較新的解決方法。它主要用于優化應用程序以支持多核處理器以及其他對稱多處理系統。它是一個在線程池模式的基礎上執行的并發任務。在 Mac OS X 10.6 雪豹中首次推出,也可在 iOS 4 及以上版本使用。
使用 GCD 的好處:
- GCD 可用于多核的并行運算;
- GCD 會自動利用更多的 CPU 內核(比如雙核、四核);
- GCD 會自動管理線程的生命周期(創建線程、調度任務、銷毀線程);
- 程序員只需要告訴 GCD 想要執行什么任務,不需要編寫任何線程管理代碼。
1. GCD 任務和隊列
任務:就是執行操作的意思,換句話說就是你在線程中執行的那段代碼。在 GCD 中是放在 block 中的。執行任務有兩種方式:同步執行?和 異步執行。兩者的主要區別是:是否等待隊列的任務執行結束,以及是否具備開啟新線程的能力。
- 同步執行(sync):
- 同步添加任務到指定的隊列中,在添加的任務執行結束之前,會一直等待,直到隊列里面的任務完成之后再繼續執行。
- 只能在當前線程中執行任務,不具備開啟新線程的能力。
- 異步執行(async):
- 異步添加任務到指定的隊列中,它不會做任何等待,可以繼續執行任務。
- 可以在新的線程中執行任務,具備開啟新線程的能力。
注意:異步執行(async)雖然具有開啟新線程的能力,但是并不一定開啟新線程。這跟任務所指定的隊列類型有關(下面會講)。
隊列(Dispatch Queue):這里的隊列指執行任務的等待隊列,即用來存放任務的隊列。隊列是一種特殊的線性表,采用 FIFO(先進先出)的原則,即新任務總是被插入到隊列的末尾,而讀取任務的時候總是從隊列的頭部開始讀取。每讀取一個任務,則從隊列中釋放一個任務。隊列的結構可參考下圖:
在 GCD 中有兩種隊列:『串行隊列』?和?『并發隊列』。兩者都符合 FIFO(先進先出)的原則。兩者的主要區別是:執行順序不同,以及開啟線程數不同。
- 串行隊列(Serial Dispatch Queue):
- 每次只有一個任務被執行。讓任務一個接著一個地執行。(只開啟一個線程,一個任務執行完畢后,再執行下一個任務)
- 并發隊列(Concurrent Dispatch Queue):
- 可以讓多個任務并發(同時)執行。(可以開啟多個線程,并且同時執行任務)
注意:并發隊列 的并發功能只有在異步(dispatch_async)方法下才有效。
2. GCD 的使用步驟
2.1 隊列的創建方法 / 獲取方法
可以使用 dispatch_queue_create 方法來創建隊列。該方法需要傳入兩個參數:
- 第一個參數表示隊列的唯一標識符,用于 DEBUG,可為空。隊列的名稱推薦使用應用程序 ID 這種逆序全程域名。
- 第二個參數用來識別是串行隊列還是并發隊列。DISPATCH_QUEUE_SERIAL 表示串行隊列,DISPATCH_QUEUE_CONCURRENT 表示并發隊列。
對于串行隊列,GCD 默認提供了:主隊列(Main Dispatch Queue)。
- 所有放在主隊列中的任務,都會放到主線程中執行。
- 可使用 dispatch_get_main_queue() 方法獲得主隊列。
注意:主隊列其實并不特殊。?主隊列的實質上就是一個普通的串行隊列,只是因為默認情況下,當前代碼是放在主隊列中的,然后主隊列中的代碼,有都會放到主線程中去執行,所以才造成了主隊列特殊的現象。
// 主隊列的獲取方法 dispatch_queue_t queue = dispatch_get_main_queue();對于并發隊列,GCD 默認提供了 『全局并發隊列(Global Dispatch Queue)』。
- 可以使用 dispatch_get_global_queue 方法來獲取全局并發隊列。需要傳入兩個參數。第一個參數表示隊列優先級,一般用 DISPATCH_QUEUE_PRIORITY_DEFAULT。第二個參數暫時沒用,用 0 即可。
2.2 任務的創建方法
GCD 提供了同步執行任務的創建方法?dispatch_sync?和異步執行任務創建方法?dispatch_async。
// 同步執行任務創建方法 dispatch_sync(queue, ^{// 這里放同步執行任務代碼 }); // 異步執行任務創建方法 dispatch_async(queue, ^{// 這里放異步執行任務代碼 });雖然使用 GCD 只需兩步,但是既然我們有兩種隊列(串行隊列 / 并發隊列),兩種任務執行方式(同步執行 / 異步執行),那么我們就有了四種不同的組合方式。這四種不同的組合方式是:
實際上,剛才還說了兩種默認隊列:全局并發隊列、主隊列。全局并發隊列可以作為普通并發隊列來使用。但是當前代碼默認放在主隊列中,所以主隊列很有必要專門來研究一下,所以我們就又多了兩種組合方式。這樣就有六種不同的組合方式了。
? ? 5、同步執行 + 主隊列
? ? 6、異步執行 + 主隊列
2.3 任務和隊列不同組合方式的區別
主線程?中,不同隊列?+?不同任務?簡單組合的區別:
| 同步(sync) | 沒有開啟新線程,串行執行任務 | 沒有開啟新線程,串行執行任務 | 死鎖卡住不執行 |
| 異步(async) | 有開啟新線程,并發執行任務 | 有開啟新線程(1條),串行執行任務 | 沒有開啟新線程,串行執行任務 |
注意:從上邊可看出: 主線程?中調用 主隊列 + 同步執行?會導致死鎖問題。
這是因為 主隊列中追加的同步任務 和 主線程本身的任務 兩者之間相互等待,阻塞了 主隊列,最終造成了主隊列所在的線程(主線程)死鎖問題。
2.4 隊列嵌套情況下,不同組合方式區別
不同隊列 + 不同任務?組合,以及 隊列中嵌套隊列?使用的區別:
| 同步(sync) | 沒有開啟新的線程,串行執行任務 | 沒有開啟新線程,串行執行任務 | 死鎖卡住不執行 | 死鎖卡住不執行 |
| 異步(async) | 有開啟新線程,并發執行任務 | 有開啟新線程,并發執行任務 | 有開啟新線程(1 條),串行執行任務 | 有開啟新線程(1 條),串行執行任務 |
3. GCD 的基本使用
3.1 同步執行 + 并發隊列
在當前線程中執行任務,不會開啟新線程,執行完一個任務,再執行下一個任務。
/*** 同步執行 + 并發隊列* 特點:在當前線程中執行任務,不會開啟新線程,執行完一個任務,再執行下一個任務。*/ - (void)syncConcurrent {NSLog(@"currentThread---%@",[NSThread currentThread]); // 打印當前線程NSLog(@"syncConcurrent---begin");dispatch_queue_t queue = dispatch_queue_create("com.hiccup.myQueue", DISPATCH_QUEUE_CONCURRENT);dispatch_sync(queue, ^{// 追加任務 1[NSThread sleepForTimeInterval:2]; // 模擬耗時操作NSLog(@"1---%@",[NSThread currentThread]); // 打印當前線程});dispatch_sync(queue, ^{// 追加任務 2[NSThread sleepForTimeInterval:2]; // 模擬耗時操作NSLog(@"2---%@",[NSThread currentThread]); // 打印當前線程});dispatch_sync(queue, ^{// 追加任務 3[NSThread sleepForTimeInterval:2]; // 模擬耗時操作NSLog(@"3---%@",[NSThread currentThread]); // 打印當前線程});NSLog(@"syncConcurrent---end"); }輸出結果:
?currentThread---<NSThread: 0x600006748362>{number = 1, name = main}
?syncConcurrent---begin
?1---<NSThread: 0x600006748362>{number = 1, name = main}
?2---<NSThread: 0x600006748362>{number = 1, name = main}
?3---<NSThread: 0x600006748362>{number = 1, name = main}
?syncConcurrent---end
從 同步執行 + 并發隊列 中可看到:
- 所有任務都是在當前線程(主線程)中執行的,沒有開啟新的線程(同步執行不具備開啟新線程的能力)。
- 所有任務都在打印的 syncConcurrent---begin 和 syncConcurrent---end 之間執行的(同步任務 需要等待隊列的任務執行結束)。
- 任務按順序執行的。按順序執行的原因:雖然 并發隊列 可以開啟多個線程,并且同時執行多個任務。但是因為本身不能創建新線程,只有當前線程這一個線程(同步任務 不具備開啟新線程的能力),所以也就不存在并發。而且當前線程只有等待當前隊列中正在執行的任務執行完畢之后,才能繼續接著執行下面的操作(同步任務 需要等待隊列的任務執行結束)。所以任務只能一個接一個按順序執行,不能同時被執行。
3.2 異步執行 + 并發隊列
可以開啟多個線程,任務交替(同時)執行。
/*** 異步執行 + 并發隊列* 特點:可以開啟多個線程,任務交替(同時)執行。*/ - (void)asyncConcurrent {NSLog(@"currentThread---%@",[NSThread currentThread]); // 打印當前線程NSLog(@"asyncConcurrent---begin");dispatch_queue_t queue = dispatch_queue_create("com.hiccup.myQueue", DISPATCH_QUEUE_CONCURRENT);dispatch_async(queue, ^{// 追加任務 1[NSThread sleepForTimeInterval:2]; // 模擬耗時操作NSLog(@"1---%@",[NSThread currentThread]); // 打印當前線程});dispatch_async(queue, ^{// 追加任務 2[NSThread sleepForTimeInterval:2]; // 模擬耗時操作NSLog(@"2---%@",[NSThread currentThread]); // 打印當前線程});dispatch_async(queue, ^{// 追加任務 3[NSThread sleepForTimeInterval:2]; // 模擬耗時操作NSLog(@"3---%@",[NSThread currentThread]); // 打印當前線程});NSLog(@"asyncConcurrent---end"); }輸出結果:
?currentThread---<NSThread: 0x60000706d670>{number = 1, name = main}
?asyncConcurrent---begin
?asyncConcurrent---end
?2---<NSThread: 0x600007364720>{number = 4, name = (null)}
?3---<NSThread: 0x600007371450>{number = 6, name = (null)}
?1---<NSThread: 0x600007354560>{number = 5, name = (null)}
在 異步執行 + 并發隊列 中可以看出:
- 除了當前線程(主線程),系統又開啟了 3 個線程,并且任務是交替/同時執行的。(異步執行 具備開啟新線程的能力。且 并發隊列 可開啟多個線程,同時執行多個任務)。
- 所有任務是在打印的 syncConcurrent---begin 和 syncConcurrent---end 之后才執行的。說明當前線程沒有等待,而是直接開啟了新線程,在新線程中執行任務(異步執行 不做等待,可以繼續執行任務)。
3.3 同步執行 + 串行隊列
不會開啟新線程,在當前線程執行任務。任務是串行的,執行完一個任務,再執行下一個任務。
/*** 同步執行 + 串行隊列* 特點:不會開啟新線程,在當前線程執行任務。任務是串行的,執行完一個任務,再執行下一個任務。*/ - (void)syncSerial {NSLog(@"currentThread---%@",[NSThread currentThread]); // 打印當前線程NSLog(@"syncSerial---begin");dispatch_queue_t queue = dispatch_queue_create("com.hiccup.myQueue", DISPATCH_QUEUE_SERIAL);dispatch_sync(queue, ^{// 追加任務 1[NSThread sleepForTimeInterval:2]; // 模擬耗時操作NSLog(@"1---%@",[NSThread currentThread]); // 打印當前線程});dispatch_sync(queue, ^{// 追加任務 2[NSThread sleepForTimeInterval:2]; // 模擬耗時操作NSLog(@"2---%@",[NSThread currentThread]); // 打印當前線程});dispatch_sync(queue, ^{// 追加任務 3[NSThread sleepForTimeInterval:2]; // 模擬耗時操作NSLog(@"3---%@",[NSThread currentThread]); // 打印當前線程});NSLog(@"syncSerial---end"); }輸出結果為:
?currentThread---<NSThread: 0x600003c6e530>{number = 1, name = main}
?syncSerial---begin
?1---<NSThread: 0x600003c6e530>{number = 1, name = main}
?2---<NSThread: 0x600003c6e530>{number = 1, name = main}
?3---<NSThread: 0x600003c6e530>{number = 1, name = main}
?syncSerial---end
在 同步執行 + 串行隊列 可以看到:
- 所有任務都是在當前線程(主線程)中執行的,并沒有開啟新的線程(同步執行 不具備開啟新線程的能力)。
- 所有任務都在打印的 syncConcurrent---begin 和 syncConcurrent---end 之間執行(同步任務 需要等待隊列的任務執行結束)。
- 任務是按順序執行的(串行隊列 每次只有一個任務被執行,任務一個接一個按順序執行)。
3.4 異步執行 + 串行隊列
會開啟新線程,但是因為任務是串行的,執行完一個任務,再執行下一個任務
/*** 異步執行 + 串行隊列* 特點:會開啟新線程,但是因為任務是串行的,執行完一個任務,再執行下一個任務。*/ - (void)asyncSerial {NSLog(@"currentThread---%@",[NSThread currentThread]); // 打印當前線程NSLog(@"asyncSerial---begin");dispatch_queue_t queue = dispatch_queue_create("com.hiccup.myQueue", DISPATCH_QUEUE_SERIAL);dispatch_async(queue, ^{// 追加任務 1[NSThread sleepForTimeInterval:2]; // 模擬耗時操作NSLog(@"1---%@",[NSThread currentThread]); // 打印當前線程});dispatch_async(queue, ^{// 追加任務 2[NSThread sleepForTimeInterval:2]; // 模擬耗時操作NSLog(@"2---%@",[NSThread currentThread]); // 打印當前線程});dispatch_async(queue, ^{// 追加任務 3[NSThread sleepForTimeInterval:2]; // 模擬耗時操作NSLog(@"3---%@",[NSThread currentThread]); // 打印當前線程});NSLog(@"asyncSerial---end"); }輸出結果為:
?currentThread---<NSThread: 0x6000042e2570>{number = 1, name = main}
?asyncSerial---begin
?asyncSerial---end
?1---<NSThread: 0x6000043c2310>{number = 3, name = (null)}
?2---<NSThread: 0x6000043c2310>{number = 3, name = (null)}
?3---<NSThread: 0x6000043c2310>{number = 3, name = (null)}
在 異步執行 + 串行隊列 可以看到:
- 開啟了一條新線程(異步執行 具備開啟新線程的能力,串行隊列 只開啟一個線程)。
- 所有任務是在打印的 syncConcurrent---begin 和 syncConcurrent---end 之后才開始執行的(異步執行 不會做任何等待,可以繼續執行任務)。
- 任務是按順序執行的(串行隊列 每次只有一個任務被執行,任務一個接一個按順序執行)。
3.5 同步執行 + 主隊列
同步執行 + 主隊列?在不同線程中調用結果也是不一樣,在主線程中調用會發生死鎖問題,而在其他線程中調用則不會。
3.5.1 在主線程中調用 『同步執行 + 主隊列』
互相等待卡住不可行
/*** 同步執行 + 主隊列* 特點(主線程調用):互等卡主不執行。* 特點(其他線程調用):不會開啟新線程,執行完一個任務,再執行下一個任務。*/ - (void)syncMain {NSLog(@"currentThread---%@",[NSThread currentThread]); // 打印當前線程NSLog(@"syncMain---begin");dispatch_queue_t queue = dispatch_get_main_queue();dispatch_sync(queue, ^{// 追加任務 1[NSThread sleepForTimeInterval:2]; // 模擬耗時操作NSLog(@"1---%@",[NSThread currentThread]); // 打印當前線程});dispatch_sync(queue, ^{// 追加任務 2[NSThread sleepForTimeInterval:2]; // 模擬耗時操作NSLog(@"2---%@",[NSThread currentThread]); // 打印當前線程});dispatch_sync(queue, ^{// 追加任務 3[NSThread sleepForTimeInterval:2]; // 模擬耗時操作NSLog(@"3---%@",[NSThread currentThread]); // 打印當前線程});NSLog(@"syncMain---end"); }輸出結果(Xcode 9 以下版本)
?currentThread---<NSThread: 0x6000042c5570>{number = 1, name = main}
?syncMain---begin
(lldb)
在主線程中使用 同步執行 + 主隊列 可以驚奇的發現:
- 追加到主線程的任務 1、任務 2、任務 3 都不再執行了,而且 syncMain---end 也沒有打印,在 XCode 9 及以上版本上還會直接報崩潰。這是為什么呢?【Thread 1: EXC_BAD_INSTRUCTION (code=EXC_I386_INVOP, subcode=0x0)】
這是因為我們在主線程中執行 syncMain 方法,相當于把 syncMain 任務放到了主線程的隊列中。而 同步執行 會等待當前隊列中的任務執行完畢,才會接著執行。那么當我們把 任務 1 追加到主隊列中,任務 1 就在等待主線程處理完 syncMain 任務。而syncMain 任務需要等待 任務 1 執行完畢,才能接著執行。
3.5.2 在其他線程中調用『同步執行 + 主隊列』
不會開啟新線程,執行完一個任務,再執行下一個任務
// 使用 NSThread 的 detachNewThreadSelector 方法會創建線程,并自動啟動線程執行 selector 任務 [NSThread detachNewThreadSelector:@selector(syncMain) toTarget:self withObject:nil];輸出結果:
?currentThread---<NSThread: 0x600003ad2a20>{number = 3, name = (null)}
?syncMain---begin
?1---<NSThread: 0x60000382a340>{number = 1, name = main}
?2---<NSThread: 0x60000382a340>{number = 1, name = main}
?3---<NSThread: 0x60000382a340>{number = 1, name = main}
?syncMain---end
在其他線程中使用 同步執行 + 主隊列 可看到:
- 所有任務都是在主線程(非當前線程)中執行的,沒有開啟新的線程(所有放在主隊列中的任務,都會放到主線程中執行)。
- 所有任務都在打印的 syncConcurrent---begin 和 syncConcurrent---end 之間執行(同步任務 需要等待隊列的任務執行結束)。
- 任務是按順序執行的(主隊列是 串行隊列,每次只有一個任務被執行,任務一個接一個按順序執行)。
為什么現在就不會卡住了呢?
因為syncMain 任務 放到了其他線程里,而 任務 1、任務 2、任務3 都在追加到主隊列中,這三個任務都會在主線程中執行。syncMain 任務 在其他線程中執行到追加 任務 1 到主隊列中,因為主隊列現在沒有正在執行的任務,所以,會直接執行主隊列的 任務1,等 任務1 執行完畢,再接著執行 任務 2、任務 3。所以這里不會卡住線程,也就不會造成死鎖問題。
3.6 異步執行 + 主隊列
只在主線程中執行任務,執行完一個任務,再執行下一個任務。
/*** 異步執行 + 主隊列* 特點:只在主線程中執行任務,執行完一個任務,再執行下一個任務*/ - (void)asyncMain {NSLog(@"currentThread---%@",[NSThread currentThread]); // 打印當前線程NSLog(@"asyncMain---begin");dispatch_queue_t queue = dispatch_get_main_queue();dispatch_async(queue, ^{// 追加任務 1[NSThread sleepForTimeInterval:2]; // 模擬耗時操作NSLog(@"1---%@",[NSThread currentThread]); // 打印當前線程});dispatch_async(queue, ^{// 追加任務 2[NSThread sleepForTimeInterval:2]; // 模擬耗時操作NSLog(@"2---%@",[NSThread currentThread]); // 打印當前線程});dispatch_async(queue, ^{// 追加任務 3[NSThread sleepForTimeInterval:2]; // 模擬耗時操作NSLog(@"3---%@",[NSThread currentThread]); // 打印當前線程});NSLog(@"asyncMain---end"); }輸出結果:
?currentThread---<NSThread: 0x6000032e2160>{number = 1, name = main}
?asyncMain---begin
?asyncMain---end
?1---<NSThread: 0x6000032e2160>{number = 1, name = main}
?2---<NSThread: 0x6000032e2160>{number = 1, name = main}
?3---<NSThread: 0x6000032e2160>{number = 1, name = main}
在 異步執行 + 主隊列 可以看到:
- 所有任務都是在當前線程(主線程)中執行的,并沒有開啟新的線程(雖然 異步執行 具備開啟線程的能力,但因為是主隊列,所以所有任務都在主線程中)。
- 所有任務是在打印的 syncConcurrent---begin 和 syncConcurrent---end 之后才開始執行的(異步執行不會做任何等待,可以繼續執行任務)。
- 任務是按順序執行的(因為主隊列是 串行隊列,每次只有一個任務被執行,任務一個接一個按順序執行)。
4. GCD 線程間的通信
在 iOS 開發過程中,我們一般在主線程里邊進行 UI 刷新,例如:點擊、滾動、拖拽等事件。我們通常把一些耗時的操作放在其他線程,比如說圖片下載、文件上傳等耗時操作。而當我們有時候在其他線程完成了耗時操作時,需要回到主線程,那么就用到了線程之間的通訊。
/*** 線程間通信*/ - (void)communication {// 獲取全局并發隊列dispatch_queue_t queue = dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0);// 獲取主隊列dispatch_queue_t mainQueue = dispatch_get_main_queue();dispatch_async(queue, ^{// 異步追加任務 1[NSThread sleepForTimeInterval:2]; // 模擬耗時操作NSLog(@"1---%@",[NSThread currentThread]); // 打印當前線程// 回到主線程dispatch_async(mainQueue, ^{// 追加在主線程中執行的任務[NSThread sleepForTimeInterval:2]; // 模擬耗時操作NSLog(@"2---%@",[NSThread currentThread]); // 打印當前線程});}); }輸出結果:
?1---<NSThread: 0x60000432a580>{number = 3, name = (null)}
?2---<NSThread: 0x60000431e320>{number = 1, name = main}
- 可以看到在其他線程中先執行任務,執行完了之后回到主線程執行主線程的相應操作。
5. GCD 的其他方法
5.1 GCD 柵欄方法:dispatch_barrier_async
我們有時需要異步執行兩組操作,而且第一組操作執行完之后,才能開始執行第二組操作。這樣我們就需要一個相當于 柵欄 一樣的一個方法將兩組異步執行的操作組給分割起來,當然這里的操作組里可以包含一個或多個任務。這就需要用到dispatch_barrier_async 方法在兩個操作組間形成柵欄。
dispatch_barrier_async 方法會等待前邊追加到并發隊列中的任務全部執行完畢之后,再將指定的任務追加到該異步隊列中。然后在 dispatch_barrier_async 方法追加的任務執行完畢之后,異步隊列才恢復為一般動作,接著追加任務到該異步隊列并開始執行。具體如下圖所示:
輸出結果:
?1---<NSThread: 0x6000057a3210>{number = 3, name = (null)}
?2---<NSThread: 0x600005a23440>{number = 4, name = (null)}
?barrier---<NSThread: 0x6000057a3210>{number = 3, name = (null)}
?4---<NSThread: 0x600005a23440>{number = 4, name = (null)}
?3---<NSThread: 0x6000057a3210>{number = 3, name = (null)}
在?dispatch_barrier_async?執行結果中可以看出:
- 在執行完柵欄前面的操作之后,才執行柵欄操作,最后再執行柵欄后邊的操作。
5.2 GCD 延時執行方法:dispatch_after
我們經常會遇到這樣的需求:在指定時間(例如 3 秒)之后執行某個任務。可以用 GCD 的dispatch_after 方法來實現。
需要注意的是:dispatch_after 方法并不是在指定時間之后才開始執行處理,而是在指定時間之后將任務追加到主隊列中。嚴格來說,這個時間并不是絕對準確的,但想要大致延遲執行任務,dispatch_after 方法是很有效的。
輸出結果:
?currentThread---<NSThread: 0x600003c45270>{number = 1, name = main}
?asyncMain---begin
?after---<NSThread: 0x600003c45270>{number = 1, name = main}
5.3 GCD 一次性代碼(只執行一次):dispatch_once
我們在創建單例、或者有整個程序運行過程中只執行一次的代碼時,我們就用到了 GCD 的 dispatch_once 方法。使用 dispatch_once 方法能保證某段代碼在程序運行過程中只被執行 1 次,并且即使在多線程的環境下,dispatch_once 也可以保證線程安全。
/*** 一次性代碼(只執行一次)dispatch_once*/ - (void)once {static dispatch_once_t onceToken;dispatch_once(&onceToken, ^{// 只執行 1 次的代碼(這里面默認是線程安全的)}); }5.4 GCD 快速迭代方法:dispatch_apply
通常我們會用 for 循環遍歷,但是 GCD 給我們提供了快速迭代的方法 dispatch_apply。dispatch_apply 按照指定的次數將指定的任務追加到指定的隊列中,并等待全部隊列執行結束。
如果是在串行隊列中使用 dispatch_apply,那么就和 for 循環一樣,按順序同步執行。但是這樣就體現不出快速迭代的意義了。
我們可以利用并發隊列進行異步執行。比如說遍歷 0~5 這 6 個數字,for 循環的做法是每次取出一個元素,逐個遍歷。dispatch_apply 可以 在多個線程中同時(異步)遍歷多個數字。
還有一點,無論是在串行隊列,還是并發隊列中,dispatch_apply 都會等待全部任務執行完畢,這點就像是同步操作,也像是隊列組中的 dispatch_group_wait方法。
/*** 快速迭代方法 dispatch_apply*/ - (void)apply {dispatch_queue_t queue = dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0);NSLog(@"apply---begin");dispatch_apply(6, queue, ^(size_t index) {NSLog(@"%zd---%@",index, [NSThread currentThread]);});NSLog(@"apply---end"); }因為是在并發隊列中異步執行任務,所以各個任務的執行時間長短不定,最后結束順序也不定。但是?apply---end?一定在最后執行。這是因為?dispatch_apply?方法會等待全部任務執行完畢。
5.5 GCD 隊列組:dispatch_group
有時候我們會有這樣的需求:分別異步執行2個耗時任務,然后當2個耗時任務都執行完畢后再回到主線程執行任務。這時候我們可以用到 GCD 的隊列組。
- 調用隊列組的 dispatch_group_async 先把任務放到隊列中,然后將隊列放入隊列組中。或者使用隊列組的 dispatch_group_enter、dispatch_group_leave 組合來實現 dispatch_group_async。
- 調用隊列組的 dispatch_group_notify 回到指定線程執行任務。或者使用 dispatch_group_wait 回到當前線程繼續向下執行(會阻塞當前線程)。
5.5.1 dispatch_group_notify
- 監聽 group 中任務的完成狀態,當所有的任務都執行完成后,追加任務到 group 中,并執行任務。
輸出結果:
?currentThread---<NSThread: 0x600005c4567ea0>{number = 1, name = main}
?group---begin
?2---<NSThread: 0x600005c64a33c0>{number = 4, name = (null)}
?1---<NSThread: 0x600005c53ea210>{number = 3, name = (null)}
?3---<NSThread: 0x600005c4567ea0>{number = 1, name = main}
?group---end
從?dispatch_group_notify?相關代碼運行輸出結果可以看出:
當所有任務都執行完成之后,才執行?dispatch_group_notify?相關 block 中的任務。
5.5.2 dispatch_group_wait
暫停當前線程(阻塞當前線程),等待指定的 group 中的任務執行完成后,才會往下繼續執行。
/*** 隊列組 dispatch_group_wait*/ - (void)groupWait {NSLog(@"currentThread---%@",[NSThread currentThread]); // 打印當前線程NSLog(@"group---begin");dispatch_group_t group = dispatch_group_create();dispatch_group_async(group, dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0), ^{// 追加任務 1[NSThread sleepForTimeInterval:2]; // 模擬耗時操作NSLog(@"1---%@",[NSThread currentThread]); // 打印當前線程});dispatch_group_async(group, dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0), ^{// 追加任務 2[NSThread sleepForTimeInterval:2]; // 模擬耗時操作NSLog(@"2---%@",[NSThread currentThread]); // 打印當前線程});// 等待上面的任務全部完成后,會往下繼續執行(會阻塞當前線程)dispatch_group_wait(group, DISPATCH_TIME_FOREVER);NSLog(@"group---end");}輸出結果:
?currentThread---<NSThread: 0x6000032a5680>{number = 1, name = main}
?group---begin
?2---<NSThread: 0x6000032e2440>{number = 4, name = (null)}
?1---<NSThread: 0x6000032c5630>{number = 3, name = (null)}
?group---end
從 dispatch_group_wait 相關代碼運行輸出結果可以看出:
當所有任務執行完成之后,才執行 dispatch_group_wait 之后的操作。但是,使用dispatch_group_wait 會阻塞當前線程。
5.5.3 dispatch_group_enter、dispatch_group_leave
dispatch_group_enter 標志著一個任務追加到 group,執行一次,相當于 group 中未執行完畢任務數 +1
dispatch_group_leave 標志著一個任務離開了 group,執行一次,相當于 group 中未執行完畢任務數 -1。
當 group 中未執行完畢任務數為0的時候,才會使 dispatch_group_wait 解除阻塞,以及執行追加到 dispatch_group_notify 中的任務。
輸出結果:
?currentThread---<NSThread: 0x600006ac6730>{number = 1, name = main}
?group---begin
?2---<NSThread: 0x600006a23240>{number = 3, name = (null)}
?1---<NSThread: 0x600006a56460>{number = 4, name = (null)}
?3---<NSThread: 0x600006ac6730>{number = 1, name = main}
?group---end
從 dispatch_group_enter、dispatch_group_leave 相關代碼運行結果中可以看出:當所有任務執行完成之后,才執行 dispatch_group_notify 中的任務。這里的dispatch_group_enter、dispatch_group_leave 組合,其實等同于dispatch_group_async。
5.6 GCD 信號量:dispatch_semaphore
GCD 中的信號量是指 Dispatch Semaphore,是持有計數的信號。類似于過高速路收費站的欄桿。可以通過時,打開欄桿,不可以通過時,關閉欄桿。在 Dispatch Semaphore 中,使用計數來完成這個功能,計數小于 0 時等待,不可通過。計數為 0 或大于 0 時,計數減 1 且不等待,可通過。
Dispatch Semaphore?提供了三個方法:
- dispatch_semaphore_create:創建一個 Semaphore 并初始化信號的總量
- dispatch_semaphore_signal:發送一個信號,讓信號總量加 1
- dispatch_semaphore_wait:可以使總信號量減 1,信號總量小于 0 時就會一直等待(阻塞所在線程),否則就可以正常執行。
注意:信號量的使用前提是:想清楚你需要處理哪個線程等待(阻塞),又要哪個線程繼續執行,然后使用信號量。
Dispatch Semaphore 在實際開發中主要用于:
- 保持線程同步,將異步執行任務轉換為同步執行任務
- 保證線程安全,為線程加鎖
5.6.1 Dispatch Semaphore 線程同步
我們在開發中,會遇到這樣的需求:異步執行耗時任務,并使用異步執行的結果進行一些額外的操作。換句話說,相當于,將將異步執行任務轉換為同步執行任務。比如說:AFNetworking 中 AFURLSessionManager.m 里面的 tasksForKeyPath: 方法。通過引入信號量的方式,等待異步執行任務結果,獲取到 tasks,然后再返回該 tasks。
- (NSArray *)tasksForKeyPath:(NSString *)keyPath {__block NSArray *tasks = nil;dispatch_semaphore_t semaphore = dispatch_semaphore_create(0);[self.session getTasksWithCompletionHandler:^(NSArray *dataTasks, NSArray *uploadTasks, NSArray *downloadTasks) {if ([keyPath isEqualToString:NSStringFromSelector(@selector(dataTasks))]) {tasks = dataTasks;} else if ([keyPath isEqualToString:NSStringFromSelector(@selector(uploadTasks))]) {tasks = uploadTasks;} else if ([keyPath isEqualToString:NSStringFromSelector(@selector(downloadTasks))]) {tasks = downloadTasks;} else if ([keyPath isEqualToString:NSStringFromSelector(@selector(tasks))]) {tasks = [@[dataTasks, uploadTasks, downloadTasks] valueForKeyPath:@"@unionOfArrays.self"];}dispatch_semaphore_signal(semaphore);}];dispatch_semaphore_wait(semaphore, DISPATCH_TIME_FOREVER);return tasks; }下面,我們來利用 Dispatch Semaphore 實現線程同步,將異步執行任務轉換為同步執行任務。
/*** semaphore 線程同步*/ - (void)semaphoreSync {NSLog(@"currentThread---%@",[NSThread currentThread]); // 打印當前線程NSLog(@"semaphore---begin");dispatch_queue_t queue = dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0);dispatch_semaphore_t semaphore = dispatch_semaphore_create(0);__block int number = 0;dispatch_async(queue, ^{// 追加任務 1[NSThread sleepForTimeInterval:2]; // 模擬耗時操作NSLog(@"1---%@",[NSThread currentThread]); // 打印當前線程number = 100;dispatch_semaphore_signal(semaphore);});dispatch_semaphore_wait(semaphore, DISPATCH_TIME_FOREVER);NSLog(@"semaphore---end,number = %zd",number); }輸出結果:
?currentThread---<NSThread: 0x60000567a530>{number = 1, name = main}
?semaphore---begin
?1---<NSThread: 0x6000057ea540>{number = 3, name = (null)}
?semaphore---end,number = 100
從 Dispatch Semaphore 實現線程同步的代碼可以看到:
semaphore---end 是在執行完 number = 100; 之后才打印的。而且輸出結果 number 為 100。這是因為 異步執行 不會做任何等待,可以繼續執行任務。
執行順如下:
這樣就實現了線程同步,將異步執行任務轉換為同步執行任務。
5.6.2 Dispatch Semaphore 線程安全和線程同步(為線程加鎖)
線程安全:如果你的代碼所在的進程中有多個線程在同時運行,而這些線程可能會同時運行這段代碼。如果每次運行結果和單線程運行的結果是一樣的,而且其他的變量的值也和預期的是一樣的,就是線程安全的。
若每個線程中對全局變量、靜態變量只有讀操作,而無寫操作,一般來說,這個全局變量是線程安全的;若有多個線程同時執行寫操作(更改變量),一般都需要考慮線程同步,否則的話就可能影響線程安全。
線程同步:可理解為線程 A 和 線程 B 一塊配合,A 執行到一定程度時要依靠線程 B 的某個結果,于是停下來,示意 B 運行;B 依言執行,再將結果給 A;A 再繼續操作。
舉個簡單例子就是:兩個人在一起聊天。兩個人不能同時說話,避免聽不清(操作沖突)。等一個人說完(一個線程結束操作),另一個再說(另一個線程再開始操作)。
下面,我們模擬火車票售賣的方式,實現 NSThread 線程安全和解決線程同步問題。
場景:總共有 100 張火車票,有兩個售賣火車票的窗口,一個是北京火車票售賣窗口,另一個是上海火車票售賣窗口。兩個窗口同時售賣火車票,賣完為止。
5.6.2.1 非線程安全(不使用 semaphore)
先來看看不考慮線程安全的代碼:
/*** 非線程安全:不使用 semaphore* 初始化火車票數量、賣票窗口(非線程安全)、并開始賣票*/ - (void)initTicketStatusNotSave {NSLog(@"currentThread---%@",[NSThread currentThread]); // 打印當前線程NSLog(@"semaphore---begin");self.ticketSurplusCount = 100;// queue1 代表北京火車票售賣窗口dispatch_queue_t queue1 = dispatch_queue_create("com.hiccup.myQueue1", DISPATCH_QUEUE_SERIAL);// queue2 代表上海火車票售賣窗口dispatch_queue_t queue2 = dispatch_queue_create("com.hiccup.myQueue2", DISPATCH_QUEUE_SERIAL);__weak typeof(self) weakSelf = self;dispatch_async(queue1, ^{[weakSelf saleTicketNotSafe];});dispatch_async(queue2, ^{[weakSelf saleTicketNotSafe];}); }/*** 售賣火車票(非線程安全)*/ - (void)saleTicketNotSafe {while (1) {if (self.ticketSurplusCount > 0) { // 如果還有票,繼續售賣self.ticketSurplusCount--;NSLog(@"%@", [NSString stringWithFormat:@"剩余票數:%d 窗口:%@", self.ticketSurplusCount, [NSThread currentThread]]);[NSThread sleepForTimeInterval:0.2];} else { // 如果已賣完,關閉售票窗口NSLog(@"所有火車票均已售完");break;}} }輸出結果(部分):
?currentThread---<NSThread: 0x6000056787a0>{number = 1, name = main}
?semaphore---begin
?剩余票數:98 窗口:<NSThread: 0x6000015cc600>{number = 4, name = (null)}
?剩余票數:99 窗口:<NSThread: 0x6000015f8600>{number = 3, name = (null)}
?剩余票數:97 窗口:<NSThread: 0x6000015f8600>{number = 3, name = (null)}
?剩余票數:947 窗口:<NSThread: 0x6000015cc600>{number = 4, name = (null)}
?剩余票數:96 窗口:<NSThread: 0x6000015cc600>{number = 4, name = (null)}
...
可以看到在不考慮線程安全,不使用 semaphore 的情況下,得到票數是錯亂的,這樣顯然不符合我們的需求,所以我們需要考慮線程安全問題。
5.6.2.2 線程安全(使用 semaphore 加鎖)
考慮線程安全的代碼:
/*** 線程安全:使用 semaphore 加鎖* 初始化火車票數量、賣票窗口(線程安全)、并開始賣票*/ - (void)initTicketStatusSave {NSLog(@"currentThread---%@",[NSThread currentThread]); // 打印當前線程NSLog(@"semaphore---begin");semaphoreLock = dispatch_semaphore_create(1);self.ticketSurplusCount = 100;// queue1 代表北京火車票售賣窗口dispatch_queue_t queue1 = dispatch_queue_create("com.hiccup.myQueue1", DISPATCH_QUEUE_SERIAL);// queue2 代表上海火車票售賣窗口dispatch_queue_t queue2 = dispatch_queue_create("com.hiccup.myQueue2", DISPATCH_QUEUE_SERIAL);__weak typeof(self) weakSelf = self;dispatch_async(queue1, ^{[weakSelf saleTicketSafe];});dispatch_async(queue2, ^{[weakSelf saleTicketSafe];}); }/*** 售賣火車票(線程安全)*/ - (void)saleTicketSafe {while (1) {// 相當于加鎖dispatch_semaphore_wait(semaphoreLock, DISPATCH_TIME_FOREVER);if (self.ticketSurplusCount > 0) { // 如果還有票,繼續售賣self.ticketSurplusCount--;NSLog(@"%@", [NSString stringWithFormat:@"剩余票數:%d 窗口:%@", self.ticketSurplusCount, [NSThread currentThread]]);[NSThread sleepForTimeInterval:0.2];} else { // 如果已賣完,關閉售票窗口NSLog(@"所有火車票均已售完");// 相當于解鎖dispatch_semaphore_signal(semaphoreLock);break;}// 相當于解鎖dispatch_semaphore_signal(semaphoreLock);} }輸出結果為:
?currentThread---<NSThread: 0x600000681380>{number = 1, name = main}
?semaphore---begin
?剩余票數:49 窗口:<NSThread: 0x6000006ede80>{number = 3, name = (null)}
?剩余票數:48 窗口:<NSThread: 0x6000006e4b40>{number = 4, name = (null)}
...
?剩余票數:1 窗口:<NSThread: 0x6000006ede80>{number = 3, name = (null)}
?剩余票數:0 窗口:<NSThread: 0x6000006e4b40>{number = 4, name = (null)}
?所有火車票均已售完
?所有火車票均已售完
可以看出,在考慮了線程安全的情況下,使用?dispatch_semaphore?機制之后,得到的票數是正確的,沒有出現混亂的情況。我們也就解決了多個線程同步的問題。
參考資料:
- 書籍:『Objective-C 高級編程 iOS 與 OS X 多線程和內存管理』
- 博文:iOS GCD 之 dispatch_semaphore(信號量)
總結
以上是生活随笔為你收集整理的iOS进阶 - GCD总结的全部內容,希望文章能夠幫你解決所遇到的問題。
- 上一篇: Symbol 函数
- 下一篇: 万有引力的意思_万有引力的本质是什么?