GCD提供兩種方式支持dispatch隊列同步合冀,即dispatch組和信號量脸爱。
一瘪阁、dispatch組(dispatch group)
1. 創(chuàng)建dispatch組
dispatch_group_t group = dispatch_group_create();
2. 啟動dispatch隊列中的block關(guān)聯(lián)到group中
dispatch_group_async(group, queue, ^{
// 类浪。臭蚁。最铁。
});
3. 等待group關(guān)聯(lián)的block執(zhí)行完畢,也可以設(shè)置超時參數(shù)
dispatch_group_wait(group, DISPATCH_TIME_FOREVER);
4. 為group設(shè)置通知一個block垮兑,當(dāng)group關(guān)聯(lián)的block執(zhí)行完畢后冷尉,就調(diào)用這個block。類似dispatch_barrier_async系枪。
dispatch_group_notify(group, queue, ^{
// 雀哨。。。
});
5. 手動管理group關(guān)聯(lián)的block的運行狀態(tài)(或計數(shù))雾棺,進(jìn)入和退出group次數(shù)必須匹配
dispatch_group_enter(group);
dispatch_group_leave(group);
所以下面的兩種調(diào)用其實是等價的膊夹,
A)
dispatch_group_async(group, queue, ^{
// 。捌浩。放刨。
});
B)
dispatch_group_enter(group);
dispatch_async(queue, ^{
//。尸饺。进统。
dispatch_group_leave(group);
});
所以,可以利用dispatch_group_enter侵佃、?dispatch_group_leave和dispatch_group_wait來實現(xiàn)同步麻昼,具體例子:http://stackoverflow.com/questions/10643797/wait-until-multiple-operations-executed-including-completion-block-afnetworki/10644282#10644282奠支。
二馋辈、dispatch信號量(dispatch semaphore)
1. 創(chuàng)建信號量,可以設(shè)置信號量的資源數(shù)倍谜。0表示沒有資源迈螟,調(diào)用dispatch_semaphore_wait會立即等待。
dispatch_semaphore_t semaphore?= dispatch_semaphore_create(0);
2. 等待信號尔崔,可以設(shè)置超時參數(shù)答毫。該函數(shù)返回0表示得到通知,非0表示超時季春。
dispatch_semaphore_wait(semaphore,?DISPATCH_TIME_FOREVER);
3. 通知信號洗搂,如果等待線程被喚醒則返回非0,否則返回0载弄。
dispatch_semaphore_signal(semaphore);
最后耘拇,還是回到生成消費者的例子,使用dispatch信號量是如何實現(xiàn)同步:
dispatch_semaphore_tsem =dispatch_semaphore_create(0);
dispatch_async(dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT,0),
^{?//消費者隊列
while(condition) {
if (dispatch_semaphore_wait(sem,dispatch_time(DISPATCH_TIME_NOW,10*NSEC_PER_SEC)))
//等待10秒
continue;
//得到數(shù)據(jù)
}
});
dispatch_async(dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT,0),
^{?//生產(chǎn)者隊列
while(condition) {
if (!dispatch_semaphore_signal(sem))
{
sleep(1); //wait for a while
continue;
}
//通知成功
}
});