GCD
全称: Grand Central Dispatch
本质: 一套低层级的 C 语言 API,GCD 管理着一个线程池,它不仅决定这你的代码块将在哪个线程被执行。
作用: 管理线程,让开发者不直接与线程打交道,从而解决线程被创建的问题。
GCD 优点
- 灵活:GCD 在常见模式,如单例、锁,用更高的性能的方法优化代码,而且 GCD 能提供更多的控制权利以及大量的底层函数。
- 易用:GCD 提供易用的并发模型(不仅仅是锁和线程),以帮我们避开并发陷阱,而且因为基于 block ,他能极为简单的在不同代码作用域之间传递上下文
- 高性能:GCD 能自动根据形同负载来增减线程数量,这就减少了上下文切换以及增加了计算效率
dispatch Queue
可以并发或者串行的执行任意一个代码块,而且并发任务会像 NSOperationQueue 那样基于系统负载来合适的并发进行,串行队列同一时间只会执行单一任务。dispatch 内部使用的是线程,GCD 管理这些线程,并且使用 Dispatch queue 的时候,我们都不需要自己创建线程。 Dispatch queue 相对于和线程直接通信的代码优势是,更方便,更效率。
队列的类型
- Serial 串行队列,将任务以先进先出的顺序来执行,所以串行队列经常用来做访问某些特定资源的同步处理。你可以根据需要创建多个队列。而这些队列相对于其他队列都是并发执行的。
- Concurrent 并发队列,虽然是能同时执行多个任务,但这些任务仍然是按照先到限制性的顺序来执行。
- Main dispatch queue,与主线程功能相同。实际上,提交至 main queue 的任务会在主线程中执行。
创建和管理队列
当你决定添加一些任务到队列中时,你需要决定应该使用哪种类型的队列,并且抉择该如何使用它们。
1.获取一个全局队列
dispatch_get_global_queue 这个方法来调用它们。
//全局队列按优先级分的四种类型
DISPATCH_QUEUE_PRIORITY_HIGH
DISPATCH_QUEUE_PRIORITY_DEFAULT
DISPATCH_QUEUE_PRIORITY_LOW
DISPATCH_QUEUE_PRIORITY_BACKGROUND
//获取全局队列的方法,最后一个参数 0 是方法保留参数
dispatch_queue_t aQueue = dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT,0);
2.创建 串行 or 并行队列
//串行
dispatch_queue_t serialQueue = dispatch_queue_create("serialqueue",NULL);
//并发
dispatch_queue_t concurrentQueue = dispatch_queue_create("concurrentQueue",DISPATCH_QUEUE_CONCURRENT);
3.并发执行迭代循环
我们需要执行一个 for 循环,每一次循环操作
```
for ( i = 0; i< count; i++){
NSLog(@"%d",i);
}
```
GCD 提供了一个简化方法 dispatch_apply,当我们把这个方法放到并发队列中执行时,这个函数会调用单一block多次,并平行运算,然后等待所有运算结束。
dispatch_queue_t queue = dispatch_get_global_queue(DISPATH_QUEUE_PRIORITY_DEFAULT,0);
dispatch_apply(count,queue,^(size_t i)){
NSLog(@"%d",i);
});
4.挂起和恢复队列
有时候,我们不想让队列中的某些任务马上执行,这时我们可以通过挂起操作来组织一个队列中将要执行的任务。当需要 挂起队列时,使用 dispatch_suspend 方法;恢复队列时,使用 dispatch_resume 则会减少引用计数,当引用计数大于 0 时,队列会保持挂起状态。因此,在队列的挂起和恢复中,我们需要小心使用以避免引用计数计算错误的出现。
dispatch_queue_t myQueue;
myQueue = dispatch_queue_create("customQueue",NULL);
//队列挂起
dispatch_suspend(myQueue);
//恢复队列
dispatch_resume(myQueue);
//执行挂起操作不会对已经开始执行的任务起作用,它仅仅会阻止将要进行但是未开始的任务
5.group
dispatch_group_async();
dispatch_group_wait();
dispatch_group_notify();
//假设 group 也持有一个整形变量,当调用 enter 时 计数 + 1,调用 leave 时计数 -1,
// 当计数为0时,会调用 dispatch_group_notify 并且 dispatch_group_wait 会停止等待。
dispatch_group_enter();
dispatch_group_leave();
dispatch_queue_t queue = dispatch_queue_create("hello", DISPATCH_QUEUE_CONCURRENT);
dispatch_group_t group = dispatch_group_create();
dispatch_group_async(group, queue, ^{
[NSThread sleepForTimeInterval:2.0];
NSLog(@"first download task success! %@",[NSThread currentThread]);
});
dispatch_group_async(group, queue, ^{
[NSThread sleepForTimeInterval:1.0];
NSLog(@"second download task success! %@", [NSThread currentThread]);
});
dispatch_group_notify(group, queue, ^{
NSLog(@"begin task three %@",[NSThread currentThread]);
});
dispatch_group_t group = dispatch_group_create();
dispatch_queue_t concurrent = dispatch_queue_create("hello", DISPATCH_QUEUE_CONCURRENT);
dispatch_queue_t serial = dispatch_queue_create("world", NULL);
dispatch_group_enter(group);
dispatch_async(concurrent, ^{
[NSThread sleepForTimeInterval:2.0];
NSLog(@"first download task success! %@",[NSThread currentThread]);
dispatch_group_leave(group);
});
dispatch_group_enter(group);
dispatch_async(serial, ^{
[NSThread sleepForTimeInterval:2.0];
NSLog(@"second download task success! %@",[NSThread currentThread]);
dispatch_group_leave(group);
});
dispatch_group_enter(group);
dispatch_async(serial, ^{
[NSThread sleepForTimeInterval:2.0];
NSLog(@"three download task success! %@",[NSThread currentThread]);
dispatch_group_leave(group);
});
//超时处理.
long result = dispatch_group_wait(group, dispatch_time(DISPATCH_TIME_NOW, 1.0 * NSEC_PER_SEC));
if (result == 0) {
NSLog(@"success");
}else {
NSLog(@"time out!");
}
dispatch_group_notify(group, concurrent, ^{
NSLog(@"begin task three! %@",[NSThread currentThread]);
});
6.信号量
7.栅栏
网友评论