在上一篇NSOperation簡單使用中介紹了使用NSInvocationOperation和NSBlockOperation配合NSOperationQueue來實現(xiàn)多線程編程斗锭。
這一篇來看一下通過自定義NSOperation的子類來實現(xiàn)多線程編程泼差。

創(chuàng)建SHOperation繼承NSOperation

#import <Foundation/Foundation.h>

@interface SHOperation : NSOperation

/**NSOperation的線程鎖 */
@property (readwrite, nonatomic, strong) NSRecursiveLock *lock;

/**NSOperation的線程runloop模式 */
@property (nonatomic, strong) NSSet *runLoopModes;

@end

#import "SHOperation.h"

static NSString * const kMsspSDKLockName = @"operation.lock";

@implementation SHOperation
{
    BOOL finished;
    BOOL executing;
}

- (instancetype)init
{
    self = [super init];
    if (!self)
    {
        return nil;
    }
    self.lock = [[NSRecursiveLock alloc] init];
    self.lock.name = kMsspSDKLockName;
    self.runLoopModes = [NSSet setWithObject:NSRunLoopCommonModes];
    
    return self;
}

- (void)start
{
    [self.lock lock];
    if ([self isCancelled])
    {
        [self willChangeValueForKey:@"isFinished"];
        finished = YES;
        [self didChangeValueForKey:@"isFinished"];
        return;
    }
    else if ([self isReady])
    {
        [self willChangeValueForKey:@"isFinished"];
        finished  = NO;
        [self didChangeValueForKey:@"isFinished"];
        
        [self willChangeValueForKey:@"isExecuting"];
        executing = YES;
        [self willChangeValueForKey:@"isExecuting"];
        
        NSLog(@"這里是start,線程號：%@", [NSThread currentThread]);
        //[self performSelector:@selector(operationDidStart) onThread:[[self class] networkRequestThread] withObject:nil waitUntilDone:NO];
        [self performSelector:@selector(operationDidStart) onThread:[[self class] networkRequestThread] withObject:nil waitUntilDone:NO modes:[self.runLoopModes allObjects]];
    }
    [self.lock unlock];
}

+ (NSThread *)networkRequestThread
{
    NSLog(@"networkRequestThread");
    static NSThread *_networkRequestThread = nil;
    static dispatch_once_t oncePredicate;
    dispatch_once(&oncePredicate, ^{
        _networkRequestThread = [[NSThread alloc] initWithTarget:self selector:@selector(networkRequestThreadEntryPoint:) object:nil];
        [_networkRequestThread start];
    });
    
    return _networkRequestThread;
}

+ (void)networkRequestThreadEntryPoint:(id)__unused object {
    @autoreleasepool {
        NSLog(@"networkRequestThreadEntryPoint");
        [[NSThread currentThread] setName:@"TestThread"];
        NSRunLoop *runloop = [NSRunLoop currentRunLoop];
        [runloop addPort:[NSMachPort port] forMode:NSDefaultRunLoopMode];
        [runloop run];
    }
}

- (void)operationDidStart
{
    [self.lock lock];
    if (![self isCancelled])
    {
        NSLog(@"operationDidStart");
    }
    [self.lock unlock];
}

- (void)finishOperation
{
    [self.lock lock];
    NSLog(@"is finishOperation");
    [self willChangeValueForKey:@"isExecuting"];
    executing = NO;
    [self didChangeValueForKey:@"isExecuting"];
    
    [self willChangeValueForKey:@"isFinished"];
    finished  = YES;
    [self didChangeValueForKey:@"isFinished"];
    [self.lock unlock];
}

- (BOOL) isConcurrent{
    NSLog(@"is concurrent");
    return YES;
}

- (BOOL) isFinished{
    NSLog(@"is finished");
    return finished;
}

- (BOOL) isExecuting{
    NSLog(@"is executing");
    return executing;
}

//- (void)cancel
//{
//    [self.lock lock];
//    if (![self isFinished] && ![self isCancelled])
//    {
//        [super cancel];
//    }
//    [self.lock unlock];
//}

@end

創(chuàng)建線程類，繼承SHOperation類

#import <Foundation/Foundation.h>
#import "SHOperation.h"

@interface T1Operation : SHOperation

@end

#import "T1Operation.h"

@implementation T1Operation

- (void)operationDidStart
{
    [self.lock lock];
    if (![self isCancelled])
    {
        //需要在線程中運行的代碼
        NSLog(@"T1   operationDidStart");
    }
    [self.lock unlock];
}

@end

開啟線程

//創(chuàng)建隊列
 NSOperationQueue *queue = [[NSOperationQueue alloc] init];
//創(chuàng)建操作
    T1Operation *t1 = [[T1Operation alloc] init];
//將操作加入隊列中
    [queue addOperation:t1];

項目代碼：github

參考

• 參考1
• 參考2
• 參考3