在开发过程中,一般一个页面的数据通过一个接口请求来实现,但也有当一个页面分不同模块时,后台通过多个接口实现(其实可以一个接口实现,后台同事觉得后续迭代方便)。
本文使用GCD的三个方法解决:
1、dispatch_group_enter():通知group,下面的任务马上要放到group中执行了。
2、dispatch_group_leave():通知group,任务完成了,该任务要从group中移除了。
3、dispatch_group_notify():当所有enter到group里的任务都leaves时执行此通知。
个人理解:和内存管理的引用计数类似,我们可以认为group也持有一个整形变量(只是假设),当调用enter时计数加1,调用leave时计数减1,当计数为0时会调用dispatch_group_notify并且dispatch_group_wait会停止等待;
实战
网络请求基于对AFNetworking的封装,代码如下:
-(void)loadData{
WeakSelf_Macro;
MBProgressHUD *hud = [Common showCustomHUDAddToView:self.view];
dispatch_group_t group = dispatch_group_create();
// 请求一
dispatch_group_enter(group);
[self loadGoods:^(BOOL isSuccess) {
dispatch_group_leave(group);
}];
// 请求二
dispatch_group_enter(group);
[self loadCredit:^(BOOL isSuccess) {
dispatch_group_leave(group);
}];
// 当上述两个请求结束后,收到通知,在此做后续工作
dispatch_group_notify(group, dispatch_get_main_queue(), ^{
[hud hideAnimated:YES];
[weakSelf.tableView.mj_header endRefreshing];
[weakSelf.tableView reloadData];
});
}
// 请求一
- (void)loadGoods:(void(^)(BOOL isSuccess))requestBolck{
WeakSelf_Macro;
[NetworkToolCredit appCredit_queryMemberGoodsUserNo:nil success_callback:^(APIResult *result, NSObject *obj) {
if (result.returnCode.integerValue == KErrorCode_SUCCESSE) {
[weakSelf.dataArr removeAllObjects];
[weakSelf.dataArr addObjectsFromArray:(NSMutableArray *)obj];
}else{
[Common makeToast:result.returnMsg view:weakSelf.view];
}
if (requestBolck) {
requestBolck(result.returnCode.integerValue == KErrorCode_SUCCESSE);
}
} failure:^(NSError *error) {
if (requestBolck) {
requestBolck(NO);
}
}];
}
// 请求二
- (void)loadCredit:(void(^)(BOOL isSuccess))requestBolck{
WeakSelf_Macro;
[NetworkToolCredit appCredit_queryBillUserNo:[UserInfo getCurrentUserNo] success_callback:^(APIResult *result, NSObject *obj) {
if (result.returnCode.integerValue == KErrorCode_SUCCESSE) {
weakSelf.billModel = (CreditIndexBillModel *)obj;
}else{
[Common makeToast:result.returnMsg view:weakSelf.view];
}
if (requestBolck) {
requestBolck(result.returnCode.integerValue == KErrorCode_SUCCESSE);
}
} failure:^(NSError *error) {
if (requestBolck) {
requestBolck(NO);
}
}];
}
本文在此介绍另一种实现线程同步的方式,但不适用于上述情况,原因稍后介绍:
void dispatch_group_async(dispatch_group_t group, dispatch_queue_t queue, dispatch_block_t block);
将代码块dispatch_block_t block放入队列dispatch_queue_t queue中执 行;并和调度组dispatch_group_t group相互关联;如果提交到dispatch_queue_t queue中的block全都执行完毕会调用dispatch_group_notify并且dispatch_group_wait会停止等待;
不适用原因:它的判断标准是放入的block是否执行完毕,如果我们放入block中包含异步的网络请求,这个方法无法在网络数据返回后再进行同步。
网友评论