提交 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");
});
