Operation Queues

Operation Queues 在GCD之前就有了暴备,其中的某些設(shè)計原理因Operation Queues而流行,GCD就是基于這些原理構(gòu)建的暑竟。從iOS4與Mac OSX 10.6開始,Operation Queues在底層就是用GCD來實現(xiàn)的。

GCD是純C的API,而Operation Queues是Objective-C的對象。

NSOperation

很多執(zhí)行任務(wù)類型的案例都很好的運用了NSOperation
膨报,包括網(wǎng)絡(luò)請求磷籍,圖像壓縮,自然語言處理或者其他很多需要返回處理后數(shù)據(jù)的现柠、可重復的院领、結(jié)構(gòu)化的、相對長時間運行的任務(wù)
比如我們經(jīng)常使用的AFNetworking

@interface AFURLConnectionOperation : NSOperation <NSURLConnectionDelegate, NSURLConnectionDataDelegate, NSSecureCoding, NSCopying>
@property (nonatomic, strong) NSSet *runLoopModes;
@property (readonly, nonatomic, strong) NSURLRequest *request;
@property (readonly, nonatomic, strong) NSURLResponse *response;
@property (readonly, nonatomic, strong) NSError *error;
@property (readonly, nonatomic, strong) NSData *responseData;
@property (readonly, nonatomic, copy) NSString *responseString;
...

SDWebImage

extern NSString *const SDWebImageDownloadStartNotification;
extern NSString *const SDWebImageDownloadReceiveResponseNotification;
extern NSString *const SDWebImageDownloadStopNotification;
extern NSString *const SDWebImageDownloadFinishNotification;

繼承自NSOperation
@interface SDWebImageDownloaderOperation : NSOperation <SDWebImageOperation>
@property (strong, nonatomic, readonly) NSURLRequest *request;
@property (assign, nonatomic) BOOL shouldDecompressImages;
...
- (id)initWithRequest:(NSURLRequest *)request
              options:(SDWebImageDownloaderOptions)options
             progress:(SDWebImageDownloaderProgressBlock)progressBlock
            completed:(SDWebImageDownloaderCompletedBlock)completedBlock
            cancelled:(SDWebImageNoParamsBlock)cancelBlock;

@end

子類化NSOperation有兩種類型

  • 非并發(fā)型NSOperation
    子類化一個非并發(fā)型operation非常簡單晒旅,只需要重寫main方法即可栅盲。其他的一些復雜的操作比如工程配置,KVO通知父類已經(jīng)幫我們做好了废恋。
    main方法執(zhí)行結(jié)束,該類就被釋放了扒寄。
  • 并發(fā)型NSOperation
    至少需要實現(xiàn)以下幾個方法
- (void)start;
- (BOOL)isConcurrent;
- (BOOL)isExecuting;
- (BOOL)isFinished;

以AFNetworking為例

@implementation AFURLConnectionOperation
- (instancetype)initWithRequest:(NSURLRequest *)urlRequest {
    NSParameterAssert(urlRequest);

    self = [super init];
    if (!self) {
        return nil;
    }

    _state = AFOperationReadyState;

    self.lock = [[NSRecursiveLock alloc] init];
    self.lock.name = kAFNetworkingLockName;

    self.runLoopModes = [NSSet setWithObject:NSRunLoopCommonModes];

    self.request = urlRequest;

    self.shouldUseCredentialStorage = YES;

    self.securityPolicy = [AFSecurityPolicy defaultPolicy];

    return self;
}
- (void)start {
    [self.lock lock];
    if ([self isCancelled]) {
        [self performSelector:@selector(cancelConnection) onThread:[[self class] networkRequestThread] withObject:nil waitUntilDone:NO modes:[self.runLoopModes allObjects]];
    } else if ([self isReady]) {
        self.state = AFOperationExecutingState;

        [self performSelector:@selector(operationDidStart) onThread:[[self class] networkRequestThread] withObject:nil waitUntilDone:NO modes:[self.runLoopModes allObjects]];
    }
    [self.lock unlock];
}

- (BOOL)isConcurrent {
    return YES;
}
- (BOOL)isExecuting {
    return self.state == AFOperationExecutingState;
}

- (BOOL)isFinished {
    return self.state == AFOperationFinishedState;
}

發(fā)出isFinished的kvo通知鱼鼓,代表著opration結(jié)束

typedef NS_ENUM(NSInteger,MyOperationState) {
    MyOperationStateReady,
    MyOperationStateExecuting,
    MyOperationStateFinished,
};

@interface MyOperation ()
@property (nonatomic, copy) MyOperationAction action;
@property (nonatomic, assign) MyOperationState state;
@property (nonatomic, readonly,getter=isCancelled) BOOL cancel;
@end

@implementation MyOperation

#pragma mark - Override
- (BOOL)isReady{
    return self.state == MyOperationStateReady;
}

- (BOOL)isConcurrent{
    return YES;
}

- (BOOL)isExecuting{
    return self.state == MyOperationStateExecuting;
}

- (BOOL)isFinished{
    return self.state == MyOperationStateFinished;
}

- (void)cancel{
    [self willChangeValueForKey:@"isCancelled"];
    _cancel = YES;
    [self didChangeValueForKey:@"isCancelled"];
}

//在start中建立一個thread執(zhí)行任務(wù)
- (void)start{
    if([self isReady]){
        [self willChangeValueForKey:@"isExecuting"];
        [self willChangeValueForKey:@"isReady"];
        self.state = MyOperationStateExecuting;
        [self didChangeValueForKey:@"isReady"];
        [self didChangeValueForKey:@"isExecuting"];
        
        [self performSelector:@selector(operationDidStart) onThread:[[self class] threadForMyOperation] withObject:nil waitUntilDone:NO];
    }
}

- (void)operationDidStart{
    if (self.isCancelled) {
        [self willChangeValueForKey:@"isFinished"];
        [self willChangeValueForKey:@"isCancelled"];
        self.state = MyOperationStateFinished;
        [self didChangeValueForKey:@"isCancelled"];
        [self didChangeValueForKey:@"isFinished"];
    }else{
        self.action();
        [self willChangeValueForKey:@"isFinished"];
        [self willChangeValueForKey:@"isExecuting"];
        self.state = MyOperationStateFinished;
        [self didChangeValueForKey:@"isExecuting"];
        [self didChangeValueForKey:@"isFinished"];
    }
}

#pragma mark Create Singleton Thread
+ (void)keepThreadAlive{
    do{
        @autoreleasepool {
            [[NSRunLoop currentRunLoop] run];
        }
    }while (YES);
}

+ (NSThread*)threadForMyOperation{
    static NSThread *_threadInstance = nil;
    static dispatch_once_t onceToken;
    dispatch_once(&onceToken, ^{
        _threadInstance = [[NSThread alloc] initWithTarget:self selector:@selector(keepThreadAlive) object:nil];
        _threadInstance.name = @"MyOperation.Thread";
        [_threadInstance start];
    });
    
    return _threadInstance;
}
@end

NSOPerationQueue

但是僅僅把計算封裝進一個對象而不做其他處理顯然沒有多大用處,我們還需要NSOperationQueue來大顯身手该编。當operation被添加到隊列之后迄本,NSOperationQueue會瀏覽所有的operation,優(yōu)先運行那些處于ready狀態(tài)且優(yōu)先級較高的操作课竣。

http://nshipster.cn/nsoperation/

//創(chuàng)建隊列
NSOperationQueue *queue = [[NSOperationQueue alloc] init];  

//將NSOperation加入隊列之后嘉赎,queue會自動執(zhí)行該operation
[queue addOperation:operation];

//設(shè)置并發(fā)數(shù)目為2
queue.maxConcurrentOperationCount = 2;

取消任務(wù)

// 取消一個任務(wù) 
[operation cancel];  

// 取消queue中所有的任務(wù)  
[queue cancelAllOperations];

http://nshipster.cn/nsoperation/
http://blog.leichunfeng.com/blog/2015/07/29/ios-concurrency-programming-operation-queues/
refrence

最后編輯于
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請聯(lián)系作者
  • 序言:七十年代末,一起剝皮案震驚了整個濱河市于樟,隨后出現(xiàn)的幾起案子公条,更是在濱河造成了極大的恐慌,老刑警劉巖迂曲,帶你破解...
    沈念sama閱讀 219,490評論 6 508
  • 序言:濱河連續(xù)發(fā)生了三起死亡事件靶橱,死亡現(xiàn)場離奇詭異,居然都是意外死亡路捧,警方通過查閱死者的電腦和手機关霸,發(fā)現(xiàn)死者居然都...
    沈念sama閱讀 93,581評論 3 395
  • 文/潘曉璐 我一進店門,熙熙樓的掌柜王于貴愁眉苦臉地迎上來杰扫,“玉大人队寇,你說我怎么就攤上這事≌滦眨” “怎么了佳遣?”我有些...
    開封第一講書人閱讀 165,830評論 0 356
  • 文/不壞的土叔 我叫張陵炭序,是天一觀的道長。 經(jīng)常有香客問我苍日,道長惭聂,這世上最難降的妖魔是什么? 我笑而不...
    開封第一講書人閱讀 58,957評論 1 295
  • 正文 為了忘掉前任相恃,我火速辦了婚禮辜纲,結(jié)果婚禮上,老公的妹妹穿的比我還像新娘拦耐。我一直安慰自己耕腾,他們只是感情好,可當我...
    茶點故事閱讀 67,974評論 6 393
  • 文/花漫 我一把揭開白布杀糯。 她就那樣靜靜地躺著扫俺,像睡著了一般。 火紅的嫁衣襯著肌膚如雪固翰。 梳的紋絲不亂的頭發(fā)上狼纬,一...
    開封第一講書人閱讀 51,754評論 1 307
  • 那天,我揣著相機與錄音骂际,去河邊找鬼疗琉。 笑死,一個胖子當著我的面吹牛歉铝,可吹牛的內(nèi)容都是我干的盈简。 我是一名探鬼主播,決...
    沈念sama閱讀 40,464評論 3 420
  • 文/蒼蘭香墨 我猛地睜開眼太示,長吁一口氣:“原來是場噩夢啊……” “哼柠贤!你這毒婦竟也來了?” 一聲冷哼從身側(cè)響起类缤,我...
    開封第一講書人閱讀 39,357評論 0 276
  • 序言:老撾萬榮一對情侶失蹤臼勉,失蹤者是張志新(化名)和其女友劉穎,沒想到半個月后呀非,有當?shù)厝嗽跇淞掷锇l(fā)現(xiàn)了一具尸體坚俗,經(jīng)...
    沈念sama閱讀 45,847評論 1 317
  • 正文 獨居荒郊野嶺守林人離奇死亡,尸身上長有42處帶血的膿包…… 初始之章·張勛 以下內(nèi)容為張勛視角 年9月15日...
    茶點故事閱讀 37,995評論 3 338
  • 正文 我和宋清朗相戀三年岸裙,在試婚紗的時候發(fā)現(xiàn)自己被綠了猖败。 大學時的朋友給我發(fā)了我未婚夫和他白月光在一起吃飯的照片。...
    茶點故事閱讀 40,137評論 1 351
  • 序言:一個原本活蹦亂跳的男人離奇死亡降允,死狀恐怖恩闻,靈堂內(nèi)的尸體忽然破棺而出,到底是詐尸還是另有隱情剧董,我是刑警寧澤幢尚,帶...
    沈念sama閱讀 35,819評論 5 346
  • 正文 年R本政府宣布破停,位于F島的核電站,受9級特大地震影響尉剩,放射性物質(zhì)發(fā)生泄漏真慢。R本人自食惡果不足惜,卻給世界環(huán)境...
    茶點故事閱讀 41,482評論 3 331
  • 文/蒙蒙 一理茎、第九天 我趴在偏房一處隱蔽的房頂上張望黑界。 院中可真熱鬧,春花似錦皂林、人聲如沸朗鸠。這莊子的主人今日做“春日...
    開封第一講書人閱讀 32,023評論 0 22
  • 文/蒼蘭香墨 我抬頭看了看天上的太陽烛占。三九已至,卻和暖如春沟启,著一層夾襖步出監(jiān)牢的瞬間忆家,已是汗流浹背。 一陣腳步聲響...
    開封第一講書人閱讀 33,149評論 1 272
  • 我被黑心中介騙來泰國打工美浦, 沒想到剛下飛機就差點兒被人妖公主榨干…… 1. 我叫王不留弦赖,地道東北人。 一個月前我還...
    沈念sama閱讀 48,409評論 3 373
  • 正文 我出身青樓浦辨,卻偏偏與公主長得像,于是被迫代替她去往敵國和親沼沈。 傳聞我的和親對象是個殘疾皇子流酬,可洞房花燭夜當晚...
    茶點故事閱讀 45,086評論 2 355

推薦閱讀更多精彩內(nèi)容