关键字:多线程原理,队列(串行并行),任务(同步异步),NSThread,GCD,NSOperation,@synchronized
概述
一个应用的运行是一个进程,一个进程中可以开启多条线程用于执行不同的任务,提高程序执行效率,但线程过多会占用大量内存空间,降低性能。iOS中一般将UI事件的处理放在主线程里。一些耗时的操作不应放入主线程,应新开线程异步执行。
原理:CPU只能处理一条线程,多线程实际上是CPU快速在多条线程间不断切换调度,而切换调度的时间特别快,造成了并发处理的假象。
队列与线程:队列是对线程的包装,便于使用,偏程序(线程偏CPU)。队列的底层也是通过线程实现的。
任务(狭义的闭包含义,非进程层级的广义任务):根据是否开辟新线程,任务分为同步和异步,区别为是否阻塞当前线程。
iOS中的多线程
pthread
一套C语言编写的通用的跨平台的多线程API,iOS中不常用。忽略。
NSThread
面向对象的轻量级的多线程方案,更直观的控制线程对象,需手动管理生命周期,但多适用于比较简单的场景。
创建
1、实例方法创建(不需要start立刻创建线程)
[NSThread detachNewThreadSelector:@selector(doSomething:) toTarget:self withObject:nil];
2、performSelector创建(swift中取消了performSelector:方法)
[self performSelectorInBackground:@selector(SEL) withObject:nil];
3、类方法创建(需手动start,可在线程开始前配置stack大小和优先级)
NSThread * myThread = [[NSThread alloc] initWithTarget:(id)target selector:(SEL)selector object:(id)argument];
[myThread start];
属性和用法
@property (readonly, getter=isExecuting) BOOL executing;
@property (readonly, getter=isFinished) BOOL finished;
@property (readonly, getter=isCancelled) BOOL cancelled;
@property (nullable, copy) NSString *name;
- (void)start;
- (void)cancel;
+ (void)exit;
+ (NSThread *)mainThread;
+ (NSThread *)currentThread;
+ (void)sleepForTimeInterval:(NSTimeInterval)time;
GCD
苹果为多核开发的多线程解决方案,自动利用CPU内核,自动管理线程的生命周期,使用了C语言和Block,更加方便灵活的管理多线程。
队列
串行队列(连续性):FIFO(先进先出)串联执行。包括主队列dispatch_get_main_queue和自建队列dispatch_queue_create(第一个参数表示队列名,第二个参数表示队列类型:DISPATCH_QUEUE_SERIAL或NULL创建串行队列,DISPATCH_QUEUE_CONCURRENT创建并行队列)。
并行队列(并发性):全局并行队列dispatch_get_global_queue(priority指定优先级,flag作为保留参数备用)。
注:dispatch_queue_create+DISPATCH_QUEUE_CONCURRENT创建自建并行队列是没有必要的,所有并发操作应放在全局并行队列中以节省开销。
任务(即一段代码)
dispatch_sync:创建同步执行任务,阻塞当前线程直到block结束,在主线程直接调用或在其他串行线程中创建同步任务会造成死锁。
dispatch_async:创建异步执行任务,不阻塞当前线程(或者说新开了线程执行任务)。
参数:一个队列,一个block,block会在指定的队列里按照其串行或并行属性执行。
用法和实例
1、不阻塞当前线程的情况下,在主队列中强行插入串行任务
dispatch_async(dispatch_get_main_queue(), ^{ });
注:如sdwebimage下载图片时,processblock回调中的UI更新操作应插入主线程,否则不能实时更新UI。
2、不阻塞当前线程的情况下,在全局队列中加入并行任务
dispatch_async(dispatch_get_global_queue(0, 0), ^{ });
3、异步在自定义队列中插入串行任务
dispatch_queue_t urls_queue = dispatch_queue_create(“test.myQueue", NULL);
dispatch_async(urls_queue, ^{ });
dispatch_release(urls_queue); //释放队列(提前结束线程)
4、队列组
dispatch_group_t group = dispatch_group_create(); //创建队列组
dispatch_queue_t queue = dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0); //全局并行队列
dispatch_group_async(group, queue, ^{ //任务一 });
dispatch_group_async(group, dispatch_get_main_queue(), ^{ //任务二 });
dispatch_group_enter(group); //标志队列组内的异步任务开始,类似引用计数+1
dispatch_group_async(group, dispatch_get_global_queue(0, 0), ^{
//任务三(任务中可嵌套处理异步操作,即处理异步任务的同步)
sleep(5); //异步操作
dispatch_group_leave(group); //标志异步任务结束,一般写在异步操作完成的block内实现队列组内任务完成的统一通知
});
dispatch_group_notify(group, dispatch_get_main_queue(), ^{ //当group组中的任务都完成后,会自动通知 });
dispatch_async(dispatch_get_global_queue(0, 0), ^{
dispatch_group_wait(group, dispatch_time(DISPATCH_TIME_NOW, 5 * NSEC_PER_SEC)); //监听group队列组中的全部任务并设置超时时间
//此处执行和dispatch_group_notify的block参数中一样的内容
});
注:上述三个任务(全局队列+主队列+全局队列中的异步任务)执行顺序严格上来说是完全并行无顺序的,但实际会按照三个任务的执行顺序打印,任务内的每行代码才会穿插并行。
5、其他用法
//生命周期内的一次性执行
static dispatch_once_t onceToken;
dispatch_once(&onceToken, ^{ });
//延迟执行
dispatch_after(dispatch_time(DISPATCH_TIME_NOW, 2.0 * NSEC_PER_SEC), dispatch_get_main_queue(), ^(void){ });
NSOperation和NSOperationQueue
对GCD的封装,完全面向对象。NSOperation对应GCD的任务;NSOperationQueue对应GCD的队列。将任务添加到队列中,系统自动执行。
NSOperation
内部任务执行状态机:ready→executing→finished/cancelled。
NSOperation是个抽象类不能直接使用,一般使用它的子类NSBlockOperation(用block传递任务)和NSInvocationOperation(用@selector传递任务)。
NSBlockOperation *operation = [NSBlockOperation blockOperationWithBlock:^{ }];
NSInvocationOperation *operation = [[NSInvocationOperation alloc] initWithTarget:self selector:@selector(run) object:nil];
[operation start]; //默认asynchronous = NO,阻塞当前线程
NSBlockOperation有个addExecutionBlock的方法,可以给一个任务添加多个block且在多个线程中并发执行,add一定要在start前。
注:当我们在自定义operation中构建异步任务时(自定义同步任务无意义因为可以直接用它的两个子类),应重写asynchronous属性(默认是NO时任务执行完operation状态自动变成finished)的getter返回YES,在异步任务完成的block中手动设置finished状态(此操作涉及KVO的手动触发)。重写main方法时一定要加入@autoreleasepool自动释放池,因为无法访问主线程的自动释放池。如果要完全控制状态机,也要重写start方法判断或者手动触发任务执行状态的KVO(cancelled,executing等)。同GCD中的dispatch_group_enter/leave。
注2:NSInvocation用于主动调用对象的方法,处理performSelector无法处理的多参数或有返回值的方法调用。
注3:addDependency可以添加依赖让NSOperation在队列中按顺序串行,相互依赖会死锁。
NSOperationQueue
NSOperation的直接执行还是会占用当前线程,所以应把任务加到队列中,添加完成后,任务会自动start,并根据NSOperationQueue的maxConcurrentOperationCount属性决定并行数(= 1时即为串行),并根据waitUntilFinished决定是否阻塞当前线程(同步异步)。
NSOperationQueue *mainQueue = [NSOperationQueue mainQueue]; //创建主队列
NSOperationQueue *otherQueue = [[NSOperationQueue alloc] init]; //创建其他队列
[mainQueue addOperation:operation]; //传入NSOperation任务对象
[otherQueue addOperationWithBlock:^{ //传入任务block }];
[operation2 addDependency:operation1]; //设置依赖,按顺序执行任务
[otherQueue addOperations:@[operation1, operation2] waitUntilFinished:NO]; //不阻塞当前线程
注:主队列是在主线程中执行的,所以默认最大并发数就是1,且设置无效。
注2:监听队列的完成需要手动添加KVO监听operationCount。
其他方法和属性
@property (getter=isSuspended) BOOL suspended; //暂停和继续队列
- (void)cancelAllOperations; //取消队列所有任务
- (void)waitUntilAllOperationsAreFinished; //阻塞线程直至队列任务全部完成
线程同步
为了防止多个线程抢夺同一个资源造成的数据安全问题,给线程加锁的操作。
@synchronized
互斥锁。
@synchronized (self) {
[_array addObject:obj];
}
等同于
[_lock lock];
[_array addObject:obj];
[_lock unlock];
同步执行
GCD:将操作放入自建队列(串行)中。
NSOperation:任务放入自建队列并将最大并发数设置为1。
网友评论