草庐IT

iOS 网络请求顺序处理(信号量,group)

心猿意码_ 2023-03-28 原文
一、日常开发中,会经常遇到这样的需求:
  • 网络请求A返回成功后,调用网络请求B,网络请求B结果返回成功后调用网络请求C(即:A—>B—>C)。
  • 循环调用网络请求A,确保每次请求返回成功后继续调用网络请求A(即:A—>A—>A)。
  • 网络请求A和B返回成功后,调用网路请求C(即:A&B—>C)。
二、以上三种需求,分别在此列举下示例:
  • 在GCD中跟信号量有关的三个函数如下::
//创建时,值为<0返回null;值为0时,当前线程无法直接执行wait,需等待signal信号+1后执行wait
dispatch_semaphore_t sema = dispatch_semaphore_create(0); semaphore
//发送一个信号 +1
dispatch_semaphore_signal(sema);
//等待信号(signal)>0执行
dispatch_semaphore_wait(sema, DISPATCH_TIME_FOREVER);

A—>B—>C:信号量处理

- (void)viewDidLoad {
  NSLog(@"开始====%@",@"A");
  [self loadListMenuWithFinishMark:@"A"];
  NSLog(@"开始====%@",@"B");
  [self loadListMenuWithFinishMark:@"B"];
  NSLog(@"开始====%@",@"C");
  [self loadListMenuWithFinishMark:@"C"];
}

- (void)loadListMenuWithFinishMark:(NSString *)mark{
    // 创建信号量
    dispatch_semaphore_t sema = dispatch_semaphore_create(0);
    NSString *urlString = @"http://www.qubaobei.com/ios/cf/dish_list.php?stage_id=1&limit=20&page=1";
    [[AFHTTPSessionManager manager] GET:urlString parameters:nil headers:nil progress:^(NSProgress * _Nonnull downloadProgress) {
    } success:^(NSURLSessionDataTask * _Nonnull task, id  _Nullable responseObject) {
        // 发送信号 (+ 1)
        dispatch_semaphore_signal(sema);
        NSLog(@"结束======%@",mark);
    } failure:^(NSURLSessionDataTask * _Nullable task, NSError * _Nonnull error) {
        dispatch_semaphore_signal(sema);
        NSLog(@"结束======%@", mark);
    }];
    // 等待signal执行+1后(>0),才执行wait后的业务
    dispatch_semaphore_wait(sema, DISPATCH_TIME_FOREVER);
}

打印结果(异常):

2022-05-12 10:35:50.871154+0800 SemaphoreDemo[12896:3290528] 开始====A

原因是:
如果在主线程运行以上代码,会发现没有结果输出;这是因为AFNetworking回调默认是主线程,这样dispatch_semaphore_waitdispatch_semaphore_signal在同一个线程,这样就死锁了。
所以以上代码需要放在异步线程执行如下:

- (void)viewDidLoad {
  dispatch_async(dispatch_get_global_queue(0, 0), ^{
        NSLog(@"开始====%@",@"A");
        [self loadListMenuWithFinishMark:@"A"];
        NSLog(@"开始====%@",@"B");
        [self loadListMenuWithFinishMark:@"B"];
        NSLog(@"开始====%@",@"C");
        [self loadListMenuWithFinishMark:@"C"];
    });
}

- (void)loadListMenuWithFinishMark:(NSString *)mark{
    // 创建信号量
    dispatch_semaphore_t sema = dispatch_semaphore_create(0);
    NSString *urlString = @"http://www.qubaobei.com/ios/cf/dish_list.php?stage_id=1&limit=20&page=1";
    [[AFHTTPSessionManager manager] GET:urlString parameters:nil headers:nil progress:^(NSProgress * _Nonnull downloadProgress) {
    } success:^(NSURLSessionDataTask * _Nonnull task, id  _Nullable responseObject) {
        // 发送信号 (+ 1)
        dispatch_semaphore_signal(sema);
        NSLog(@"结束======%@",mark);
    } failure:^(NSURLSessionDataTask * _Nullable task, NSError * _Nonnull error) {
        dispatch_semaphore_signal(sema);
        NSLog(@"结束======%@", mark);
    }];
    // 等待signal执行+1后(>0),才执行wait后的业务
    dispatch_semaphore_wait(sema, DISPATCH_TIME_FOREVER);
}

打印结果:

2022-05-12 10:29:55.555207+0800 SemaphoreDemo[12269:3284921] 开始====A
2022-05-12 10:29:55.706748+0800 SemaphoreDemo[12269:3284782] 结束======A
2022-05-12 10:29:55.706758+0800 SemaphoreDemo[12269:3284921] 开始====B
2022-05-12 10:29:55.712722+0800 SemaphoreDemo[12269:3284782] 结束======B
2022-05-12 10:29:55.712728+0800 SemaphoreDemo[12269:3284921] 开始====C
2022-05-12 10:29:55.715101+0800 SemaphoreDemo[12269:3284782] 结束======C

循环请求:信号量处理


- (void)viewDidLoad {
    [super viewDidLoad];
    dispatch_async(dispatch_get_global_queue(0, 0), ^{
        for (NSInteger i = 0; i < 3; i ++) {
            NSLog(@"开始====%ld",i);
            [self loadListMenuWithFinishIndex:i];
        }
    });
}

- (void)loadListMenuWithFinishIndex:(NSInteger)index{
    dispatch_semaphore_t sema = dispatch_semaphore_create(0);
    NSString *urlString = @"http://www.qubaobei.com/ios/cf/dish_list.php?stage_id=1&limit=20&page=1";
    [[AFHTTPSessionManager manager] GET:urlString parameters:nil headers:nil progress:^(NSProgress * _Nonnull downloadProgress) {
    } success:^(NSURLSessionDataTask * _Nonnull task, id  _Nullable responseObject) {
        dispatch_semaphore_signal(sema);
        NSLog(@"结束======%ld",index);
    } failure:^(NSURLSessionDataTask * _Nullable task, NSError * _Nonnull error) {
        dispatch_semaphore_signal(sema);
        NSLog(@"结束======%ld", index);
    }];
    dispatch_semaphore_wait(sema, DISPATCH_TIME_FOREVER);
}

打印结果:

2022-05-12 10:45:15.329772+0800 SemaphoreDemo[13910:3299813] 开始====0
2022-05-12 10:45:15.439159+0800 SemaphoreDemo[13910:3299720] 结束======0
2022-05-12 10:45:15.439178+0800 SemaphoreDemo[13910:3299813] 开始====1
2022-05-12 10:45:15.444384+0800 SemaphoreDemo[13910:3299720] 结束======1
2022-05-12 10:45:15.444405+0800 SemaphoreDemo[13910:3299813] 开始====2
2022-05-12 10:45:15.464591+0800 SemaphoreDemo[13910:3299720] 结束======2

多个网络请求都完成之后进行某操作(A&B—>C): Group处理

#import "AFNetworking.h"

@interface ViewController ()
@property (nonatomic,strong)dispatch_group_t group;
@end

@implementation ViewController
- (void)viewDidLoad {
    [super viewDidLoad];
    self.group = dispatch_group_create();
    NSLog(@"开始====%@",@"A");
    [self loadListFinishMark:@"A"];
    NSLog(@"开始====%@",@"B");
    [self loadListFinishMark:@"B"];
    // 完成A&B后执行C请求
    dispatch_group_notify(self.group, dispatch_get_main_queue(), ^{
        NSLog(@"开始====%@",@"C");
        [self loadListFinishCMark];
    });
}

#pragma mark - Group Request
- (void)loadListFinishMark:(NSString *)mark{
    //  enter 与 leave 一一对应
    dispatch_group_enter(self.group);
    NSString *urlString = @"http://www.qubaobei.com/ios/cf/dish_list.php?stage_id=1&limit=20&page=1";
    [[AFHTTPSessionManager manager] GET:urlString parameters:nil headers:nil progress:^(NSProgress * _Nonnull downloadProgress) {
    } success:^(NSURLSessionDataTask * _Nonnull task, id  _Nullable responseObject) {
        NSLog(@"结束======%@",mark);
        dispatch_group_leave(self.group);
    } failure:^(NSURLSessionDataTask * _Nullable task, NSError * _Nonnull error) {
        NSLog(@"结束======%@", mark);
        dispatch_group_leave(self.group);
    }];
}

- (void)loadListFinishCMark{
    NSString *urlString = @"http://www.qubaobei.com/ios/cf/dish_list.php?stage_id=1&limit=20&page=1";
    [[AFHTTPSessionManager manager] GET:urlString parameters:nil headers:nil progress:^(NSProgress * _Nonnull downloadProgress) {
    } success:^(NSURLSessionDataTask * _Nonnull task, id  _Nullable responseObject) {
        NSLog(@"结束======C");
    } failure:^(NSURLSessionDataTask * _Nullable task, NSError * _Nonnull error) {
        NSLog(@"结束======C");
    }];
}

打印结果:

2022-05-12 10:52:32.505854+0800 SemaphoreDemo[14680:3307180] 开始====A
2022-05-12 10:52:32.508026+0800 SemaphoreDemo[14680:3307180] 开始====B
2022-05-12 10:52:32.626408+0800 SemaphoreDemo[14680:3307180] 结束======B
2022-05-12 10:52:32.626604+0800 SemaphoreDemo[14680:3307180] 结束======A
2022-05-12 10:52:32.627107+0800 SemaphoreDemo[14680:3307180] 开始====C
2022-05-12 10:52:32.631006+0800 SemaphoreDemo[14680:3307180] 结束======C

码字不易,留个赞在走吧!!??????

有关iOS 网络请求顺序处理(信号量,group)的更多相关文章

  1. ruby - 如何指定 Rack 处理程序 - 2

    Rackup通过Rack的默认处理程序成功运行任何Rack应用程序。例如:classRackAppdefcall(environment)['200',{'Content-Type'=>'text/html'},["Helloworld"]]endendrunRackApp.new但是当最后一行更改为使用Rack的内置CGI处理程序时,rackup给出“NoMethodErrorat/undefinedmethod`call'fornil:NilClass”:Rack::Handler::CGI.runRackApp.newRack的其他内置处理程序也提出了同样的反对意见。例如Rack

  2. ruby-on-rails - Rails HTML 请求渲染 JSON - 2

    在我的Controller中,我通过以下方式在我的index方法中支持HTML和JSON:respond_todo|format|format.htmlformat.json{renderjson:@user}end在浏览器中拉起它时,它会自然地以HTML呈现。但是,当我对/user资源进行内容类型为application/json的curl调用时(因为它是索引方法),我仍然将HTML作为响应。如何获取JSON作为响应?我还需要说明什么? 最佳答案 您应该将.json附加到请求的url,提供的格式在routes.rb的路径中定义。这

  3. ruby - Chef 执行非顺序配方 - 2

    我遵循了教程http://gettingstartedwithchef.com/,第1章。我的运行list是"run_list":["recipe[apt]","recipe[phpap]"]我的phpapRecipe默认Recipeinclude_recipe"apache2"include_recipe"build-essential"include_recipe"openssl"include_recipe"mysql::client"include_recipe"mysql::server"include_recipe"php"include_recipe"php::modul

  4. ruby - 如何验证 IO.copy_stream 是否成功 - 2

    这里有一个很好的答案解释了如何在Ruby中下载文件而不将其加载到内存中:https://stackoverflow.com/a/29743394/4852737require'open-uri'download=open('http://example.com/image.png')IO.copy_stream(download,'~/image.png')我如何验证下载文件的IO.copy_stream调用是否真的成功——这意味着下载的文件与我打算下载的文件完全相同,而不是下载一半的损坏文件?documentation说IO.copy_stream返回它复制的字节数,但是当我还没有下

  5. Ruby 文件 IO 定界符? - 2

    我正在尝试解析一个文本文件,该文件每行包含可变数量的单词和数字,如下所示:foo4.500bar3.001.33foobar如何读取由空格而不是换行符分隔的文件?有什么方法可以设置File("file.txt").foreach方法以使用空格而不是换行符作为分隔符? 最佳答案 接受的答案将slurp文件,这可能是大文本文件的问题。更好的解决方案是IO.foreach.它是惯用的,将按字符流式传输文件:File.foreach(filename,""){|string|putsstring}包含“thisisanexample”结果的

  6. ruby - 用 Ruby 编写一个简单的网络服务器 - 2

    我想在Ruby中创建一个用于开发目的的极其简单的Web服务器(不,不想使用现成的解决方案)。代码如下:#!/usr/bin/rubyrequire'socket'server=TCPServer.new('127.0.0.1',8080)whileconnection=server.acceptheaders=[]length=0whileline=connection.getsheaders想法是从命令行运行这个脚本,提供另一个脚本,它将在其标准输入上获取请求,并在其标准输出上返回完整的响应。到目前为止一切顺利,但事实证明这真的很脆弱,因为它在第二个请求上中断并出现错误:/usr/b

  7. jquery - 我的 jquery AJAX POST 请求无需发送 Authenticity Token (Rails) - 2

    rails中是否有任何规定允许站点的所有AJAXPOST请求在没有authenticity_token的情况下通过?我有一个调用Controller方法的JqueryPOSTajax调用,但我没有在其中放置任何真实性代码,但调用成功。我的ApplicationController确实有'request_forgery_protection'并且我已经改变了config.action_controller.consider_all_requests_local在我的environments/development.rb中为false我还搜索了我的代码以确保我没有重载ajaxSend来发送

  8. Get https://registry-1.docker.io/v2/: net/http: request canceled while waiting - 2

    1.错误信息:Errorresponsefromdaemon:Gethttps://registry-1.docker.io/v2/:net/http:requestcanceledwhilewaitingforconnection(Client.Timeoutexceededwhileawaitingheaders)或者:Errorresponsefromdaemon:Gethttps://registry-1.docker.io/v2/:net/http:TLShandshaketimeout2.报错原因:docker使用的镜像网址默认为国外,下载容易超时,需要修改成国内镜像地址(首先阿里

  9. 网络编程套接字 - 2

    网络编程套接字网络编程基础知识理解源`IP`地址和目的`IP`地址理解源MAC地址和目的MAC地址认识端口号理解端口号和进程ID理解源端口号和目的端口号认识`TCP`协议认识`UDP`协议网络字节序socket编程接口`sockaddr``UDP`网络程序服务器端代码逻辑:需要用到的接口服务器端代码`udp`客户端代码逻辑`udp`客户端代码`TCP`网络程序服务器代码逻辑多个版本服务器单进程版本多进程版本多线程版本线程池版本服务器端代码客户端代码逻辑客户端代码TCP协议通讯流程TCP协议的客户端/服务器程序流程三次握手(建立连接)数据传输四次挥手(断开连接)TCP和UDP对比网络编程基础知识

  10. ruby-on-rails - 在 RSpec 中,如何以任意顺序期望具有不同参数的多条消息? - 2

    RSpec似乎按顺序匹配方法接收的消息。我不确定如何使以下代码工作:allow(a).toreceive(:f)expect(a).toreceive(:f).with(2)a.f(1)a.f(2)a.f(3)我问的原因是a.f的一些调用是由我的代码的上层控制的,所以我不能对这些方法调用添加期望。 最佳答案 RSpecspy是测试这种情况的一种方式。要监视一个方法,用allowstub,除了方法名称之外没有任何约束,调用该方法,然后expect确切的方法调用。例如:allow(a).toreceive(:f)a.f(2)a.f(1)

随机推荐