當(dāng)我們?cè)谔幚矶嗑€程的時(shí)候,如果想控制并發(fā)線程的數(shù)量,我們會(huì)使用NSOperationQueue的maxConcurrentOperationCount來(lái)進(jìn)行控制,所以遇到此類問題,我們一般會(huì)使用NSOperation+ NSOperationQueue來(lái)解決。
我們也可以使用GCD來(lái)解決這個(gè)問題,就是配合dispatch_semaphore來(lái)使用。
dispatch_semaphore就是信號(hào)量,在以前的Linux開發(fā)中就已經(jīng)用過(guò)。信號(hào)量是一個(gè)整形值,在初始化的時(shí)候分配一個(gè)初始值,支持兩個(gè)操作信號(hào)通知和等待。
等待
// 返回0:表示正常。返回非0:表示等待時(shí)間超時(shí)
long dispatch_semaphore_wait(dispatch_semaphore_t dsema, dispatch_time_t timeout);
信號(hào)通知
long dispatch_semaphore_signal(dispatch_semaphore_t dsema);
創(chuàng)建信號(hào)量
// 值得注意的是,這里的傳入的參數(shù)value必須大于或等于0,否則dispatch_semaphore_create會(huì)返回NULL
dispatch_semaphore_t dispatch_semaphore_create(long value);
- 當(dāng)一個(gè)信號(hào)量被通知
dispatch_semaphore_signal,計(jì)數(shù)會(huì)加1;- 如果一個(gè)線程等待一個(gè)信號(hào)量
dispatch_semaphore_wait,線程會(huì)被阻塞,直到計(jì)數(shù)器>0,此時(shí)開始運(yùn)行,并且對(duì)信號(hào)量減1。
這樣我們就可以根據(jù) 初始值 ,來(lái)控制可以有多少個(gè)并發(fā)的線程在運(yùn)行。關(guān)于信號(hào)量,可以用停車位來(lái)比喻,如果停車場(chǎng)有5個(gè)停車位,都停滿了,如果此時(shí)來(lái)了第6輛車,就需要等待,信號(hào)量的值就相當(dāng)于剩余的車位的數(shù)量。dispatch_semaphore_wait函數(shù)就相當(dāng)于來(lái)了一輛車,dispatch_semaphore_signal就相當(dāng)于走了一輛車。
dispatch_semaphore_wait中的參數(shù)timeout表示超時(shí)時(shí)間,如果等待期間沒有獲取到信號(hào)量或者信號(hào)量的值一直為0,那么等到timeout時(shí),其所處線程自動(dòng)執(zhí)行其后語(yǔ)句??扇≈禐椋?code>DISPATCH_TIME_NOW和 DISPATCH_TIME_FOREVER,我們也可以自己設(shè)置一個(gè)dispatch_time_t的時(shí)間值,表示超時(shí)時(shí)間為這個(gè)時(shí)間之后。
- DISPATCH_TIME_NOW:超時(shí)時(shí)間為0,表示忽略信號(hào)量,直接運(yùn)行
- ** DISPATCH_TIME_FOREVER**:超時(shí)時(shí)間為永遠(yuǎn),表示會(huì)一直等待信號(hào)量為正數(shù),才會(huì)繼續(xù)運(yùn)行
來(lái)看一個(gè)具體的例子:

信號(hào)量的初始值設(shè)置為:1,即最多只能又一個(gè)線程在run,可以驗(yàn)證一下運(yùn)行結(jié)果,除去最開始的三個(gè),后面的是每三秒打印一個(gè),并且保證運(yùn)行的順序按照添加的順序。

如果把創(chuàng)建信號(hào)量的值設(shè)置為4,即最多可以有4個(gè)線程同時(shí)運(yùn)行,來(lái)看一下運(yùn)行結(jié)果,是每三秒同時(shí)打印四個(gè),且順序不能保證。
