1. 日常开发中常用的多线程方式?
- GCD;
简单的线程同步, 子线程操作;
- NSOperation
AFNetworkingde的实现;
- NSThread
常驻线程;
2. 以GCD
为例简单分析线程
和队列
的关系;
首先了解下并发和并行的概念;
-
dispatch_async
:异步执行; 将传入的block
块放入指定的queue
中执行, 如果这个queue
是非主队列
那么它会立即返回block
执行的结果,不会阻塞UI线程(处理一些耗时操作, 例如网络请求之类的); 如果这个queue
是主队列
那么它会等待block
中代码执行完成后才会继续向下执行;
-
queue
的类型
1.1mainQueue
:不会创建新线程, 所有任务在主线程中逐次执行;
1.2globalQueue
或者并行队列
:根据情况开辟子线程数 , 并发执行;
1.3串行队列
: 创建一个子线程, 串行执行;
-
dispatch_sync
:同步执行; 不会创建新的线程, 只会在当前线程逐次执行;不论是添加到串行队列还是并行队列都是这个效果;
-
queue
的类型
2.1mainQueue
:死锁;
2.2globalQueue
或者并行队列
:全局/并发队列中并发执行;
2.3 串行队列: 在当前线程串行执行;
- 3.
dispatch_get_global_queue
: 全局并行队列; 任务的执行不会相互依赖; -
dispatch_get_main_queue
: 主队列, 配合异步async
函数使用;
-
-
serialQueue
:串行队列, 任务依赖,后面的任务依赖前面执行完才会执行;
-
获取串行队列:
dispatch_queue_t serialQueue = dispatch_queue_create("获取串行队列", NULL);
dispatch_queue_t serialQueue = dispatch_queue_create("获取串行队列", DISPATCH_QUQUE_SERIAL);
获取并行队列:
dispatch_queue_t serialQueue = dispatch_queue_create("获取并行队列", DISPATCH_QUQUE_CONCURRENT);
3. 常见问题/情景分析
情景1:这段代码为什么会死锁?
- (void)viewDidLoad {
[super viewDidLoad];
dispatch_sync(dispatch_get_main_queue(), ^{
NSLog(@"造成死锁");
});
// Do any additional setup after loading the view.
}
死锁原因:
- 不论是
viewDidLoad
还是NSLog
最后都要到主线程中去执行;
- 不论是
- 在图的右列可以看出由于是
dispatch_sync
同步队列, 所以在执行完viewDidLoad
才会去执行Block
;
- 在图的右列可以看出由于是
-
viewDidLoad
首先到主线程中,执行到Block
时需要等到Block
执行完才能继续往下执行, 另一方面由于是dispatch_sync
的原因;Block
要在viewDidLoad
执行完才会去执行;
-
- 这样就造成了一个死循环, 成为死锁;
情景2: 这段代码执行结果为什么是 1, 3?
- (void)testCase1 {
dispatch_async(dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0), ^{
NSLog(@"1");
[self performSelector:@selector(print2) withObject:nil afterDelay:0];
NSLog(@"3");
});
}
- (void)print2 {
NSLog(@"2");
}
原因:首先程序入口是async
, 异步方式分发在全局队列中是会开辟子线程的,而performSelector
的调用是与runloop
对应的; 只有在主线程才会默认开启runloop
, 子线程中不会默认开启, 所以- (void)print2
方法不会被触发;
情景3: 这段代码执行结果为什么是 A>B>C>D>E?
- (void)viewDidLoad {
[super viewDidLoad];
[self testCase2];
}
- (void)testCase2 {
NSLog(@"A");
dispatch_sync(dispatch_get_global_queue(0, 0), ^{
NSLog(@"B");
dispatch_sync(dispatch_get_global_queue(0, 0), ^{
NSLog(@"C");
});
NSLog(@"D");
});
NSLog(@"E");
}
原因:首先testCase2
函数入口是viewDidLoad
在主线程;因为是sync
函数, 所以往下执行都是在主线程中, 由于是全局并行队列,NSLog(@"B")
和NSLog(@"C")
会在全局队列中并发执行不会相互依赖;最终打印出A>B>C>D>E;
并发队列:并发队列中的任务可以并发执行,例如依次进入队列A,B,C,D四个任务那么顺序一定是先执行A再执行B的顺序, 但是在执行B,C,D时A是否执行完毕是不一定的;具体可以并发执行几个任务由系统控制(
GCD
中不能直接设置并发数,可以通过创建信号量的方式实现,NSOperationQueue
可以直接设置);
情景4: 这段代码执行结果为什么会崩溃?
- (void)viewDidLoad {
[super viewDidLoad];
[self testCase3];
}
- (void)testCase3 {
dispatch_queue_t queue = dispatch_queue_create("queue1", NULL);
NSLog(@"A");
dispatch_sync(queue, ^{
NSLog(@"B");
dispatch_sync(queue, ^{
NSLog(@"C");
});
NSLog(@"D");
});
NSLog(@"E");
}
原因:首先testCase3
函数入口是viewDidLoad
在主线程;因为是sync
函数, 所以往下执行都是在主线程中, 由于queue
是串行队列,所以在执行完NSLog(@"B");
程序会因为队列的死锁而崩溃; 具体分析祥看情形1:这段代码为什么会死锁?;
将queue
从串行队列改为并行队列即可解决死锁崩溃问题;示例代码
情景5:如何实现一个多读单写模型?
实现此模型要用到这两个函数;示例代码
dispatch_barrier_async(<#dispatch_queue_t _Nonnull queue#>, <#^(void)block#>)
dispatch_barrier_sync(<#dispatch_queue_t _Nonnull queue#>, <#^(void)block#>)
多个读的线程可以并发,读和写的线程互斥, 多个写的线程互斥;
注意:
dispatch_barrier_async
只能配合自定义并行队列使用; 不用使用global_queue
, 不然dispatch_barrier_async
的效果会跟dispatch_async
的效果一样;
#多读单写模型示例
@interface Model ()
///并发队列
@property (nonatomic, strong) dispatch_queue_t queue;
///用户数据, 期间可能多线程同时访问
@property (nonatomic, strong) NSMutableDictionary *dataDic;
@end
@implementation Model
- (instancetype)init {
self = [super init];
if (self) {
self.queue = dispatch_queue_create("CONCURRENT_QUEUE", DISPATCH_QUEUE_CONCURRENT);
self.dataDic = [NSMutableDictionary dictionaryWithCapacity:0];
}
return self;
}
- (id)objectForKey:(NSString *)key {
__block id object;
///采用同步方式获取数据, 执行block然后返回
dispatch_sync(self.queue, ^{
object = [self.dataDic objectForKey:key];
});
return object;
}
- (void)setObject:(id)object forKey:(NSString *)key {
///采用barrier, 确保唯一一个线程在写
dispatch_barrier_async(self.queue, ^{
[self.dataDic setObject:object forKey:key];
});
}
@end
情景6:如何实现并发执行A和B任务, 在A和B都完成后继续执行C任务?
日常开发中用到的场景, 两个接口请求的数据都返回后才能刷新UI;
使用dispatch_group_t
达到预期效果;示例代码
@interface GroupModel ()
@property (nonatomic, strong) dispatch_queue_t queue;
@end
@implementation GroupModel
- (instancetype)init {
self = [super init];
if (self) {
self.queue = dispatch_queue_create("CONCURRENT_QUEUE", DISPATCH_QUEUE_CONCURRENT);
}
return self;
}
- (void)testGroupCase {
dispatch_group_t group = dispatch_group_create();
[self requestHTTP_AWithGroup:group];
[self requestHTTP_BWithGroup:group];
///多个group全部leave后,即全部执行完后. 刷新UI
dispatch_group_notify(group, dispatch_get_main_queue(), ^{
[self layoutUI];
});
}
- (void)requestHTTP_AWithGroup:(dispatch_group_t)group {
/**
方式1: 将需要执行的内容放在block中, 但是这种由于是异步并不能立即获取到回调, 日常开发一般采用第二种方式
dispatch_group_async(group, self.queue, ^{
});
*/
/**方式2*/
if (group == nil) {
return;
}
dispatch_group_enter(group);
dispatch_async(self.queue, ^{
for (int i = 0; i < 100; i ++) {
NSLog(@"AAA");
}
dispatch_group_leave(group);
});
}
- (void)requestHTTP_BWithGroup:(dispatch_group_t)group {
if (group == nil) {
return;
}
dispatch_group_enter(group);
dispatch_async(self.queue, ^{
for (int i = 0; i < 100; i ++) {
NSLog(@"BBB");
}
dispatch_group_leave(group);
});
}
- (void)layoutUI {
NSLog(@"AAA和BBB歌打印100次后更新UI");
}
@end
情景7:NSOperation
多线程如何使用?
首先NSOpetaion
是基于GCD
封装的;
它是一个抽象类, 使用NSInvocationOperation
和NSBlockOperation
或者自定义子类
;
相比其他多线程它有以下优点:
- 操作之间可以添加依赖, 方便控制执行的顺序;
- 可以设置任务的并发量(对比:
GCD
的globalQueue
并发量是不可控的);
- 可以设置任务的并发量(对比:
- 任务的执行状态是可以控制的;
- 通过
KVO
的方式监听isExecuteing
、isFinished
、isCancelled
等操作;
- 通过
参考文章
iOS iOS 多线程--GCD 串行队列、并发队列以及同步执行、异步执行
iOS 解决performSelector afterDelay在子线程不调用问题
iOS dispatch_async 与 dispatch_get_global_queue 区别
iOS GCD的Dispatch Queue(串行队列、并发队列、主队列)
iOS 多线程:『NSOperation、NSOperationQueue』详尽总结
网友评论