GCD,全程Grand Central Dispatch,是蘋果為了多核並行提出的解決方案。它是使用C語言實現,但是由於用了block來處理回調,所以使用起來十分方便。並且GCD會自動管理線程的生命周期,不需要我們去管理。
GCD中有兩個重要的概念,任務和隊列。
1、任務,就是我們想要處理的事情,任務可以分為同步執行和異步執行:
同步(sync):使用dispatch_sync(dispatch_queue_t queue, dispatch_block_t block) 創建,同步執行任務時會阻塞當前線程等待block執行完畢返回。然後當前線程才會繼續執行下去。
異步(async):使用dispatch_async(dispatch_queue_t queue, dispatch_block_t block)創建,異步任務不會阻塞當前線程,任務創建後立即返回線程往下執行。
2、隊列,存放任務,並將任務由先入先出地派發出去。分為串行隊列和並行隊列:
串行隊列(Serial queue):隊列中的任務根據創建順序,先入先出地執行,等待上一個任務執行完畢後,才會執行下一個任務,有嚴格的執行先後順序。
並行隊列(Concurrent queue):隊列會根據先後順序,將任務派發出去,並行執行。所有的任務幾乎都是一起執行的。不過需要注意,GCD 會根據系統資源控制並行的數量,所以如果任務很多,它並不會讓所有任務同時執行。有一個表,可以大體說明任務和隊列之間的配合使用:
串行隊列 並行隊列 同步執行任務 當前線程,一個一個執行 當前線程,一個一個執行 異步執行任務 另開線程,一個一個執行 開很多線程,一起執行 下面是任務和隊列的使用演示:
/** * 串行隊列中的任務會等待正在執行的任務執行結束,排隊執行 */ dispatch_queue_t serial_queue = dispatch_queue_create("serial.queue", DISPATCH_QUEUE_SERIAL); //主隊列 dispatch_queue_t mainQueue = dispatch_get_main_queue(); /** * 並行,不等待正在執行的任務的處理結果,可以並發執行多個任務 */ dispatch_queue_t concurrent_queue = dispatch_queue_create("concurrent.queue", DISPATCH_QUEUE_CONCURRENT); //全局隊列 dispatch_queue_t globalQueue = dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0); //在串行隊列中創建幾個同步任務,在主線程順序執行 dispatch_sync(serial_queue, ^{ NSLog(@"task a ,thread:%@",[NSThread currentThread]); }); dispatch_sync(serial_queue, ^{ NSLog(@"task b ,thread:%@",[NSThread currentThread]); }); dispatch_sync(serial_queue, ^{ NSLog(@"task c ,thread:%@",[NSThread currentThread]); }); //在串行隊列中創建幾個異步任務,在主線程順序執行 dispatch_sync(serial_queue, ^{ NSLog(@"task aa ,thread:%@",[NSThread currentThread]); }); dispatch_sync(serial_queue, ^{ NSLog(@"task bb ,thread:%@",[NSThread currentThread]); }); dispatch_sync(serial_queue, ^{ NSLog(@"task cc ,thread:%@",[NSThread currentThread]); }); //在串行隊列中創建幾個異步任務,另開1個線程順序執行 dispatch_async(serial_queue, ^{ NSLog(@"task 1 ,thread:%@",[NSThread currentThread]); }); dispatch_async(serial_queue, ^{ NSLog(@"task 1 ,thread:%@",[NSThread currentThread]); }); dispatch_async(serial_queue, ^{ NSLog(@"task 1 ,thread:%@",[NSThread currentThread]); }); //在並隊列中創建幾個異步任務,另開多個線程同時執行 dispatch_async(concurrent_queue, ^{ NSLog(@"task 11 ,thread:%@",[NSThread currentThread]); }); dispatch_async(concurrent_queue, ^{ NSLog(@"task 22 ,thread:%@",[NSThread currentThread]); }); dispatch_async(concurrent_queue, ^{ NSLog(@"task 33 ,thread:%@",[NSThread currentThread]); });
有時候當我們想要為多個任務添加依賴關系的時候,就可以使用任務組dispatch_group和dispatch_barrier。
任務組是將若干個任務放在一個group 中,這些任務可以在同一隊列也可以在不同隊列,然後用dispatch_group_notify()和dispatch_group_wait()對任務組中任務的完成進行處理。
1、dispatch_group_notify()中的任務會在group中多有任務執行完畢後執行
dispatch_group_t group = dispatch_group_create(); /** * group中所有任務任務執行完畢後,執行dispatch_group_notify中的任務 */ dispatch_group_async(group, serial_queue, ^{ sleep(2); NSLog(@"serial_queue1"); }); dispatch_group_async(group, serial_queue, ^{ sleep(2); NSLog(@"serial_queue2"); }); dispatch_group_async(group, concurrent_queue, ^{ sleep(2); NSLog(@"concurrent_queue1"); }); dispatch_group_notify(group, dispatch_get_main_queue(), ^{ NSLog(@"return main queue"); });
2、dispatch_group_wait()中可傳入一個給定時間,如果在等待時間結束前group所有任務執行完畢則返回0,否則返回非0,這個函數是一個同步任務
/** * dispatch_group_wait給定一個時間,如果在等待時間結束前group所有任務執行完畢則返回0,否則返回非0,這個函數是一個同步任務 */ dispatch_group_async(group, serial_queue, ^{ sleep(3); NSLog(@"serial_queue1"); }); dispatch_group_async(group, serial_queue, ^{ sleep(2); NSLog(@"serial_queue2"); }); dispatch_group_async(group, concurrent_queue, ^{ sleep(3); NSLog(@"concurrent_queue1"); }); long i = dispatch_group_wait(group, dispatch_time(DISPATCH_TIME_NOW, NSEC_PER_SEC * 6)); NSLog(@"-- %ld --",i); dispatch_group_async(group, concurrent_queue, ^{ NSLog(@"finish all"); });
3、可以使用dispatch_group_enter()和dispatch_group_leave()來添加任務組的任務,兩者必須要成對出現,兩個函數之間的代碼便是要加入任務住的任務
/** * 使用dispatch_group_enter和dispatch_group_leave添加組任務,兩者必須要成對出現 */ dispatch_group_enter(group); sleep(2); NSLog(@"1"); dispatch_group_leave(group); dispatch_group_enter(group); dispatch_async(concurrent_queue, ^{ sleep(3); NSLog(@"2"); dispatch_group_leave(group); }); dispatch_group_enter(group); sleep(2); NSLog(@"3"); dispatch_group_leave(group); long i = dispatch_group_wait(group, dispatch_time(DISPATCH_TIME_NOW, NSEC_PER_SEC * 6)); NSLog(@"-- %ld --",i); dispatch_group_async(group, concurrent_queue, ^{ NSLog(@"finish all"); });
柵欄是將一個隊列中的任務分割成兩部分,在柵欄任務之前添加的任務全部執行完畢後,單獨執行柵欄任務,執行完畢後,再繼續執行後面的任務。柵欄必須單獨執行,不能與其他任務並發執行,因此,柵欄只對並發隊列有意義。柵欄只有等待當前隊列所有並發任務都執行完畢後,才會單獨執行,待其執行完畢,再按照正常的方式繼續向下執行。
dispatch_queue_t concurrent_queue = dispatch_queue_create("concurrent.queue", DISPATCH_QUEUE_CONCURRENT); dispatch_async(concurrent_queue, ^{ sleep(2); NSLog(@"1"); }); dispatch_async(concurrent_queue, ^{ sleep(2); NSLog(@"2"); }); dispatch_async(concurrent_queue, ^{ sleep(2); NSLog(@"3"); }); dispatch_barrier_async(concurrent_queue, ^{ sleep(2); NSLog(@"barrier"); }); dispatch_async(concurrent_queue, ^{ sleep(2); NSLog(@"finish1"); }); dispatch_async(concurrent_queue, ^{ NSLog(@"finish2"); });
dispatch_apply()是將一個任務提交到隊列中重復執行,並行或者串行由隊列決定,dispatch_apply會阻塞當前線程,等到所有任務完成後返回
dispatch_queue_t concurrent_queue = dispatch_queue_create("concurrent.queue", DISPATCH_QUEUE_CONCURRENT); dispatch_apply(5, concurrent_queue, ^(size_t index) { sleep(1); NSLog(@"index:%zu",index); }); NSLog(@"finish");
dispatch_once()確保block內代碼在整個應用運行期間只執行一次
//確保block內代碼在整個應用運行期間只執行一次 static dispatch_once_t onceToken; dispatch_once(&onceToken, ^{ NSLog(@"just run once in application"); });
多線程處理經常需要考慮到資源搶占的問題,比如經典的購票問題,寫數據庫等問題。處理問題的辦法有很多,下面介紹最簡單的兩種做法:加上同步鎖,或者用信號量來解決。
同步鎖,每當有線程訪問鎖裡的資源時,會將此部分鎖住,拒絕其他線程訪問。直到占用的線程推出後才解鎖,允許其他資源訪問。
//同步鎖,對block內的代碼加鎖,同一時間內只允許一個線程訪問 @synchronized(self) { NSLog(@"lock"); };
信號量dispatch_semaphore,一開始設置信號的總量,然後用dispatch_semaphore_wait()和dispatch_semaphore_signal()來管理信號量,達到控制線程訪問的目的
//信號量dispatch_semaphore dispatch_group_t group = dispatch_group_create(); //設置總信號量 dispatch_semaphore_t semaphore = dispatch_semaphore_create(10); for (int i = 0; i<100; i++) { //設置等待信號,如果此時信號量大於0,那麼信號量減一並繼續往下執行 //如果此時信號量小於0,會一直等待,直到超時 //如果超時返回非零,成功執行返回0 dispatch_semaphore_wait(semaphore, dispatch_time(DISPATCH_TIME_NOW, NSEC_PER_SEC*50)); dispatch_group_async(group, concurrent_queue, ^{ sleep(1); NSLog(@"%d",i); //發送信號,讓信號量加一 dispatch_semaphore_signal(semaphore); }); } dispatch_group_notify(group, concurrent_queue, ^{ NSLog(@"finish"); });
GCD盡管使用起來非常方便,但是如果使用不當也活造成一些麻煩,下面列舉幾個會造成線程死鎖的場合:
//在並行隊列中,在當前隊列調用dispatch_sync,並傳入當前隊列執行,並不會造成deadlock。dispatch_sync會阻塞當前線程,但是由於隊列是並行執行,所以block中的任務會馬上執行後返回。 - (void)syncAndConcurrentQueue { dispatch_queue_t queue = dispatch_queue_create("concurrent.queue", DISPATCH_QUEUE_CONCURRENT); dispatch_sync(queue, ^{ NSLog(@"Jump to concurrent.queue! ,thread:%@",[NSThread currentThread]); dispatch_sync(queue, ^{ sleep(3); NSLog(@"success6 ,thread:%@",[NSThread currentThread]); }); NSLog(@"return"); }); } //在串行隊列中,在當前隊列調用dispatch_sync,並傳入當前隊列執行,會造成deadlock。 dispatch_sync會阻塞當前線程,等待block中的任務執行完之後再繼續執行,但是由於隊列是串行執行,block中的任務放在最後,所以永遠沒有機會執行,線程死鎖 - (void)synAndSerialQueue { dispatch_queue_t queue = dispatch_queue_create("serial.queue", DISPATCH_QUEUE_SERIAL); dispatch_async(queue, ^{ NSLog(@"Jump to serial.queue!"); dispatch_sync(queue, ^{ NSLog(@"success"); }); NSLog(@"return"); }); } //任務1會阻塞主線程,直到block中執行完畢返回,任務二在主線程添加了了一個同步任務,阻塞當前線程,知道任務執行完畢返回,而任務2沒有機會被執行。造成兩條線程死鎖。 - (void)recycle { dispatch_queue_t concurrent_queue = dispatch_queue_create("concurrent.queue", DISPATCH_QUEUE_CONCURRENT); //任務1 dispatch_sync(concurrent_queue, ^{ NSLog(@"jump to concurrent queue"); //任務2 dispatch_sync(dispatch_get_main_queue(), ^{ NSLog(@"return main queue"); }); }); }
以上是使用GCD的一些心得,GCD使用起來盡管十分便利,但是在處理一些場景比如取消任務時候會很麻煩,所以實現簡單功能的時候推薦使用GCD,如果功能復雜的話建議使用NSOperation和NSOperationQueue,NSOperationQueue的底層也是由GCD實現的,完全面向對象,所以使用起來更好理解。下次有空講講NSOperation和NSOperationQueue。以上代碼demo地址:https://github.com/GarenChen/GCDDemo