GCD 常见用法速查小手册

提交 block

在主队列提交一个异步 block

dispatch_async(dispatch_get_main_queue(), ^{
    //Your codes
});

在默认优先级的全局队列提交一个同步 block,请尽量使用默认优先级,除非你真的知道你在做什么。

dispatch_sync(dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0), ^{
    //Your codes
});

dispatch_once

static dispatch_once_t onceToken;
for (int i = 0; i < 5; ++i) {
    dispatch_once(&onceToken, ^{
        NSLog(@"once");
    });
}
//将只打印一次 once,适用于单例初始化等使用场景

Group

//创建一个并行用户队列
dispatch_queue_t queue = dispatch_queue_create("myQueue", DISPATCH_QUEUE_CONCURRENT);
//创建一个group
dispatch_group_t group = dispatch_group_create();

//该 dispatch_apply 作用是执行5次block,将每个block加入到queued队列中。当所有block执行完毕后,返回
dispatch_apply(5, queue, ^(size_t n) {
    //进入 group
    dispatch_group_enter(group);
    //异步执行
    dispatch_async(dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0), ^{
        NSLog(@"sleep");
        sleep((int)n);
        //退出 group
        dispatch_group_leave(group);
    });
});

//当所有异步block退出group后, group_notify 会被执行,表明group执行完毕
dispatch_group_notify(group, queue, ^{
    NSLog(@"finished!");
});


dispatch_apply(5, queue, ^(size_t n) {
    //也可以这么写,dispatch_group_async 会自动将 block 与 group 关联
    dispatch_group_async(group, queue, ^{
        NSLog(@"sleep");
        sleep((int)n);
    });
});

dispatch_group_notify(group, queue, ^{
    NSLog(@"finished!");
});

Semaphore

//创建一个并行用户队列
dispatch_queue_t queue = dispatch_queue_create(NULL, DISPATCH_QUEUE_CONCURRENT);
//创建一个semaphore,信号量为0(直接阻塞),如果要设一个资源访问数量限制,可以设信号量为
//该数量限制,每当一个线程访问该资源,调用 semphore_wait, 信号量 -1, 当信号量为0,阻塞
dispatch_semaphore_t semaphore = dispatch_semaphore_create(0);
dispatch_async(queue, ^{
    NSLog(@"sleep");
    sleep(3);
    //信号量 +1
    dispatch_semaphore_signal(semaphore);
});
//永远等待 semphore, 当信号量不为 0 时,继续执行下面程序
//dispatch_semaphore_wait 会先检查信号量是否为 0,是则阻塞等待,否则执行将信号量 -1
dispatch_semaphore_wait(semaphore, DISPATCH_TIME_FOREVER);
NSLog(@"go on");

Barrier

dispatch_queue_t queue = dispatch_queue_create(NULL, DISPATCH_QUEUE_CONCURRENT);
dispatch_async(queue, ^{
    NSLog(@"5");
    sleep(5);
});
dispatch_async(queue, ^{
    NSLog(@"3");
    sleep(3);
});
dispatch_barrier_async(queue, ^{
    //当在这之前的所有异步操作完成,会执行下面语句,在这里程序结果是等待5秒后执行输出 finished
    NSLog(@"finished");
});
dispatch_async(queue, ^{
    NSLog(@"10");
    sleep(10);
});

Data Add

NSArray *integers = @[@1, @2, @3, @4, @5];
//创建一个 dispatch source,类型为 Data add, 其作用是累加接收到的 data
self.source_add = dispatch_source_create(DISPATCH_SOURCE_TYPE_DATA_ADD, 0, 0, dispatch_get_main_queue());
//设置 source 接收到事件的句柄
dispatch_source_set_event_handler(self.source_add, ^{
    //通过source_get_data来获取数据,获取后,data将清零
    NSLog(@"added: %lu", dispatch_source_get_data(self.source_add));
});
//source 默认状态为挂起,需要手动resume
dispatch_resume(self.source_add);
//该 dispatch_apply 作用是执行5次block,将每个block加入到全局队列中。当所有block执行完毕后,返回
dispatch_apply(5, dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0), ^(size_t index) {
    //像 source 添加 data,GCD会将多次添加merge为1次,所以并不是添加几次就会执行几次句柄
    dispatch_source_merge_data(self.source_add, [integers[index] integerValue]);
});

Timer

//创建一个 dispatch source, 类型为 Timer
self.timer = dispatch_source_create(DISPATCH_SOURCE_TYPE_TIMER, 0, 0, dispatch_get_main_queue());
//设置 timer 为 walltime(绝对时间,不受程序挂起影响),10秒触发时间,精度为1秒
dispatch_source_set_timer(self.timer, dispatch_walltime(NULL, 0), 10 * NSEC_PER_SEC, 1 * NSEC_PER_SEC);
dispatch_source_set_event_handler(self.timer, ^{
    NSLog(@"10s passed");
    //cancel source,需要在这里释放 source
    dispatch_source_set_cancel_handler(self.timer, ^{
        self.timer = nil;
    });
    //执行 source cancel
    dispatch_source_cancel(self.timer);
});
//source 默认状态为挂起,需要手动resume
dispatch_resume(self.timer);

set_target_queue

//创建一个串行用户队列
dispatch_queue_t queue = dispatch_queue_create("banana", DISPATCH_QUEUE_SERIAL);
//通过set_target_queue,将其指定为另一个目标队列。可以为全局、主队列,也可以为另一个用户队列。最终的用户队列实际上都是指向到全局队列的。
//使用set_target_queue,我们可以这样,比如设置队列A的目标队列是B,那么队列A可以看做B的子队列,当我挂起B队列后,A也将被挂起
//从而可以方便组织与管理各种队列。
dispatch_set_target_queue(queue, dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_LOW, 0));
dispatch_sync(queue, ^{
    NSLog(@"in block");
});
2017-05-22 15:211214