zoukankan      html  css  js  c++  java
  • iOS多线程的初步研究(十)-- dispatch同步


    GCD提供两种方式支持dispatch队列同步,即dispatch组和信号量。

    一、dispatch组(dispatch group

    1. 创建dispatch组

    dispatch_group_t group = dispatch_group_create(); 

    2. 启动dispatch队列中的block关联到group中

    dispatch_group_async(group, queue, ^{ 

      // 。。。 

    }); 

    3. 等待group关联的block执行完毕,也可以设置超时参数

    dispatch_group_wait(group, DISPATCH_TIME_FOREVER); 

    4. 为group设置通知一个block,当group关联的block执行完毕后,就调用这个block。类似dispatch_barrier_async。

    dispatch_group_notify(group, queue, ^{

      // 。。。 

    }); 

    5. 手动管理group关联的block的运行状态(或计数),进入和退出group次数必须匹配

    dispatch_group_enter(group);

    dispatch_group_leave(group);

    所以下面的两种调用其实是等价的, 

    A)

    dispatch_group_async(group, queue, ^{ 

      // 。。。 

    }); 

    B) 

    dispatch_group_enter(group);

    dispatch_async(queue, ^{

      //。。。

      dispatch_group_leave(group);

    });

    所以,可以利用dispatch_group_enter、 dispatch_group_leave和dispatch_group_wait来实现同步,具体例子:http://stackoverflow.com/questions/10643797/wait-until-multiple-operations-executed-including-completion-block-afnetworki/10644282#10644282

     

    二、dispatch信号量(dispatch semaphore

    1. 创建信号量,可以设置信号量的资源数。0表示没有资源,调用dispatch_semaphore_wait会立即等待。

    dispatch_semaphore_t semaphore = dispatch_semaphore_create(0);

    2. 等待信号,可以设置超时参数。该函数返回0表示得到通知,非0表示超时。

    dispatch_semaphore_wait(semaphore, DISPATCH_TIME_FOREVER);

    3. 通知信号,如果等待线程被唤醒则返回非0,否则返回0。

    dispatch_semaphore_signal(semaphore);

    最后,还是回到生成消费者的例子,使用dispatch信号量是如何实现同步:

     

    dispatch_semaphore_t sem = dispatch_semaphore_create(0);

    dispatch_async(dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT0), ^{ //消费者队列

          while (condition) {

        if (dispatch_semaphore_wait(sem, dispatch_time(DISPATCH_TIME_NOW10*NSEC_PER_SEC))) //等待10秒

          continue;

        //得到数据

      }

    });

    dispatch_async(dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT0), ^{ //生产者队列

          while (condition) {

         if (!dispatch_semaphore_signal(sem))

        {

          sleep(1); //wait for a while

          continue;

        }

        //通知成功

      }

    });

    转载自:http://www.cnblogs.com/sunfrog/category/508548.html

  • 相关阅读:
    __x__(10)0906第三天__字符实体(转义字符)
    __x__(9)0906第三天__常见的标签
    __x__(8)0906第三天__乱码问题
    广工校赛——小明在工作
    广工校赛——01串也疯狂之光棍也有伴
    POJ2488——DFS——A Knight's Journey
    josephus问题
    链表(排序和删除)
    Buy Tickets
    敌兵布阵
  • 原文地址:https://www.cnblogs.com/zsw-1993/p/4879498.html
Copyright © 2011-2022 走看看