美文网首页
iOS GCD 线程同步方法

iOS GCD 线程同步方法

作者: 刘宇航iOS | 来源:发表于2016-06-30 16:12 被阅读1302次

    我们使用GCD的时候如何让线程同步,目前我能想到的就三种

    • 1.dispatch_group
    • 2.dispatch_barrier
    • 3.dispatch_semaphore

    一、dispatch_group 线程组

    1.线程组,是一种同步机制,可以让某些线程先执行,某些线程最后执行,以控制线程的执行顺序。
    2.有这么一个需要,分别执行2个耗时的异步操作,等2个异步操作都执行完毕后在回到主线程执行操作。如果想要快速高效地实现这个需求,可以考虑使用线程组。 线程组的创建代码如下:
    (1.) 创建dispatch_group_t

     dispatch_group_t group = dispatch_group_create();
    

    (2.) 往线程组里面添加任务的函数如下
    自己创建队列:使用dispatch_group_async

    无法直接使用队列变量(如使用AFNetworking添加异步任务):使用dispatch_group_enterdispatch_group_leave
    调用了dispatch_group_enter(dispatch_group_t group)
    之后,必须有与之对应的dispatch_group_leave(dispatch_group_t group)
    才行
    第一种:

      group 负责监控任务,queue 负责调度任务
     dispatch_group_async(group, dispatch_get_global_queue(0, 0), ^{  
         i = 1;  
     });  
      
     dispatch_group_async(group, dispatch_get_global_queue(0, 0), ^{  
         j = 2;  
     });  
    

    第二种:

    AFHTTPRequestOperationManager *manager = [AFHTTPRequestOperationManager manager];
    
    //Enter group
    dispatch_group_enter(group);
    [manager GET:@"http://www.baidu.com" parameters:nil success:^(AFHTTPRequestOperation *operation, id responseObject) {
        //Deal with result...
    
        //Leave group
        dispatch_group_leave(group);
    }    failure:^(AFHTTPRequestOperation *operation, NSError *error) {
        //Deal with error...
    
        //Leave group
        dispatch_group_leave(group);
    }];
    
    //More request...
    

    (3.) 监听所有任务完成 - 等到 group 中的所有任务执行完毕后,"由队列调度 block 中的任务异步执行!"
    在当前线程阻塞的同步等待:dispatch_group_wait。
    添加一个异步执行的任务作为结束任务:dispatch_group_notify

     dispatch_group_notify(group, dispatch_get_global_queue(0, 0), ^{  
         NSLog(@"%d",i+j);  
     }); 
    

    ::适用于后台批量下载 结束后主线程统一刷新UI

    二、dispatch_barrier 栅栏块

    dispatch_barrier_async,对于同一个队列中的不同任务而言,在dispatch_barrier_async之前的先执行,在dispatch_barrier_async后面的后执行 .

    _syncQueue = dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0);
    
    - (NSString *)someString
    {
     __weak NSString *localSomeString;
    
     dispatch_sync(_syncQueue, ^{
    
     localSomeString = _someString;
    
     });
    
     return localSomeString;
    
    }
    - (void)setSomeString:(NSString *)someString
    {
     // barrier
     dispatch_barrier_async(_syncQueue, ^{
    
     _someString = someString;
    
     });
    }
    

    函数 dispatch_barrier_sync 和 dispatch_barrier_async
    可以让队列中派发的 block 变成 barrier(栅栏) 使用,这种 block 称为 barrier block。队列中的 barrier block 必须等当前并发队列中的 block 都执行结束才开始执行,时序图如下:

    image_note64272_1.png

    在这个并发队列中,读取操作是用普通的块来实现的,而写入操作则是用栅栏块来实现的,读取操作可以并行,但写入操作必须单独执行,因为他是栅栏快.
    注意dispatch_barrier_async的同步控制和线程组、信号量的同步机制是不一样的,dispatch_barrier_async是对于同一个队列中的不同任务而言的,线程组和信号量是对于不同线程而言的。

    三、dispatch_semaphore 信号量

    创建一个信号量。参数指定信号量的起始值。这个数字是你可以访问的信号量,不需要先去增加它的数量(增加信号量也叫作发射信号量)。
    初始value = 0时,信号量--,小于0,wait线程阻塞。然后执行signal,信号量++,激活wait线程。

        dispatch_semaphore_t sema = dispatch_semaphore_create(0);
        
        dispatch_async(dispatch_get_global_queue(0, 0), ^{
            
            dispatch_semaphore_wait(sema, DISPATCH_TIME_FOREVER);
        
            NSLog(@"等你");
        });
        dispatch_async(dispatch_get_global_queue(0, 0), ^{
           
            NSLog(@"发送信号");
            [NSThread sleepForTimeInterval:5];
            dispatch_semaphore_signal(sema);
            
        });
    

    相关文章

      网友评论

          本文标题:iOS GCD 线程同步方法

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