NSOperation和NSOperationQueue實(shí)現(xiàn)多線程的具體步驟
- 先將需要執(zhí)行的操作封裝到一個(gè)NSOperation對象中
- 然后將NSOperation對象添加到NSOperationQueue中
- 系統(tǒng)會(huì)自動(dòng)將NSOperationQueue中的NSOperation取出來
- 將取出的NSOperation封裝的操作放到一條新線程中執(zhí)行
NSOperation是個(gè)抽象類,并不具備封裝操作的能力,必須使用它的子類(三種方式):
- NSInvocationOperation
- NSBlockOperation
- 自定義子類繼承NSOperation,實(shí)現(xiàn)內(nèi)部相應(yīng)的方法
創(chuàng)建NSInvocationOperation對象
- (id)initWithTarget:(id)target selector:(SEL)sel object:(id)arg;
調(diào)用start方法開始執(zhí)行操作
- (void)start;
一旦執(zhí)行操作,就會(huì)調(diào)用target的sel方法
注意
默認(rèn)情況下,調(diào)用start方法后并不會(huì)開一條新線程去執(zhí)行操作,而是在當(dāng)前線程同步執(zhí)行操作
只有將NSOperation添加到NSOperationQueue(操作隊(duì)列)中,才會(huì)異步執(zhí)行NSOperation中的操作
-(void)demo1{
NSInvocationOperation * op = [[NSInvocationOperation alloc] initWithTarget:self selector:@selector(downloadImage:) object:@"invocation"];
// start 方法,會(huì)在當(dāng)前線程執(zhí)行調(diào)度方法
// [op start];
//隊(duì)列
NSOperationQueue * q = [[NSOperationQueue alloc]init];
//將操作添加到隊(duì)列 - 會(huì)自動(dòng)異步執(zhí)行調(diào)度方法
[q addOperation:op];
}
/** 開啟多個(gè)線程 不會(huì)順序執(zhí)行 --> GCD 并發(fā)隊(duì)列,異步執(zhí)行
NSOperation 本質(zhì)上是對 GCD 的面向?qū)ο蟮姆庋b!
- 隊(duì)列:本質(zhì)上 就是GCD的并發(fā)隊(duì)列
- 操作:異步執(zhí)行任務(wù)
*/
-(void)demo2{
//1.隊(duì)列
NSOperationQueue * q = [[NSOperationQueue alloc]init];
for (int i = 0; i < 10; i++) {
NSInvocationOperation * op = [[NSInvocationOperation alloc] initWithTarget:self selector:@selector(downloadImage:) object:@(i)];
//添加到隊(duì)列
[q addOperation:op];
}
}
NSBlockOperation
-(void)demo4{
//在實(shí)際開發(fā)中,會(huì)使用全局隊(duì)列
//@property(nonatomic,strong)NSOperationQueue * opQueue;
////懶加載
//-(NSOperationQueue *)opQueue
//{
// if (!_opQueue) {
// _opQueue = [[NSOperationQueue alloc]init];
// }
// return _opQueue;
//}
//1.隊(duì)列 - > 隊(duì)列如果每次分配會(huì)比較浪費(fèi)
NSOperationQueue * q = [[NSOperationQueue alloc] init];
//2.添加操作
// 方式一
[q addOperationWithBlock:^{
NSLog(@"%@ --- %d",[NSThread currentThread],i);
}];
// 方式二
// NSBlockOperation * op = [NSBlockOperation blockOperationWithBlock:^{
// NSLog(@"%@ --- %d",[NSThread currentThread],i);
// }];
// //添加到隊(duì)列
// [q addOperation:op];
}
通過addExecutionBlock:方法添加更多的操作
- (void)addExecutionBlock:(void (^)(void))block;
GCD & NSOperation 對比
/**
NSOperaton 是蘋果大力推薦的"并發(fā)"技術(shù)!
NSOperation 的核心概念:將"操作" 添加到 "隊(duì)列"
GCD 將"任務(wù)"添加到 "隊(duì)列"
GCD & NSOperation 對比
GCD 在 iOS 4.0 推出,主要針對多核處理器做了優(yōu)化的并發(fā)技術(shù),是C語言的
- 將"任務(wù)"[block]添加到 隊(duì)列[串行/并發(fā)/主隊(duì)列/全局隊(duì)列] ,并且指定執(zhí)行任務(wù)的函數(shù)[同步/異步]
- 線程間的通訊 dispatch_get_main_queue()
- 提供了一些 NSOperation 不具備的功能
- 一次執(zhí)行
- 延遲執(zhí)行
- 調(diào)度組(在op中也可以做到,有點(diǎn)麻煩)
NSOperation 在 iOS 2.0 推出的,蘋果推出 GCD以后,對NSOperation 底層做了重寫!
- 將操作[異步執(zhí)行的任務(wù)] 添加到隊(duì)列[并發(fā)隊(duì)列],就會(huì)立刻異步執(zhí)行
- [NSOperationQueue mainQueue]
- 提供了一些GCD 實(shí)現(xiàn)起來比較困難的功能
- 最大并發(fā)線程
- 隊(duì)列的暫停/繼續(xù)
- 取消所有操作
- 指定操作之間的依賴關(guān)系(GCD 用同步來實(shí)現(xiàn))
*/
最大并發(fā)數(shù)
//設(shè)置同時(shí)最大的并發(fā)操作數(shù)量
//WIFI: 5 至 6
//流量 : 2 到 3
self.opQueue.maxConcurrentOperationCount = 2;
// - (void)setMaxConcurrentOperationCount:(NSInteger)cnt;
隊(duì)列的取消、暫停、恢復(fù)
取消隊(duì)列的所有操作
- (void)cancelAllOperations;
提示:也可以調(diào)用NSOperation的- (void)cancel方法取消單個(gè)操作
暫停和恢復(fù)隊(duì)列
- (void)setSuspended:(BOOL)b; // YES代表暫停隊(duì)列,NO代表恢復(fù)隊(duì)列
- (BOOL)isSuspended;
//MARK : 暫停&繼續(xù)
/*
當(dāng)掛起隊(duì)列的時(shí)候,正在執(zhí)行的操作不受影響!
suspended : 決定隊(duì)列的暫停和繼續(xù)
operationCount : 隊(duì)列中的操作數(shù)
*/
-(IBAction)pause{
//判斷我們隊(duì)列是否掛起
if(self.opQueue.isSuspended){
NSLog(@"繼續(xù) %tu",self.opQueue.operationCount);
self.opQueue.suspended = NO;
}else{
NSLog(@"暫停%tu",self.opQueue.operationCount);
self.opQueue.suspended = YES;
}
}
//MARK : 取消所有操作
/*
1.隊(duì)列掛起的時(shí)候,不會(huì)清空內(nèi)部的操作.只有在隊(duì)列繼續(xù)的時(shí)候才會(huì)清空!
2.正在執(zhí)行的操作也不會(huì)被取消!
*/
-(IBAction)cancelAll{
//取消操作
[self.opQueue cancelAllOperations];
NSLog(@"取消之后的操作數(shù) :%tu",self.opQueue.operationCount);
}
操作依賴
//要讓操作A執(zhí)行完后,才能執(zhí)行操作B,可以這么寫
[operationB addDependency:operationA];
//MARK: 依賴關(guān)系
-(void)dependecy{
//例子: 下載\解壓\通知用戶
//1.下載
NSBlockOperation * op1 = [NSBlockOperation blockOperationWithBlock:^{
NSLog(@"下載---%@",[NSThread currentThread]);
[NSThread sleepForTimeInterval:.5];
}];
//2.解壓
NSBlockOperation * op2 = [NSBlockOperation blockOperationWithBlock:^{
NSLog(@"解壓---%@",[NSThread currentThread]);
[NSThread sleepForTimeInterval:1.0];
}];
//3.通知用戶
NSBlockOperation * op3 = [NSBlockOperation blockOperationWithBlock:^{
NSLog(@"通知用戶---%@",[NSThread currentThread]);
}];
//NSOperation 提供了依賴關(guān)系
//!!!! 注意,不要指定循環(huán)依賴,隊(duì)列就不工作了!!
[op2 addDependency:op1];
[op3 addDependency:op2];
//添加到隊(duì)列中 waitUntilFinished:是否等待! YES : 等待會(huì)卡住當(dāng)前線程!!
[self.opQueue addOperations:@[op1,op2] waitUntilFinished:NO];
//主線程通知用戶
[[NSOperationQueue mainQueue] addOperation:op3];
}
自定義NSOperation
重寫- (void)main方法,在里面實(shí)現(xiàn)想執(zhí)行的任務(wù)