GCD学习三
常用函数:
dispatch_set_target_queue
dispatch_after
dispatch_group
dispatch_barrier_async
dispatch_sync
dispatch_apply
dispatch_suspend/dispatch_resume
dispatch_semaphore
dispatch_once
dispatch I/O
dispatch_set_target_queue
1.变更优先级
2.使多个同步队列只执行一个。
1、我们用dispatch_queue_create创建的队列,最后都变成global dispatch queue的默认级别。如果我们要变更优先级,就可以使用dispatch_set_target_queue函数
上代码:
// 创建一般队列
dispatch_queue_t mySerialDispatchQueue = dispatch _queue_create("com.example.gcd.MySerialDispatchQueue",NULL);
// 创建后台队列
dispatch_queue_t globalDispatchQueueBackground = dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_BACKGROUND,0);
// 一般队列转换成后台队列dispatch_set_target_queue(mySerialDispatchQueue,globalDispatchQueueBackground);
注意:第一个参数最好用自定义的队列,不要用系统的队列,可能会出错。
2、如果多个Serial Dispatch Queue用dispatch_set_target_queue函数指定某个Serial Dispatch Queue,那么原本应该执行多个Serial Dispatch Queue,现在在目标Serial Dispatch Queue上只能执行一个处理。可以防止并行处理。
dispatch_after
1、延迟执行
注意:是指在x秒后将指定的block添加到Main Dispatch Queue中,不是直接执行block里面代码。
dispatch_time_t time = dispatch_time(DISPATCH_TIME_NOW,3ull*NSEC_PER_SEC);
dispatch_after(time,dispatch_get_main_queue(),^{
//执行代码
});
Dispatch Group
1、如果我们使用串行队列便可以在一个队列执行完后执行下一个,但是如果是并行队列呢?
dispatch_queue_t queue = dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT,0);
dispatch_group_t group = dispatch_group_create();
// 并行队列放到group中
dispatch_group_async(group,queue,^{NSLog(@"blk1");});
dispatch_group_async(group,queue,^{NSLog(@"blk2");});
dispatch_group_async(group,queue,^{NSLog(@"blk3");});
//第一种方式 执行完成通知该组
dispatch_group_notify(group,dispatch_get_main_queue(),^{NSLog(@"done");});
// 第二种方式 等待
disptach_group_wait(group,DISPATCH_TIME_FOREVER);// 第二个参数是时间
dispatch_barrier_async
现在有一种情形,对一个数据库读取和写入操作,要如何实现。
dispatch_queue_t queue = dispatch_queue_create("name",DISPATCH_QUEUE_CONCURRENT);
dispatch_async(queue,blk1_for_reading);
dispatch_barrier_async(queue,blk_for_writing);
dispatch_async(queue,blk1_for_reading);
dispatch_async(queue,blk1_for_reading);
dispatch_sync
dispatch_sync函数等待执行完成才执行下一个,易发生死锁。
dispatch_async函数不做任何等待
dispatch_apply
dispatch_apply函数是dispatch_sync函数和dispatch_group函数的联合api.能够按照指定的次数将指定的block添加到指定的Dispatch Queue中,并等待全部执行结束。
dispatch_queue_t queue = dispatch_get_global_queue(DISPATCH_QUEUE_PRORITY_DEFAULT,0);
dispatch_apply(5,queue,^(size_t index){
NSLog(@"%zu",index);
});
NSLog(@"done");
输出结果:2 1 3 0 4 done
是等到里面全部执行完成,再执行done
dispatch_suspend/dispatch_resume
dispatch_suspend 函数挂起指定的Dispatch Queue
dispatch_suspend(queue);
dispatch_resume函数恢复指定的Dispatch Queue
dispatch_resume(queue);
注意:这些函数对已经执行的处理没有影响。挂起后,追加到Dispatch Queue中但尚未执行的处理在此之后停止执行。而恢复则使得这些处理能够继续。
Dispatch Semaphore
虽然我们可以通过Serial Dispatch Queue 和 Dispatch_barrier_async函数可以避免资源竞争。但是有更好的办法处理这类问题。
在GCD中有三个函数是semaphore的操作,分别是:
dispatch_semaphore_create 创建一个semaphore,初始化一个值
dispatch_semaphore_signal 发送一个信号,该值+1
dispatch_semaphore_wait 等待信号,该值为0->执行,否则等待并-1
创建Dispatch Semaphore
dispatch_semaphore_t semaphore = dispatch_semaphore_create(1);
等待Dispatch_semaphore_wait
dispatch_semaphore_wait(semaphore,DISPATCH_TIME_FOREVER);
发送信号Dispatch_semaphore_signal
dispatch_semaphore_signal(semaphore);
dispatch_group_t group = dispatch_group_create();
dispatch_semaphore_t semaphore = dispatch_semaphore_create(10);
dispatch_queue_t queue = dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0);
for(inti = 0; i < 100; i++)
{
dispatch_semaphore_wait(semaphore, DISPATCH_TIME_FOREVER);
dispatch_group_async(group, queue, ^{
NSLog(@"%i",i);
sleep(2);
dispatch_semaphore_signal(semaphore);
});
}
dispatch_group_wait(group, DISPATCH_TIME_FOREVER);
dispatch_release(group);
dispatch_release(semaphore);
dispatch_once
该函数保证在应用程序执行中只执行一次,能够保证在多核编程中保证安全。
static dispatch_once_t pred;
dispatch_once(&pred,^{
//执行操作
});
Dispatch I/O
能够实现一次性使用多个线程更快的并列读取