iOS多个网络请求并发

笔者前不久终于发布了自己的APP《小印记》，希望读者能前往App Store下载《小印记》支持一下笔者，谢谢！🙂

《小印记》iOS源码分享--极光推送实践篇
《小印记》iOS源码分享--自定义弹框篇
《小印记》源码分享--极光推送服务器篇
《小印记》iOS源码分享--网络层封装篇

---

//
//  ViewController.m
//  多个网络请求并发
//
//  Created by 贾则栋 on 17/4/27.
//  Copyright © 2017年 贾则栋. All rights reserved.
//

#import "ViewController.h"

@interface ViewController ()

@end

@implementation ViewController

- (void)viewDidLoad {
    [super viewDidLoad];
    
    // 方式一：Dispatch_semaphore
    [self semaphore];
    
    // 方式二：NSOperationQueue
//    [self operationQueue];
}

#pragma mark - semaphore

- (void)semaphore
{
    /*
     信号量是一个整型值并且具有初始计数值，信号量通常支持两个操作：通知和等待。当信号被通知的时候计数值会增加，当信号量在线程上等待的时候，必要的情况下线程会被阻塞掉，直至信号被通知时计数值大于0，然后线程会减少这个计数继续工作。
     */
    
    // 根据信号量的原理，我们便可以快速的创建一个并发控制来同步任务和有限资源访问控制。
    dispatch_group_t group = dispatch_group_create();
    dispatch_semaphore_t semaphore = dispatch_semaphore_create(2);
    dispatch_queue_t queue = dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0);
    for (int i = 0; i < 100; i++)
    {
        dispatch_semaphore_wait(semaphore, DISPATCH_TIME_FOREVER);
        
        dispatch_group_async(group, queue, ^{
            NSLog(@"%i, %@",i, [NSThread currentThread]);
            sleep(1);
            dispatch_semaphore_signal(semaphore);
        });
    }
    dispatch_group_wait(group, DISPATCH_TIME_FOREVER);
    
    /*上述代码，创建了一个初使值为2的semaphore，每一次for循环都会创建一个新的线程，线程结束的时候会发送一个信号，线程创建之前会信号等待，所以当同时创建了2个线程之后，for循环就会阻塞，等待有线程结束之后会增加一个信号才继续执行，如此就形成了对并发的控制，如上就是一个并发数为2的一个线程队列。
     */
    
    
    // 实例一
    [self semaphoreOne];
    // 实例二
//    [self semaphoreTwo];
}

- (void)semaphoreOne
{
    /*当并行执行的处理更新数据时,会产生数据不一致的情况,有时应用程序还会异常结束,虽然使用Serial Dipatch queue和dispatch_barrier_async函数可避免这类问题,但有必要进行更加细腻的排他控制
     */
    
    //1.创建全局队列
    dispatch_queue_t queue = dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0);
    
    //2.创建dispatch_semaphore_t对象
    dispatch_semaphore_t semaphore = dispatch_semaphore_create(1);
    
    //3.创建保存数据的可变数组
    NSMutableArray *mArray = [NSMutableArray array];
    
    //执行10000次操作
    for (int i = 0; i < 10000; i++) {   // 若不对并发队列加以控制，异常崩溃的概率会很高
        //异步添加数据
        dispatch_async(queue, ^{
            
            //数据进入,等待处理,信号量减1
            dispatch_semaphore_wait(semaphore, DISPATCH_TIME_FOREVER);
            
            //处理数据
            [mArray addObject:[NSNumber numberWithInt:i]];
            
            //数据处理完毕,信号量加1,等待下一次处理
            dispatch_semaphore_signal(semaphore);
        });
    }
    
    NSLog(@"%@", mArray);
}

// 通讯录的获取（ABAddressBookRef iOS9中被废弃）
- (void)semaphoreTwo
{
//    //新建一个通讯录类
//    ABAddressBookRef addressBooks = nil;
//    
//    if (DeviceVersion < 6.0) {
//        addressBooks = ABAddressBookCreate();
//    } else {
//        addressBooks =  ABAddressBookCreateWithOptions(NULL, NULL);
//        //获取通讯录权限
//        dispatch_semaphore_t sema = dispatch_semaphore_create(0);
//        ABAddressBookRequestAccessWithCompletion(addressBooks, ^(bool granted, CFErrorRef error){dispatch_semaphore_signal(sema);});
//        dispatch_semaphore_wait(sema, DISPATCH_TIME_FOREVER);
//    }
}


#pragma mark - OperationQueue

- (void)operationQueue
{
    // 创建一个队列
    NSOperationQueue *queue = [[NSOperationQueue alloc]init];
    
    // 设置最大线程数
    queue.maxConcurrentOperationCount = 5;
    
    // 创建一个A操作
    NSBlockOperation *operationA = [NSBlockOperation blockOperationWithBlock:^{
        for (int i = 0; i<10; i++) {
            NSLog(@"i的值是:%d",i);
        }
    }];
    
    // 创建一个B操作
    NSBlockOperation *operationB = [NSBlockOperation blockOperationWithBlock:^{
        for (int j = 0; j<20; j++) {
            NSLog(@"j的值是:%d",j);
        }
    }];
    
    // 添加依赖 B要在A打印完在进行打印 所以是B依赖于A 那么只需要添加如下代码即可完成
    // 使任务有序进行
    [operationB addDependency:operationA];
    
    // 分别加入到队列中
    [queue addOperation:operationA];
    [queue addOperation:operationB];
}

@end

WechatIMG138.png