前往小程序,Get更优阅读体验!
立即前往
首页
学习
活动
专区
工具
TVP
发布
社区首页 >专栏 >用GCD线程组与GCD信号量将异步线程转换为同步线程

用GCD线程组与GCD信号量将异步线程转换为同步线程

作者头像
freesan44
发布2018-09-05 16:30:25
5800
发布2018-09-05 16:30:25
举报
文章被收录于专栏:freesan44freesan44

有时候我们会碰到这样子的一种情形:

同时获取两个网络请求的数据,但是网络请求是异步的,我们需要获取到两个网络请求的数据之后才能够进行下一步的操作,这个时候,就是线程组与信号量的用武之地了.

1#import"ViewController.h"2#import345@interfaceViewController ()67@end89@implementationViewController1011- (void)viewDidLoad {12[super viewDidLoad];13[self getNetworkingData];14}1516- (void)getNetworkingData{17NSString *appIdKey =@"8781e4ef1c73ff20a180d3d7a42a8c04";18NSString* urlString_1 =@"http://api.openweathermap.org/data/2.5/weather";19NSString* urlString_2 =@"http://api.openweathermap.org/data/2.5/forecast/daily";20NSDictionary* dictionary =@{@"lat":@"40.04991291",21@"lon":@"116.25626162",22@"APPID": appIdKey};23//创建组24dispatch_group_t group =dispatch_group_create();25//将第一个网络请求任务添加到组中26dispatch_group_async(group, dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT,0), ^{27//创建信号量28dispatch_semaphore_t semaphore = dispatch_semaphore_create(0);29//开始网络请求任务30AFHTTPSessionManager *manager =[AFHTTPSessionManager manager];31[manager GET:urlString_132parameters:dictionary33progress:nil34success:^(NSURLSessionDataTask * _Nonnull task,id_Nullable responseObject) {35NSLog(@"成功请求数据1:%@",[responseObjectclass]);36//如果请求成功,发送信号量37dispatch_semaphore_signal(semaphore);38} failure:^(NSURLSessionDataTask * _Nullable task, NSError *_Nonnull error) {39NSLog(@"失败请求数据");40//如果请求失败,也发送信号量41dispatch_semaphore_signal(semaphore);42}];43//在网络请求任务成功之前,信号量等待中44dispatch_semaphore_wait(semaphore, DISPATCH_TIME_FOREVER);45});46//将第二个网络请求任务添加到组中47dispatch_group_async(group, dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT,0), ^{48//创建信号量49dispatch_semaphore_t semaphore = dispatch_semaphore_create(0);50//开始网络请求任务51AFHTTPSessionManager *manager =[AFHTTPSessionManager manager];52[manager GET:urlString_253parameters:dictionary54progress:nil55success:^(NSURLSessionDataTask * _Nonnull task,id_Nullable responseObject) {56NSLog(@"成功请求数据2:%@",[responseObjectclass]);57//如果请求成功,发送信号量58dispatch_semaphore_signal(semaphore);59} failure:^(NSURLSessionDataTask * _Nullable task, NSError *_Nonnull error) {60NSLog(@"失败请求数据");61//如果请求失败,也发送信号量62dispatch_semaphore_signal(semaphore);63}];64//在网络请求任务成功之前,信号量等待中65dispatch_semaphore_wait(semaphore, DISPATCH_TIME_FOREVER);66});67dispatch_group_notify(group, dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT,0), ^{68NSLog(@"完成了网络请求,不管网络请求失败了还是成功了。");69});70}7172@end

打印结果:

2016-03-15 04:01:53.279 NetWorking[83611:1508240] 成功请求数据1:__NSCFDictionary

2016-03-15 04:01:53.280 NetWorking[83611:1508240] 成功请求数据2:__NSCFDictionary

2016-03-15 04:01:53.281 NetWorking[83611:1508287] 完成了网络请求,不管网络请求失败了还是成功了。

为了和上面形成对比,我特地将所有的信号量的代码全部去除,但是保留GCD线程组的使用,然后运行看打印结果。

1#import"ViewController.h"2#import345@interfaceViewController ()67@end89@implementationViewController1011- (void)viewDidLoad {12[super viewDidLoad];13[self getNetworkingData];14}1516- (void)getNetworkingData{17NSString *appIdKey =@"8781e4ef1c73ff20a180d3d7a42a8c04";18NSString* urlString_1 =@"http://api.openweathermap.org/data/2.5/weather";19NSString* urlString_2 =@"http://api.openweathermap.org/data/2.5/forecast/daily";20NSDictionary* dictionary =@{@"lat":@"40.04991291",21@"lon":@"116.25626162",22@"APPID": appIdKey};23//创建组24dispatch_group_t group =dispatch_group_create();25//将第一个网络请求任务添加到组中26dispatch_group_async(group, dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT,0), ^{27//开始网络请求任务28AFHTTPSessionManager *manager =[AFHTTPSessionManager manager];29[manager GET:urlString_130parameters:dictionary31progress:nil32success:^(NSURLSessionDataTask * _Nonnull task,id_Nullable responseObject) {33NSLog(@"成功请求数据1:%@",[responseObjectclass]);34} failure:^(NSURLSessionDataTask * _Nullable task, NSError *_Nonnull error) {35NSLog(@"失败请求数据");36}];37});38//将第二个网络请求任务添加到组中39dispatch_group_async(group, dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT,0), ^{40//开始网络请求任务41AFHTTPSessionManager *manager =[AFHTTPSessionManager manager];42[manager GET:urlString_243parameters:dictionary44progress:nil45success:^(NSURLSessionDataTask * _Nonnull task,id_Nullable responseObject) {46NSLog(@"成功请求数据2:%@",[responseObjectclass]);47} failure:^(NSURLSessionDataTask * _Nullable task, NSError *_Nonnull error) {48NSLog(@"失败请求数据");49}];50});51dispatch_group_notify(group, dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT,0), ^{52NSLog(@"完成了网络请求,不管网络请求失败了还是成功了。");53});54}5556@end

打印结果:

2016-03-15 04:05:09.378 NetWorking[83698:1510242] 完成了网络请求,不管网络请求失败了还是成功了。

2016-03-15 04:05:10.185 NetWorking[83698:1510096] 成功请求数据1:__NSCFDictionary

2016-03-15 04:05:10.186 NetWorking[83698:1510096] 成功请求数据2:__NSCFDictionary

看到这个打印结果,我们似乎有点看不懂了,难道notify线程组没用了?notify不是会在组中的异步任务执行完毕了才会执行么?这是什么情况?

下面我在上面的代码基础上添加了第33、38、39、49、54、55行代码(也就是下面红色高亮的几行代码,都是打印当前线程),然后我们再来看看打印结果:

1#import"ViewController.h"2#import345@interfaceViewController ()67@end89@implementationViewController1011- (void)viewDidLoad {12[super viewDidLoad];13[self getNetworkingData];14}1516- (void)getNetworkingData{17NSString *appIdKey =@"8781e4ef1c73ff20a180d3d7a42a8c04";18NSString* urlString_1 =@"http://api.openweathermap.org/data/2.5/weather";19NSString* urlString_2 =@"http://api.openweathermap.org/data/2.5/forecast/daily";20NSDictionary* dictionary =@{@"lat":@"40.04991291",21@"lon":@"116.25626162",22@"APPID": appIdKey};23//创建组24dispatch_group_t group =dispatch_group_create();25//将第一个网络请求任务添加到组中26dispatch_group_async(group, dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT,0), ^{27//开始网络请求任务28AFHTTPSessionManager *manager =[AFHTTPSessionManager manager];29[manager GET:urlString_130parameters:dictionary31progress:nil32success:^(NSURLSessionDataTask * _Nonnull task,id_Nullable responseObject) {33NSLog(@"%@",[NSThread currentThread]);34NSLog(@"成功请求数据1:%@",[responseObjectclass]);35} failure:^(NSURLSessionDataTask * _Nullable task, NSError *_Nonnull error) {36NSLog(@"失败请求数据");37}];38NSLog(@"%@",[NSThread currentThread]);

39        NSLog(@"AFN网络请求框架请求完毕");40});41//将第二个网络请求任务添加到组中42dispatch_group_async(group, dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT,0), ^{43//开始网络请求任务44AFHTTPSessionManager *manager =[AFHTTPSessionManager manager];45[manager GET:urlString_246parameters:dictionary47progress:nil48success:^(NSURLSessionDataTask * _Nonnull task,id_Nullable responseObject) {49NSLog(@"%@",[NSThread currentThread]);50NSLog(@"成功请求数据2:%@",[responseObjectclass]);51} failure:^(NSURLSessionDataTask * _Nullable task, NSError *_Nonnull error) {52NSLog(@"失败请求数据");53}];54NSLog(@"%@",[NSThread currentThread]);

55        NSLog(@"AFN网络请求框架请求完毕");56});57dispatch_group_notify(group, dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT,0), ^{58NSLog(@"完成了网络请求,不管网络请求失败了还是成功了。");59});60}6162@end

打印结果(温馨提示:请求数据可能会出现失败,因为这个网络请求的url是国外的服务器,但是没关系,不要在意这个细节,打印顺序还是一样的):

2016-03-15 04:30:07.406 NetWorking[84306:1523047] {number = 2, name = (null)}

2016-03-15 04:30:07.406 NetWorking[84306:1523048] {number = 3, name = (null)}

2016-03-15 04:30:07.407 NetWorking[84306:1523047] AFN网络请求框架请求完毕

2016-03-15 04:30:07.407 NetWorking[84306:1523048] AFN网络请求框架请求完毕

2016-03-15 04:30:07.407 NetWorking[84306:1523075] 完成了网络请求,不管网络请求失败了还是成功了。

2016-03-15 04:30:08.239 NetWorking[84306:1523016] {number = 1, name = main}

2016-03-15 04:30:08.239 NetWorking[84306:1523016] 成功请求数据1:__NSCFDictionary

2016-03-15 04:30:08.240 NetWorking[84306:1523016] {number = 1, name = main}

2016-03-15 04:30:08.240 NetWorking[84306:1523016] 成功请求数据2:__NSCFDictionary

总结:网络请求然后处理响应数据是个耗时的操作,也是我们开发中常见的一种情形,在网络请求以及处理响应数据操作完毕之后我们在执行别的操作这样的过程也是我们开发中常见的情形。根据第三部分代码(没有使用信号量的代码)打印结果的顺序,我们可以知道,网络请求的任务是提交给子线程异步处理了,网络请求这样的任务也就快速执行完毕了,但是网络请求是一个任务,处理收到的网络响应又是一个任务,注意不要把这两个过程混为一谈。而收到网络响应以及处理返回响应的数据并不是在子线程中执行的,我们通过在回调响应处理的block(比如48~53行之间就有两个block)中打印当前线程,会发现回调响应处理的block是在主线程中被执行的。

如果读者很熟悉block回调这种通信机制的话,就不难理解,这个回调响应的block真正被调用执行的地方应该是AFN框架的底层代码,AFN 底层代码,是在获取到最终数据后,执行回调操作,此时,才能拿到相应数据,而这个处理网络响应的过程,AFN底层最终是这么做的:

也就是说,seccess和failure都是在主线中异步任务中执行的。

那么,这时候,如果我们需要确定这个主线程中收到网络响应的数据被处理操作结束之后,才最后执行我们需要最后的操作的话,仅仅依靠线程组看来是不够的,所以很少用到的GCD信号量就有了用武之地了。

当然,以上代码如果不用GCD线程组,只用GCD的信号量来处理,也是可以的,这个就留给大家自己探究吧。

最后再简化总结一下:信号量的使用前提是,想清楚你需要处理哪个线程等待,又要哪个线程继续执行,然后使用信号量。

比如上面的AFN网络请求的示例,block回调是在main主线程中执行的,而get请求是在自己创建的异步子线程中执行的。所以按照需求,就需要自己创建的异步子线程等待main主线程中的block执行完了之后再执行。所以异步子线程需要信号量wait,main主线程就设置signal发送信号量。

转载注明出处:http://www.cnblogs.com/goodboy-heyang/p/5277910.html

本文参与 腾讯云自媒体分享计划,分享自作者个人站点/博客。
原始发表:2017.02.09 ,如有侵权请联系 cloudcommunity@tencent.com 删除

本文分享自 作者个人站点/博客 前往查看

如有侵权,请联系 cloudcommunity@tencent.com 删除。

本文参与 腾讯云自媒体分享计划  ,欢迎热爱写作的你一起参与!

评论
登录后参与评论
0 条评论
热度
最新
推荐阅读
领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档