GCD中两个非常重要的概念: 任务 和 队列
任务
任务就是操作,对应一段具体代码,在GCD中一般就是指一个Block。
任务有两种执行方法:同步执行和异步执行,他们的区别如下
- 同步执行:它会
阻塞当前线程
并等待Block中的任务执行完毕
,然后当前线程才会执行下去 - 异步执行:当前线程会直接往下执行,它
不会阻塞
当前线程
队列
用于存放任务,有两种队列:串行队列和并行队列
- 共同点:队列中的任务都是根据FIFO(先进先出)原则一个一个地取出来
- 不同点
串行队列:前一个任务执行完毕后,才会取下一个任务出来执行
并行队列:前一个任务取出来放到某个线程后,继续取下一个任务出来放到其他空余线程。如果线程池比较小,会出现线程全部占用的情况,这样的话就需要等待某个线程的任务执行完成后,任务才能得以执行。
死锁
情形一
- (void)GCD05
{
NSLog(@"GCD05 之前 - %@", [NSThread currentThread]);
//下面两个打印语句都不会执行,因为主线程永远不会结束,所以往主线程发送同步队列会造成死锁
//同步任务会阻塞当前线程,然后把 Block 中的任务放到指定的队列中执行,只有等到 Block 中的任务完成后才会让当前线程继续往下运行
//那么这里的步骤就是:打印完第一句后,dispatch_sync 立即阻塞当前的主线程,然后把 Block 中的任务放到 main_queue 中,可是 main_queue 中的任务会被取出来放到主线程中执行,但主线程这个时候已经被阻塞了,所以 Block 中的任务就不能完成,它不完成,dispatch_sync 就会一直阻塞主线程,这就是死锁现象。导致主线程一直卡死。
dispatch_sync(dispatch_get_main_queue(), ^{
NSLog(@"GCD05 - %@", [NSThread currentThread]);
});
NSLog(@"GCD05 之后 - %@", [NSThread currentThread]);
}
情形二
- (void)GCD07
{
dispatch_queue_t queue = dispatch_queue_create("JC", DISPATCH_QUEUE_SERIAL);
NSLog(@"1 - %@", [NSThread currentThread]);
dispatch_async(queue, ^{
NSLog(@"2 - %@", [NSThread currentThread]);
//这里同样会造成死锁,原理同上,只是把主线程换成了一个自定义的串行队列
dispatch_sync(queue, ^{
[NSThread sleepForTimeInterval:3];
NSLog(@"3 - %@", [NSThread currentThread]);
});
NSLog(@"4 - %@", [NSThread currentThread]);
});
NSLog(@"5 - %@", [NSThread currentThread]);
}
这两种死锁的情况都满足以下两种条件
1 队列为串行队列(主线程是特殊的串行队列)
2 执行同步(sync)操作
所以在情形2中,把queue改成并发队列就不会造成死锁了,因为并发队列里的后一个任务并不依赖前一个任务的完成
任务组
- (void)GCD08
{
dispatch_group_t group = dispatch_group_create();
//使用串行队列可以保证任务的顺序执行
//使用并行队列不可以保证任务的顺序执行
dispatch_queue_t queue = dispatch_queue_create("GCD08", DISPATCH_QUEUE_CONCURRENT);
dispatch_group_async(group, queue, ^{
[NSThread sleepForTimeInterval:5];
NSLog(@"GCD08 -- 步骤1 %@", [NSThread currentThread]);
});
dispatch_group_async(group, queue, ^{
[NSThread sleepForTimeInterval:3];
NSLog(@"GCD08 -- 步骤2 %@", [NSThread currentThread]);
});
dispatch_group_async(group, queue, ^{
[NSThread sleepForTimeInterval:1];
NSLog(@"GCD08 -- 步骤3 %@", [NSThread currentThread]);
});
dispatch_group_notify(group, dispatch_get_main_queue(), ^{
NSLog(@"GCD08 -- 完成 %@", [NSThread currentThread]);
});
dispatch_async(dispatch_get_main_queue(), ^{
long result = dispatch_group_wait(group, dispatch_time(DISPATCH_TIME_NOW, 6 * NSEC_PER_SEC));
//如果超时,这条语句在超时的那一刻会执行
//如果没有超时,则在group任务全部完成后执行
NSLog(@"long = %ld", result);
});
}
- (void)GCD09
{
dispatch_group_t group = dispatch_group_create();
//使用串行队列可以保证任务的顺序执行
//使用并行队列不可以保证任务的顺序执行
dispatch_queue_t queue = dispatch_queue_create("GCD09", DISPATCH_QUEUE_SERIAL);
dispatch_group_enter(group);
dispatch_async(queue, ^{
[NSThread sleepForTimeInterval:5];
NSLog(@"GCD09 -- 步骤1 %@", [NSThread currentThread]);
dispatch_group_leave(group);
});
dispatch_group_enter(group);
dispatch_async(queue, ^{
[NSThread sleepForTimeInterval:3];
NSLog(@"GCD09 -- 步骤2 %@", [NSThread currentThread]);
dispatch_group_leave(group);
});
dispatch_group_notify(group, dispatch_get_main_queue(), ^{
NSLog(@"GCD09 -- 完成 %@", [NSThread currentThread]);
});
}
- (void)GCD10
{
dispatch_queue_t queue = dispatch_queue_create("GCD10", DISPATCH_QUEUE_CONCURRENT);
NSLog(@"GCD10 开始");
dispatch_async(queue, ^{
[NSThread sleepForTimeInterval:5];
NSLog(@"GCD10 -- 步骤1 %@", [NSThread currentThread]);
});
dispatch_async(queue, ^{
[NSThread sleepForTimeInterval:3];
NSLog(@"GCD10 -- 步骤2 %@", [NSThread currentThread]);
});
dispatch_async(queue, ^{
[NSThread sleepForTimeInterval:1];
NSLog(@"GCD10 -- 步骤3 %@", [NSThread currentThread]);
});
/*这个方法重点是你传入的 queue,当你传入的 queue 是通过 DISPATCH_QUEUE_CONCURRENT 参数自己
创建的 queue 时,这个方法会阻塞这个 queue(注意是阻塞 queue ,而不是阻塞当前线程),一直等到
这个 queue 中排在它前面的任务都执行完成后才会开始执行自己,自己执行完毕后,再会取消阻塞,
使这个 queue 中排在它后面的任务继续执行。如果你传入的是其他的 queue, 那么它就和 dispatch_async 一样了。
*/
dispatch_barrier_async(queue, ^{
NSLog(@"GCD10 -- 完成 %@", [NSThread currentThread]);
});
//最后执行
dispatch_async(queue, ^{
NSLog(@"GCD10 End");
});
}
- (void)GCD11
{
dispatch_queue_t queue = dispatch_queue_create("GCD11", DISPATCH_QUEUE_CONCURRENT);
NSLog(@"GCD11 开始");
dispatch_sync(queue, ^{
[NSThread sleepForTimeInterval:5];
NSLog(@"GCD11 -- 步骤1 %@", [NSThread currentThread]);
});
dispatch_sync(queue, ^{
[NSThread sleepForTimeInterval:3];
NSLog(@"GCD11 -- 步骤2 %@", [NSThread currentThread]);
});
dispatch_sync(queue, ^{
[NSThread sleepForTimeInterval:1];
NSLog(@"GCD11 -- 步骤3 %@", [NSThread currentThread]);
});
/*
这个方法的使用和上一个一样,传入 自定义的并发队列(DISPATCH_QUEUE_CONCURRENT),
它和上一个方法一样的阻塞 queue,不同的是 这个方法还会 阻塞当前线程。
如果你传入的是其他的 queue, 那么它就和 dispatch_sync 一样了。
*/
dispatch_barrier_sync(queue, ^{
NSLog(@"GCD11 -- 完成 %@", [NSThread currentThread]);
});
dispatch_async(dispatch_get_global_queue(0, 0), ^{
NSLog(@"GCD11 End");
});
}