美文网首页
GCD 管理最大并发数

GCD 管理最大并发数

作者: wustzhy | 来源:发表于2017-08-12 13:22 被阅读459次

先前,项目中, 当时出现一些摸不着头脑的崩溃, 初步分析是 线程管理没限制好 导致的.
并且当时记录有Demo, 一直还未分享, 正好今夜打完🏀 精力旺盛有time ,挑灯夜笔挥一把~
bugly 问题现象如下

image.png

特此, 把各种线程管理方式 收集 罗列一下


< 0 >. GCD没有像NSOperation提供MaxConcurrentOperationCount方法, 所以一般我们在偶尔一次异步时这么用
// GCD, dispatch_async
- (void)test_GCD_dispatch_async {

    NSLog(@"begin: %@",[NSThread currentThread]);
    for (int i = 0; i < 10; i++) {
        __block int index = i;
        
        dispatch_async(dispatch_queue_create("socket msg recv queue", NULL), ^{
        
            sleep(1);
            NSLog(@"执行第%zd次操作,线程:%@",index, [NSThread currentThread]);
        
        });
    }
// count:   10
// begin:   02:52:54.213
// end  :   02:52:55.231
// time :    ≈ 1s
}

但是像上面那么用, 当用在接收socket消息时, 由于消息收的很快,短时间会开N个线程,而且在里面处理耗时任务时, 没等到达到60多个线程的上限, 可能主线程资源就被挤掉, 造成开篇所示的现象了 crash or stutter
【当然,用GCDSocket时,你只需传一个异步串行队列进去,内部在消息回调时只会开一个异步线程,不会n个n个的开了】
所以, 用时需谨慎。 那么,怎么实现线程数目的控制,这里有答案👇


< 1 >. 当然, 多线程管理, 首选NSOperation, SD、AFN等都在用, 它是对GCD的一层封装,方便线程的管理
//  NSOperationQueue
- (void)test_NSOperationQueue_withMaxTheadCount:(NSInteger) max {
    
    NSOperationQueue *queue = [[NSOperationQueue alloc] init];
    
    [queue setMaxConcurrentOperationCount:max];
    
    NSLog(@"begin: %@",[NSThread currentThread]);
    for (int i = 0; i < 10; i++) {
        
        __block int index = i;
        NSBlockOperation *operation = [NSBlockOperation blockOperationWithBlock:^(){
            sleep(1);
            NSLog(@"执行第%zd次操作,线程:%@",index, [NSThread currentThread]);
        }];
        
        [queue addOperation:operation];

    }
    
// max  :   2               10
// begin:   02:29:49.548    02:41:20.911
// end  :   02:29:54.806    02:41:21.985
// time :      ≈ 5.26s         ≈ 1s
}
< 2 >. 通过信号量semaphore控制
// GCD, semaphore
- (void)test_GCD_semaphore_WithMaxTheadCount:(NSInteger) max {
    
    dispatch_queue_t workConcurrentQueue = dispatch_queue_create("cccccccc", DISPATCH_QUEUE_CONCURRENT);
    dispatch_queue_t serialQueue = dispatch_queue_create("sssssssss",DISPATCH_QUEUE_SERIAL);
    dispatch_semaphore_t semaphore = dispatch_semaphore_create(max);    // create semaphore: value = 3

    NSLog(@"begin: %@",[NSThread currentThread]);
    for (int i = 0; i < 10; i++) {
        __block int index = i;
        dispatch_async(serialQueue, ^{
            
            // If value < 0, then wait here. Else value > 0, then pass, and value -1
            dispatch_semaphore_wait(semaphore, DISPATCH_TIME_FOREVER);
            dispatch_async(workConcurrentQueue, ^{
                
                sleep(1);
                NSLog(@"执行第%zd次操作,线程:%@",index, [NSThread currentThread]);
                dispatch_semaphore_signal(semaphore);});                // Perform value +1
        });
    }
    NSLog(@"主线程...!");
// max  :   2               10
// begin:   03:02:45.309    03:05:53.301
// end  :   03:02:50.332    03:05:54.309
// time :    ≈ 5.03s           ≈ 1s
}

< 3 >. 根据<2> 封装成 QSDispatchQueue, 使用如下👇
// QSDispatchQueue
- (void)test_QSDispatchQueue_withMaxTheadCount:(NSInteger) max {

    dispatch_queue_t concurrentQueue = dispatch_queue_create("socketConcurrentQueue", DISPATCH_QUEUE_CONCURRENT);
    QSDispatchQueue *queue = [[QSDispatchQueue alloc]initWithQueue:concurrentQueue concurrentCount:max];
    
    NSLog(@"begin: %@",[NSThread currentThread]);
    for (int i = 0; i < 10; i++) {
        __block int index = i;
        [queue async:^{
            sleep(1);
            NSLog(@"执行第%zd次操作,线程:%@",index, [NSThread currentThread]);
        }];
    }
    
// max  :   2               10
// begin:   02:37:29.052    02:40:11.811
// end  :   02:37:34.069    02:40:12.816
// time :    ≈ 5.1s           ≈ 1s
}

< 2 >. 通过dispatch_group_t控制
dispatch_group_t group = dispatch_group_create();

dispatch_group_enter(group);
[self request1:^{
        dispatch_group_leave(group);
    }];

dispatch_group_enter(group);
    [self request2:^{
        dispatch_group_leave(group);
    }];
    
dispatch_group_notify(group, dispatch_get_main_queue(), ^{
    //1、2两请求完毕
});

懒人下载 👉GitHub Demo

相关文章

  • GCD 管理最大并发数

    先前,项目中, 当时出现一些摸不着头脑的崩溃, 初步分析是 线程管理没限制好 导致的.并且当时记录有Demo, 一...

  • iOS实录16:GCD小结之控制最大并发数

    导语:在GCD的使用中,需要考虑控制最大并发数 和 线程同步这两个问题,本文主要介绍GCD中如何控制最大并发数 。...

  • iOS-基础巩固-NSOperation

    NSBlockOperation GCD & NSOperation 对比 最大并发数 队列的取消、暂停、恢复 取...

  • NSOperation 和 GCD 的区别

    NSOperationQueue是把GCD封装为OC语法,额外比GCD增加了几项新功能 第一、支持限制最大并发数 ...

  • GCD 文章理解

    GCD详解 1,GCD如何控制线程的最大并发数? (1,通过信号量的大小控制线成并发执行的数量) (2,一定数量的...

  • iOS多线程控制最大并发数

    iOS多线程最常用是GCD和NSOperation。一般简单的异步任务直接使用GCD,需要控制最大并发数和控制状态...

  • 为GCD并发队列设置最大并发数

    多线程原理(只有一个CPU的情况): 同一时间,CPU 只能处理1个线程,同一时间只有1个线程在执行; 多线程同时...

  • 关于GCD的使用

    在iOS开发中,对于多线程,大多数开发者使用苹果提供的简单的GCD, 频繁的使用GCD,并发队列并不会去管理最大并...

  • iOS实录:GCD使用小结(二)

    2017-07-29iOS开发 导语:在GCD的使用中,需要考虑控制最大并发数 和 线程同步这两个问题,本文主要介...

  • 06进阶之路-多线程管理

    1. GCD相关 学习链接 GCD 简介 (多核编程管理线程) GCD 任务和队列(同步和异步任务 并发和串行队列...

网友评论

      本文标题:GCD 管理最大并发数

      本文链接:https://www.haomeiwen.com/subject/ixdcrxtx.html