美文网首页iOS开发线程安全iOS
iOS 高并发操作同一数组线程安全问题

iOS 高并发操作同一数组线程安全问题

作者: 字节码 | 来源:发表于2017-07-02 11:21 被阅读2302次

    公司多个项目中主要用到下载功能,而且需要前后台运行着的App同步下载文件同步下载进度,也就是谁在前台谁下载,没有前台时后台下载。
    需要解决的问题:其中使用的方案有,进入前台本地文件检测更新数据库,操作文件在子线程中执行的,列表的展示是从数据库中取出放到数组中的,由于频繁并发操作数组,所以会经常发生线程安全问题的crash,
    解决方法:通过OC的消息转发机制,实现一个同步执行的数组(SynchronizedMutableArray),将其未实现的方法转发给NSMutableArray执行,且SynchronizedMutableArray实例的对象增删改查的方法都会同步执行,这样就解决多线程并发操作数组引发的crash,避免线程安全问题, (经测试此数组的操作速度是NSMutableArray的60%,非高并发操作,不建议使用这方法的)

    在同步方案中遇到的问题:
    1.数组在遍历时如果不在同一个队列中执行时,还是会有线程安全问题crash发生
    2.数组在遍历中,也同时执行增删改查的方法,由于是同一队列中同步执行的,会造成线程死锁问题, 比如下面的操作:

    // 这样在同一个同步队列中遍历数组,又对数组进行增删改查的操作,会造成死锁的,当然如果不在同一个队列(非主队列)中执行就不会造成死锁的
        NSMutableArray *array0 = [NSMutableArray arrayWithObjects:@"1", @"2", @"3", @"4", @"5", nil];
        dispatch_queue_t syncQueue = dispatch_queue_create("sync", NULL);
        dispatch_sync(syncQueue, ^{
            [array0 enumerateObjectsUsingBlock:^(id  _Nonnull obj, NSUInteger idx, BOOL * _Nonnull stop) {
               dispatch_sync(syncQueue, ^{
                   [array0 replaceObjectAtIndex:idx withObject:@(idx)];
               });
            }];
        });
    

    针对上面两个问题,使用了GCD信号量控制器,最终解决问题

    - (void)performBlock:(dispatch_block_t)block {
        if ([NSThread currentThread] == _signalThread) {
            block();
        } else{
            if ([NSThread isMainThread]) {
                block();
                return;
            }
            dispatch_semaphore_wait(_signal, DISPATCH_TIME_FOREVER);
            _signalThread = [NSThread currentThread];
            block();
            _signalThread = nil;
            dispatch_semaphore_signal(_signal);
        }
        
    }
    

    目前另外一种解决数组同步执行的方法也未发生线程安全问题:

    // dispatch_get_specific就是在当前队列中取出标识,如果是在当前队列就执行,非当前队列,就同步执行,防止死锁
    - (void)performBlock1:(dispatch_block_t)block {
       if (dispatch_get_specific(TreadSafetyQueueKey)) {
           block();
       } else {
           dispatch_sync(_safetyQueue, block);
       }
    }
    

    理解下dispatch_get_specific:

    线程是代码执行的路径,队列则是用于保存以及管理任务的,线程负责去队列中取任务进行执行, 比如:

    • 1.在主线程中使用同步代码块,获取当前队列
    /// 在主线程中获取当前线程和当前队列
    - (void)testSyncGCD {
       
        dispatch_queue_t queue = dispatch_queue_create("queue", NULL);
        dispatch_sync(queue, ^{
            NSLog(@"currentThread: %@\n currentQueue: %@",[NSThread currentThread], dispatch_get_current_queue());
        });
      
    }
    // Log:2017-07-02 10:40:50.499 SynchronizedMutableArray[28468:1202692] currentThread: <NSThread: 0x610000071b00>{number = 1, name = main}
     currentQueue: <OS_dispatch_queue: queue[0x6080001627c0]>
    
    

    由于当前是在主队列中执行的,而dispatch_get_current_queue()是新创建的queu,虽然是同步执行,但并不是同一个queue,所以不会造成同步死锁的

    • 2.在子线程中使用异步代码块,获取当前队列
    /// 在子线程中获取当前线程和当前队列
    - (void)testAsyncGCD {
        dispatch_queue_t queue = dispatch_queue_create("queue1", DISPATCH_QUEUE_CONCURRENT);
        dispatch_async(queue, ^{
            NSLog(@"currentThread: %@\n currentQueue: %@",[NSThread currentThread], dispatch_get_current_queue());
        });
        
    }
    // 注意:此处执行到dispatch_get_current_queue()时会挂
    

    crash的原因: 将打印的日志提交到queue队列,但系统会创建辅助线程从queue中取出任务进行执行,但是当执行dispatch_get_current_queue(), 当前的queue恰好是dispatch_get_current_queue()时就会同步阻塞会导致死锁
    GCD队列本身是不可重入的,串行同步队列的层级关系,是出现问题的根本原因。可见dispatch_get_current_queue是多么的不靠谱,为了防止类似的误用,Apple在iOS6废弃dispatch_get_current_queue()函数。

    有时候我们很希望知道当前执行的queue是谁,比如设定操作数组就要在某个队列中执行。如果可以知道当前工作的queue是谁,就可以很方便的指定一段代码操作在特定的queue中执行。

    • 使用dispatch_queue_set_specific 标记队列
    • 使用dispatch_get_specific获取标记过的队列
    /// 给队列标记,通过标记获取队列,执行任务,解决线程安全问题
    - (void)testGCDSpecific {
        dispatch_queue_t queue = dispatch_queue_create("specific", DISPATCH_QUEUE_CONCURRENT);
        void *queueSpecificKey = &queueSpecificKey;
        void *queueContext = (__bridge void *)self;
        // 使用dispatch_queue_set_specific 标记队列
        dispatch_queue_set_specific(queue, queueSpecificKey, queueContext, NULL);
        
        dispatch_async(queue, ^{
            dispatch_block_t block = ^{
                NSLog(@"currentThread: %@\n ",[NSThread currentThread]);
            };
            
            // dispatch_get_specific就是在当前队列中取出标识,如果是在当前队列就执行,非当前队列,就同步执行,防止死锁
            if (dispatch_get_specific(queueSpecificKey)) {
                block();
            } else {
                dispatch_sync(queue, block);
            }
        });
        
    }
    
    

    Demo

    相关文章

      网友评论

      • AppleIdGX: SynchronizedMutableArray *arr3 = [[SynchronizedMutableArray alloc] init];
        for (int i = 0; i < 10000000; i++) {
        [arr3 addObject:[NSNumber numberWithInt:i]];
        }
        内存飙到500m,APP直接闪退。把10000000改10000不闪退,但是耗时1036毫秒
        直接给里面的数组添加、删除等操作都上锁不行了么?为什么搞这么复杂性能还这么低?

      本文标题:iOS 高并发操作同一数组线程安全问题

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