1. 程式人生 > >iOS 信號量

iOS 信號量

如果 沒有 complete 標識 繼續 次數 www span 超過

信號量就是一個資源計數器,對信號量有兩個操作來達到互斥,分別是P和V操作。 一般情況是這樣進行臨界訪問或互斥訪問的: 設信號量值為1, 當一個進程1運行是,使用資源,進行P操作,即對信號量值減1,也就是資源數少了1個。這是信號量值為0。系統中規定當信號量值為0是,必須等待,知道信號量值不為零才能繼續操作。 這時如果進程2想要運行,那麽也必須進行P操作,但是此時信號量為0,所以無法減1,即不能P操作,也就阻塞。這樣就到到了進程1排他訪問。 當進程1運行結束後,釋放資源,進行V操作。資源數重新加1,這是信號量的值變為1. 這時進程2發現資源數不為0,信號量能進行P操作了,立即執行P操作。信號量值又變為0.次數進程2咱有資源,排他訪問資源。 這就是信號量來控制互斥的原理

定義:

1、信號量:就是一種可用來控制訪問資源的數量的標識,設定了一個信號量,在線程訪問之前,加上信號量的處理,則可告知系統按照我們指定的信號量數量來執行多個線程。

其實,這有點類似鎖機制了,只不過信號量都是系統幫助我們處理了,我們只需要在執行線程之前,設定一個信號量值,並且在使用時,加上信號量處理方法就行了。

2、信號量主要有3個函數,分別是:

//創建信號量,參數:信號量的初值,如果小於0則會返回NULL
dispatch_semaphore_create(信號量值)
 
//等待降低信號量
dispatch_semaphore_wait(信號量,等待時間)
 
//提高信號量
dispatch_semaphore_signal(信號量)

簡單的介紹一下這三個函數,第一個函數有一個整形的參數,我們可以理解為信號的總量,dispatch_semaphore_signal是發送一個信號,自然會讓信號總量加1,dispatch_semaphore_wait等待信號,當信號總量少於0的時候就會一直等待,否則就可以正常的執行,並讓信號總量-1,根據這樣的原理,我們便可以快速的創建一個並發控制來同步任務和有限資源訪問控制。 3、先來一個簡單的例子
 // 創建信號量,並且設置值為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_async(queue, ^{ NSLog(@"信號量-index=%i",i); sleep(2); // 每次發送信號則semaphore會+1, dispatch_semaphore_signal(semaphore); }); }

發現,任務是10個一組,隔2秒執行一組。可以理解為最大並發數為10。

3、是不是有點感覺了,那再來一個例子,就更清楚了

-(void)dispatchSignal{
    //crate的value表示,最多幾個資源可訪問
    dispatch_semaphore_t semaphore = dispatch_semaphore_create(2);    
    dispatch_queue_t quene = dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0);
     
    //任務1
    dispatch_async(quene, ^{
        dispatch_semaphore_wait(semaphore, DISPATCH_TIME_FOREVER);
        NSLog(@"run task 1");
        sleep(1);
        NSLog(@"complete task 1");
        dispatch_semaphore_signal(semaphore);        
    });<br>
    //任務2
    dispatch_async(quene, ^{
        dispatch_semaphore_wait(semaphore, DISPATCH_TIME_FOREVER);
        NSLog(@"run task 2");
        sleep(1);
        NSLog(@"complete task 2");
        dispatch_semaphore_signal(semaphore);        
    });<br>
    //任務3
    dispatch_async(quene, ^{
        dispatch_semaphore_wait(semaphore, DISPATCH_TIME_FOREVER);
        NSLog(@"run task 3");
        sleep(1);
        NSLog(@"complete task 3");
        dispatch_semaphore_signal(semaphore);        
    });    
}

執行結果:

技術分享  

總結:由於設定的信號值為2,先執行兩個線程,等執行完一個,才會繼續執行下一個,保證同一時間執行的線程數不超過2。

這裏我們擴展一下,假設我們設定信號值=1

dispatch_semaphore_t semaphore = dispatch_semaphore_create(1);

那麽結果就是:

技術分享

如果設定信號值=3

dispatch_semaphore_t semaphore = dispatch_semaphore_create(3);

那麽結果就是:

技術分享

其實設定為3,就是不限制線程執行了,因為一共才只有3個線程。

參考資料:

淺談GCD中的信號量

iOS GCD中級篇 - dispatch_semaphore(信號量)的理解及使用

iOS 信號量