現(xiàn)實(shí)開(kāi)發(fā)中，經(jīng)常會(huì)遇到這樣的需求匣椰，一個(gè)頁(yè)面需要批量發(fā)送幾個(gè)網(wǎng)絡(luò)請(qǐng)求顺呕，并且對(duì)這幾個(gè)網(wǎng)絡(luò)請(qǐng)求進(jìn)行統(tǒng)一處理。這種情況直接用AFNetworking實(shí)現(xiàn)不了必指，需要對(duì)其進(jìn)行進(jìn)一步的封裝囊咏。
實(shí)現(xiàn)思路：
- 把要批量發(fā)送的請(qǐng)求放入一個(gè)數(shù)組，遍歷數(shù)組塔橡，依次發(fā)送請(qǐng)求梅割，定義一個(gè)已完成的請(qǐng)求數(shù)量計(jì)數(shù)器，每個(gè)請(qǐng)求完成是對(duì)該計(jì)數(shù)器加一葛家，然后判斷計(jì)數(shù)器是否和請(qǐng)求數(shù)組的請(qǐng)求個(gè)數(shù)一致户辞，如果一致則代表請(qǐng)求完成。
- 跟第一個(gè)方法相似癞谒，只是判斷請(qǐng)求完成的方法不同底燎，使用GCD的信號(hào)量dispatch_semaphore，配合dispatch_group來(lái)實(shí)現(xiàn)弹砚。
下面來(lái)具體的講述以上兩種方法：
1. 通過(guò)請(qǐng)求計(jì)數(shù)器來(lái)判斷 :
猿題庫(kù)開(kāi)源的網(wǎng)絡(luò)庫(kù)框架YTKNetwork里面處理批量請(qǐng)求就是用這種方法双仍，它有一個(gè)類YTKBatchReques，就是用來(lái)實(shí)現(xiàn)批量請(qǐng)求的桌吃，它實(shí)現(xiàn)了一個(gè)方法requestFinished朱沃，該方法對(duì)已完成的請(qǐng)求數(shù)量_finishedCount進(jìn)行自增，然后判斷其是否與請(qǐng)求數(shù)組_requestArray中的請(qǐng)求個(gè)數(shù)相等茅诱，若相等則執(zhí)行一系列批量請(qǐng)求完成的操作逗物。
- (void)requestFinished:(YTKRequest *)request {
_finishedCount++;
if (_finishedCount == _requestArray.count) {
[self toggleAccessoriesWillStopCallBack];
if ([_delegate respondsToSelector:@selector(batchRequestFinished:)]) {
[_delegate batchRequestFinished:self];
}
if (_successCompletionBlock) {
_successCompletionBlock(self);
}
[self clearCompletionBlock];
[self toggleAccessoriesDidStopCallBack];
[[YTKBatchRequestAgent sharedInstance] removeBatchRequest:self];
}
}
2. GCD信號(hào)量dispatch_semaphore：
首先了解下信號(hào)量的幾個(gè)方法
1.dispatch_semaphore_create(long value)；
創(chuàng)建信號(hào)量瑟俭，傳入的value值要大于等于0翎卓，返回一個(gè)信號(hào)量
2.dispatch_semaphore_wait(dispatch_semaphore_t dsema, dispatch_time_t timeout)；
如果信號(hào)量的value值大于0尔当，則會(huì)往下執(zhí)行并將value的值減1莲祸，否則蹂安，阻礙當(dāng)前線程并等待timeout后再往下執(zhí)行。如果等待的期間desema的值被dispatch_semaphore_signal函數(shù)加1了锐帜，且該函數(shù)所處線程獲得了信號(hào)量田盈，那么就繼續(xù)向下執(zhí)行并將信號(hào)量減1。如果等待期間沒(méi)有獲取到信號(hào)量或者信號(hào)量的值一直為0缴阎，那么等到timeout時(shí)允瞧，其所處線程會(huì)自動(dòng)往下執(zhí)行。
3.dispatch_semaphore_signal(dispatch_semaphore_t dsema)蛮拔；
返回值為long類型述暂，當(dāng)返回值為0時(shí)表示當(dāng)前并沒(méi)有線程等待其處理的信號(hào)量，其處理的信號(hào)量的值加1即可建炫。當(dāng)返回值不為0時(shí)畦韭，表示其當(dāng)前有（一個(gè)或多個(gè)）線程等待其處理的信號(hào)量，并且該函數(shù)喚醒了一個(gè)等待的線程（當(dāng)線程有優(yōu)先級(jí)時(shí)肛跌，喚醒優(yōu)先級(jí)最高的線程艺配；否則隨機(jī)喚醒）。
實(shí)現(xiàn)過(guò)程：
- 創(chuàng)建一個(gè)任務(wù)組dispatch_group
dispatch_group_t group = dispatch_group_create();
- 將每個(gè)請(qǐng)求包裝成一個(gè)任務(wù)異步提交到任務(wù)組里衍慎，每個(gè)任務(wù)在一開(kāi)始創(chuàng)建一個(gè)信號(hào)量转唉，value值為0，任務(wù)最后在網(wǎng)絡(luò)請(qǐng)求完成前進(jìn)行信號(hào)量的等待稳捆，如果網(wǎng)絡(luò)請(qǐng)求完成赠法，則調(diào)用 'dispatch_semaphore_signal(semaphore);'對(duì)信號(hào)值加1，則線程不再進(jìn)行信號(hào)量的等待乔夯，繼續(xù)往下執(zhí)行砖织。當(dāng)所有請(qǐng)求都完成時(shí)，會(huì)在dispatch_group_notify里的回調(diào)進(jìn)行相應(yīng)的處理末荐。
dispatch_group_async(group, dispatch_get_global_queue(0, 0), ^{
// 創(chuàng)建信號(hào)量
dispatch_semaphore_t semaphore = dispatch_semaphore_create(0);
NSURLSessionDataTask *task = [manager GET:service.url parameters:service.parameters progress:nil success:^(NSURLSessionDataTask * _Nonnull task, id _Nullable responseObject) {
// 如果請(qǐng)求成功镶苞，增加信號(hào)量值
dispatch_semaphore_signal(semaphore);
// 成功回調(diào) 主線程執(zhí)行
dispatch_async(dispatch_get_main_queue(), ^{
!service.requestComplete?:service.requestComplete(responseObject,nil);
});
} failure:^(NSURLSessionDataTask * _Nullable task, NSError * _Nonnull error) {
// 如果請(qǐng)求失敗，增加信號(hào)量值
dispatch_semaphore_signal(semaphore);
}];
// 在網(wǎng)絡(luò)請(qǐng)求任務(wù)成功之前鞠评，信號(hào)量等待中
dispatch_semaphore_wait(semaphore, DISPATCH_TIME_FOREVER);
});
dispatch_group_notify(group, dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0), ^{
// 所有請(qǐng)求完成時(shí)回調(diào)
});
參考鏈接
http://www.cnblogs.com/snailHL/p/3906112.html
https://github.com/yuantiku/YTKNetwork
