iOS-多線程中的信號(hào)量

網(wǎng)絡(luò)請(qǐng)求的任務(wù)是提交給子線程異步處理了,對(duì)于主線程網(wǎng)絡(luò)請(qǐng)求這樣的任務(wù)也就快速執(zhí)行完畢了,但是對(duì)于主線程網(wǎng)絡(luò)請(qǐng)求是一個(gè)任務(wù),處理收到的網(wǎng)絡(luò)響應(yīng)又是一個(gè)任務(wù),注意不要把這兩個(gè)過程混為一談。

我們?cè)谶M(jìn)行網(wǎng)絡(luò)請(qǐng)求的過程中經(jīng)常會(huì)遇到一個(gè)場(chǎng)景,就是需要刷新一個(gè)界面數(shù)據(jù),而這個(gè)界面數(shù)據(jù)需要發(fā)起多個(gè)請(qǐng)求才能獲得,例如:一個(gè)用戶信息界面,包括基本數(shù)據(jù),關(guān)聯(lián)數(shù)據(jù),其他特別數(shù)據(jù)等,這幾種數(shù)據(jù)存在相互依賴的關(guān)系,并且獲取每種數(shù)據(jù)的api不同,需要同時(shí)異步發(fā)起多個(gè)請(qǐng)求。在這種場(chǎng)景下面,就需要有一種線程同步機(jī)制來處理。通常多線程同步用得最多的就是信號(hào)量。不過,直接使用信號(hào)量不但代碼上面相對(duì)松散,還會(huì)存在懸掛等問題。GCD已經(jīng)提供了dispatch_group來很好的實(shí)現(xiàn)同步問題。
下面我們就看看這兩種方式:

一、GCD的信號(hào)量 dispatch_semaphore_t

思路,通過dispatch_group_notify來獲取通知,那么必須保證網(wǎng)絡(luò)請(qǐng)求回調(diào)都執(zhí)行完之后接收到通知,這里是通過dispatch_semaphore來阻塞住group中的任務(wù),直到網(wǎng)絡(luò)請(qǐng)求返回以后再結(jié)束group。

dispatch_group_t group = dispatch_group_create();
    
    dispatch_group_async(group, dispatch_get_global_queue(0, 0), ^{
        dispatch_semaphore_t semaphore1 = dispatch_semaphore_create(0);
        //網(wǎng)絡(luò)請(qǐng)求1
        [NetService getUserIconSuccess:^(id successData) {
            NSLog(@"----------finished");
            dispatch_semaphore_signal(semaphore1);
        } error:^(NSString *errorStr) {
            NSLog(@"----------finished");
            dispatch_semaphore_signal(semaphore1);
        }];
        dispatch_semaphore_wait(semaphore1, DISPATCH_TIME_FOREVER);
    });
    dispatch_group_async(group, dispatch_get_global_queue(0, 0), ^{
        dispatch_semaphore_t semaphore2 = dispatch_semaphore_create(0);
        //網(wǎng)絡(luò)請(qǐng)求2
        [NetService getUserIconSuccess:^(id successData) {
            NSLog(@"----------finished");
            dispatch_semaphore_signal(semaphore2);
        } error:^(NSString *errorStr) {
            NSLog(@"----------finished");
            dispatch_semaphore_signal(semaphore2);
        }];
        dispatch_semaphore_wait(semaphore2, DISPATCH_TIME_FOREVER);
    });
    dispatch_group_notify(group, dispatch_get_main_queue(), ^{
        NSLog(@"兩個(gè)網(wǎng)絡(luò)請(qǐng)求都返回了");
    });

二、dispatch_group_enter、dispatch_group_leave

  • dispatch_group_enter:增加當(dāng)前group執(zhí)行block數(shù)
  • dispatch_group_leave:減少當(dāng)前group執(zhí)行block數(shù)

相當(dāng)于通過我們手動(dòng)調(diào)用enter和leave來告訴group中的是否執(zhí)行結(jié)束了, enter告訴group增加了一個(gè)任務(wù)(可以通過引用計(jì)數(shù)更好理解,+1),leave告訴group結(jié)束了一個(gè)任務(wù)(-1),當(dāng)group中沒有任務(wù)了,就會(huì)執(zhí)行dispatch_group_notify了。
所以,enter和leave必須成對(duì)出現(xiàn)。

dispatch_group_t group = dispatch_group_create();
    dispatch_group_enter(group);
    //網(wǎng)絡(luò)請(qǐng)求1
    [NetService getUserIconSuccess:^(id successData) {
        NSLog(@"----------finished");
        dispatch_group_leave(group);
    } error:^(NSString *errorStr) {
        NSLog(@"----------finished");
        dispatch_group_leave(group);
    }];
    
    dispatch_group_enter(group);
    //網(wǎng)絡(luò)請(qǐng)求2
    [NetService getUserIconSuccess:^(id successData) {
        NSLog(@"----------finished");
        dispatch_group_leave(group);
    } error:^(NSString *errorStr) {
        NSLog(@"----------finished");
        dispatch_group_leave(group);
    }];
    
    dispatch_group_notify(group, dispatch_get_main_queue(), ^{
        NSLog(@"所有網(wǎng)絡(luò)請(qǐng)求的數(shù)據(jù)都返回了");
    });
最后編輯于
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請(qǐng)聯(lián)系作者
【社區(qū)內(nèi)容提示】社區(qū)部分內(nèi)容疑似由AI輔助生成,瀏覽時(shí)請(qǐng)結(jié)合常識(shí)與多方信息審慎甄別。
平臺(tái)聲明:文章內(nèi)容(如有圖片或視頻亦包括在內(nèi))由作者上傳并發(fā)布,文章內(nèi)容僅代表作者本人觀點(diǎn),簡(jiǎn)書系信息發(fā)布平臺(tái),僅提供信息存儲(chǔ)服務(wù)。

相關(guān)閱讀更多精彩內(nèi)容

友情鏈接更多精彩內(nèi)容