iOS编程中,有多种并发编程的方式,比较常见的就是基于Operation Queue和GCD,还有底层一点的NSTheard,本文主要讨论Operation Queue和GCD
异步调用和并发
在谈并发之前,谈一谈异步调用和并发,异步调用是指调用时无需等待结果返回的调用。并发是指多个任务(线程)同时执行,在异步调用的实现中往往用的都是并发机制,但也有可能是其他机制,比如一些依靠中断进行的操作。(中断:(Interrupt)是指处理器接收到来自硬件或软件的信号,提示发生了某个事件,应该被注意,这种情况就称为中断。)
Operation Queue
operation queue提供了一个面向对象的并发编程接口,并支持并发数(仅operation queue支持),线程优先级,任务优先级,任务依赖关系等多种配置
1.面向对象接口
2.支持并发数配置
3.任务优先级调度
4.任务依赖关系
5.线程优先级配置
NSOperation简介
在operation queue中,把每个并发任务都定义为一个operation,对应的类名是NSOperation,NSOperation是一个抽象类,无法直接使用,它只定义了Operation的一些基本方法,我们需要创建一个基于他的子类或者使用系统预定于的子类,目前系统预定义了两个子类:NSInvocationOperation和NSBlockOperation。
NSInvocationOperation
NSInvocationOperation是一个基于对象和selector的Operation,使用这个你只需要指定对象以及任务的selector,如果有必要,还可以设定传递的参数。
NSInvocationOperation *invacationOperation = [[NSInvocationOperation alloc] initWithTarget:self selector:@selector(doSomethingWithObj:) object:obj];
当这个Operation完成后,你可以通过下面的方法获得调用执行后返回的结果对象。
id result = [invacationOperation result];
NSBlockOperation
如果不是在一个函数中执行任务,而是在一个block中执行一个任务的话,这是我们就需要NSBlockOperation
NSBlockOperation *blockOperation = [NSBlockOperation blockOperationWithBlock:^{
//Do something here.
}];
运行一个Operation
[Operation start] ;
start方法用来启动一个Operation任务。同时,Operation提供一个main方法,你的所有任务都应该在main中进行处理。默认的start方法中会先做出一些异常判断然后直接调用main方法。如果需要自定义一个NSOperation必须重载main方法来执行你所想要执行的任务。
取消一个Operation
要取消一个Operation,要发送cancel消息:
[operation cancel];
当像一个Operation对象发送cancel消息之后,并不能保证这个Operation就一定能理科取消,这取决于你的main中对cancel的处理,,如果你在main中没有对cancel进行任何处理的话,发送cancel消息是没有任何效果的,为了让Operation响应cancel消息,那么你就要在main方法中一些适当的地方手动判断isCancelled属性,如果返回为YES的话,应该释放相关资源并立刻停止继续执行。
创建可并发的Operation
由于默认下Operation的start方法中直接调用了main方法,而main方法中会有比较耗时的处理任务,如果我们在一段代码中连续start了多个Operation的话,这个Operation都是阻塞地依次执行完,因为第二个Operation必须等到第一个Operation执行完start内的main并返回,Operation默认都是不可并发的(使用了Operation Queue除外,Operation Queue会独自管理自己的线程),因为默认Operation并不额外创建贤臣,我们可以通过OPeration的isConcurrent方法来判断Operation是否是可并发的,如果要让OPeration可并发,我们需要让main在单独的线程执行,并将isConcurrent返回YES。
这个方法是在每一个Operation中自己用NSThread来创建线程,当然,这样的行为并不是如我们所愿的
@implementation MyOperation{
BOOL executing;
BOOL finished;
}
- (BOOL)isConcurrent {
returnYES;
}
- (void)start {
if([self isCancelled])
{
[self willChangeValueForKey:@"isFinished"];
finished = YES;
[self didChangeValueForKey:@"isFinished"];
return;
}
[self willChangeValueForKey:@"isExecuting"];
[NSThread detachNewThreadSelector:@selector(main) toTarget:self withObject:nil];
executing = YES;
[self didChangeValueForKey:@"isExecuting"];
}
- (void)main {
@try{
// Do some work.
[self willChangeValueForKey:@"isFinished"];
[self willChangeValueForKey:@"isExecuting"];
executing = NO;
finished = YES;
[self didChangeValueForKey:@"isExecuting"];
[self didChangeValueForKey:@"isFinished"];
}
@catch(...) {
// Exception handle.
}
}
@end
当你自定义了start或main方法时,一定要手动的调用一些KVO通知方法,以便让对象的KVO机制可以正常运作。