記得之前有講解過iOS多線程的處理,當時使用GCD的時候還有很多沒有講太清楚的地方,今天做一個小小的補充: 使用NSOperationQueue可以控制并發線程,但是如何在GCD中快速的控制并發呢?這里就需要使用到信號量(dispatch_semaphore)。信號量是一個整型值并且具有一個初始計數值,并且支持兩個操作:信號通知與等待。當一個信號被信號通知,其技術會被增加。當一個線程在一個信號量上等待時,線程會被阻塞,直至計數器大于零,然后線程會減少這個計數。GCD中有三個函數與信號量(dispatch_semaphore)相關,分別是 dispatch_semaphore_create 創建一個semaphore dispatch_semaphore_signal 發送一個信號 dispatch_semaphore_wait 等待信號 簡單的介紹一下這三個函數,第一個函數有一個整形的參數,我們可以理解為信號的總量,dispatch_semaphore_signal是發送一個信號,自然會讓信號總量加1,dispatch_semaphore_wait等待信號,當信號總量少于0的時候就會一直等待,否則就可以正常的執行,并讓信號總量-1,根據這樣的原理,我們便可以快速的創建一個并發控制來同步任務和有限資源訪問控制。
// 創建隊列組 dispatch_group_t group = dispatch_group_create(); // 創建信號量,并且設置值為10 dispatch_semaphore_t semaphore = dispatch_semaphore_create(10); dispatch_queue_t queue = dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0); for (int i = 0; i < 100; i++) { // 由于是異步執行的,所以每次循環Block里面的dispatch_semaphore_signal根本還沒有執行就會執行dispatch_semaphore_wait,從而semaphore-1.當循環10此后,semaphore等于0,則會阻塞線程,直到執行了Block的dispatch_semaphore_signal 才會繼續執行 dispatch_semaphore_wait(semaphore, DISPATCH_TIME_FOREVER); dispatch_group_async(group, queue, ^{ NSLog(@"%i",i); sleep(2); // 每次發送信號則semaphore會+1, dispatch_semaphore_signal(semaphore); }); } dispatch_group_wait(group, DISPATCH_TIME_FOREVER); dispatch_release(group); dispatch_release(semaphore);簡單的介紹一下這一段代碼,創建了一個初使值為10的semaphore,每一次for循環都會創建一個新的線程,線程結束的時候會發送一個信號,線程創建之前會信號等待,所以當同時創建了10個線程之后,for循環就會阻塞,等待有線程結束之后會增加一個信號才繼續執行,如此就形成了對并發的控制,如上就是一個并發數為10的一個線程隊列。
新聞熱點
疑難解答