文档章节

iOS多个网络请求并发

_子墨
 _子墨
发布于 2017/05/03 19:09
字数 776
阅读 19
收藏 0
//
//  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

© 著作权归作者所有

共有 人打赏支持
_子墨
粉丝 47
博文 157
码字总数 141425
作品 0
深圳
iOS工程师
(转)直接拿来用!最火的iOS开源项目(一)

AFNetworking 在众多iOS开源项目中,AFNetworking可以称得上是最受开发者欢迎的库项目。AFNetworking是一个轻量级的iOS、Mac OS X网络通信类库,现在是GitHub上第三大Objective-C库。它建立在...

孙启超
2013/06/21
0
0
iOS源码补完计划--AFNetworking 3.1.0源码研读

参拜一下AFNetworking的源码。 第四篇源码、暂时来看也是iOS方向的最后一篇、撸完准备趁着热乎撸一撸网络协议。 目录 准备工作 功能模块 AFURLSessionManager/AFHTTPSessionManager AFNetwo...

kirito_song
05/25
0
0
iOS基础深入补完计划--NSURLSession使用详解(附Demo)

目录 前言 API Demo 前言 本文主要是把NSURLSession以及NSURLSessionTask相关的代理方法全部整理了一下。 旨在大体了解在一个iOS网络请求中、一个任务究竟经理了什么。 而我们、又能做些什么...

kirito_song
05/10
0
0
再看知名应用背后的第三方开源项目

知名应用程序的设计和技术一直都是开发者需要学习的,同样这些应用所使用的开源框架也是不可忽视的一部分。此前《iOS第三方开源库的吐槽和备忘》中作者ibireme列举了国内多款知名应用所使用的...

hejunbinlan
2015/08/18
0
0
那些在学习iOS开发前就应该知道的事(part 2)

英文原文:Things I wish I had known before starting iOS development—Part 2 如果你还没读这篇文章的第一部分,请先读完了再来看第二部分。 那些在学习iOS开发前就应该知道的事(part 1)...

TomatosX
2015/06/12
0
0

没有更多内容

加载失败,请刷新页面

加载更多

计算卷积神经网络浮点数运算量

前言 本文主要是介绍了,给定一个卷积神经网络的配置之后,如何大概估算它的浮点数运算量。 相关代码:CalFlops,基于MXNet框架的 Scala 接口实现的一个计算MXNet网络模型运算量的demo。 正文...

Ldpe2G
今天
1
0
Sql语言与MySql数据库

1. 数据库简介 1. 数据库,就是存储数据的仓库,只能通过sql语言来访问,数据库也是一个文件系统。通常,MySQL、Oracle等数据库,也被称为关系型数据库,其保存的不仅仅只是数据,还包括数据...

江左煤郎
今天
1
0
IDEA 取消自动import .*

打开设置 > Editor > Code Style > Java > Scheme Default > Imports ① 将 Class count to use import with "*" 改为 99 (导入同一个包的类超过这个数值自动变为 * ) ② 将 Names count ......

乔老哥
今天
3
0
PostGIS学习笔记(开篇)

PostGIS事实上算是笔者开始写博客的第一篇内容。而事实上那篇博文的内容并不丰富,笔者对PostGIS的了解仍然不多,然而17年在OSGeo课程学习时对PostGIS又有了进一步了解,并逐步发现它的强大。...

胖胖雕
今天
3
0
【Centos】在nginx服务器中配置php和mysql

接上一章《【Centos】利用Vultr服务器和namesilo布网》(https://my.oschina.net/u/3776619/blog/2051986),在Centos中配置好nginx,并在iptables中开启了80端口,和为了远程mysql操作方便开...

yongh701
今天
7
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部