相关概念
- 线程同步:不同线程下的任务要做到完成最终监听。适合所有任务都完成才能进行下一步的情况下。
- 线程依赖:即线程任务依赖,任务按照顺序执行。
这里简单介绍NSOperationQueue和dispatch_group,这里不对两种技术做分析比较,如有需要请参考其他文章。
NSOperationQueue
这里简单介绍使用NSOperationQueue和NSOperation实现线程任务同步 和 任务依赖。
-
NSOperation的多线程工作原理
NSOperation可以调用start方法来执行任务,但默认是同步执行的。
- 先将需要执行的操作封装到一个NSOperation对象中。
- 然后将NSOperation对象添加到NSOperationQueue中。
- 系统会自动将NSOperationQueue中的NSOperation取出来。
- 将取出的NSOperation封装的操作放到一条新线程中执行。
-
NSOperation是个抽象类,并不具备封装操作的能力,必须使用它的子类(具体使用链接):
- NSBlockOperation
- NSInvocationOperation
- 自定义子类继承NSOperation(实现内部相应的方法)
-
NSOperationQueue是面向OC的类型,默认是并行队列。它有如下几个属性需要注意:
- currentQueue 类属性,获取当前线程所执行任务所在队列。
- mainQueue 类属性,获取主线程所执行任务所在队列。
- maxConcurrentOperationCount 对象属性,设置最大操作并发量;如果设置为1,队列则是串行队列。
-
线程任务依赖和同步,这里直接看代码
NSOperationQueue *queue = [[NSOperationQueue alloc] init]; NSBlockOperation *op0 = [NSBlockOperation blockOperationWithBlock:^{ NSLog(@"op0::::currentQueque = %@, currentThread = %@",NSOperationQueue.currentQueue, [NSThread currentThread]); sleep(1); }]; NSBlockOperation *op1 = [NSBlockOperation blockOperationWithBlock:^{ NSLog(@"op1::::currentQueque = %@, currentThread = %@",NSOperationQueue.currentQueue, [NSThread currentThread]); sleep(1.5); }]; NSBlockOperation *op2 = [NSBlockOperation blockOperationWithBlock:^{ NSLog(@"op2::::currentQueque = %@, currentThread = %@",NSOperationQueue.currentQueue, [NSThread currentThread]); sleep(2.0); }]; // 必须在加入queue之前 [op2 addDependency:op1]; [op1 addDependency:op0]; NSArray *opreations=[NSArray arrayWithObjects:op0,op2,op1, nil]; // 线程任务同步 [queue addOperations:opreations waitUntilFinished:YES]; NSLog(@"currentQueque = %@, currentThread = %@",NSOperationQueue.currentQueue, [NSThread currentThread]); // log 2017-11-25 11:29:45.965956+0800 GCD[4591:753700] op0::::currentQueque = <NSOperationQueue:0x600000025560>{name = 'NSOperationQueue 0x600000025560'}, currentThread = <NSThread: 0x604000270140>{number = 3, name = (null)} 2017-11-25 11:29:46.966950+0800 GCD[4591:753694] op1::::currentQueque = <NSOperationQueue: 0x600000025560>{name = 'NSOperationQueue 0x600000025560'}, currentThread = <NSThread: 0x600000276800>{number = 4, name = (null)} 2017-11-25 11:29:47.970780+0800 GCD[4591:753700] op2::::currentQueque = <NSOperationQueue: 0x600000025560>{name = 'NSOperationQueue 0x600000025560'}, currentThread = <NSThread: 0x604000270140>{number = 3, name = (null)} 2017-11-25 11:29:49.976203+0800 GCD[4591:753596] currentQueque = <NSOperationQueue: 0x600000030b80>{name = 'NSOperationQueue Main Queue'}, currentThread = <NSThread: 0x60400006b600>{number = 1, name = main}
线程不是同一线程,任务相互依赖。而且根据最后的打印结果可以看出,线程同步任务只需要一句代码,非常简单。另外还有一个线程同步的方法-(void)waitUntilAllOperationsAreFinished,此方法和-(void)addOperations:opreations waitUntilFinished:类似,它更适合和-(void)addOperationWithBlock:(void (^)(void))block配套使用。
dispatch_group
这里不做分析了,因为我发现简书里已有牛人详细整理出来用法了(简单易懂)
dispatch_group 线程任务同步的两种方法(一种方法可实现网络任务同步)
GCD的简单使用(我自己写的)