我们经常在子线程中处理一些非UI的任务,我们知道子线程处理完任务后就会自动销毁,假设某个界面需要经常在子线程中处理事情,那么线程的不断创建,销毁也是消耗性能的,因此需求就来了:

如何设计一个可控的子线程方便外界的使用?单个子线程,串行的执行任务

1.考虑设计成继承自NSThread,提供一些额外的对外接口

@interface DXThread : NSThread

@end

这样子做坏处:自定义的这个类DXThread,任然有很多系统方法没法控制外界的调用,比如我不希望外界调用线程NSThread的cancel方法,你根本就没有办法控制

2.把自定义一个继承自NSObject的类,里面自定义一个线程DXThread,这样就控制了外界,哪些方法可以使用

首先使用的时候,我们想要达到使用的效果

// 1.创建一个对象(线程)
- (void)viewDidLoad {
    [super viewDidLoad];
    
    self.threadManager = [[DXThreadManager alloc] init];
}

// 2.让对象(线程)去执行任务
- (void)touchesBegan:(NSSet<UITouch *> *)touches withEvent:(UIEvent *)event{
    [self.threadManager executeTask:^{
        NSLog(@"执行任务 - %@", [NSThread currentThread]);
    }];
}
// 3.让对象停止线程
- (IBAction)stop {
    [self.threadManager destroyThread];
}
// 4.重启线程
- (IBAction)resumeThread:(id)sender {
    [self.threadManager resumeThread];
}

1.首先创建一个集成自NSObject的类,定义对外的接口 头文件代码如下

#import <Foundation/Foundation.h>

typedef void (^MJPermenantThreadTask)(void);

@interface DXThreadManager : NSObject
/**
 在当前子线程执行一个任务
 */
- (void)executeTask:(MJPermenantThreadTask)task;

/**
 当我们确定线程不需要了,才会主动的调用这个接口
 结束线程,注意:线程结束后,就不能在继续使用这个线程做任务
 */
- (void)destroyThread;
/**
 重启线程,如果发现当前线程没有结束,不会创建一个新的线程,继续使用当前线程,否则创建一个新的线程
 注意:重启的新线程跟之前的线程肯定不是同一个线程,示例如下
 旧线程: 0x60000388bf80>{number = 3, name = (null)}
 新线程: 0x600003850740>{number = 4, name = (null)}
 */
- (void)resumeThread;
@end

.m文件的代码实现


@interface DXThreadManager()

@property (strong, nonatomic) NSThread *innerThread;
@property (assign, nonatomic, getter=isStopped) BOOL stopped;

@end

@implementation DXThreadManager
#pragma mark - public methods
- (instancetype)init{
    if (self = [super init]) {
        self.stopped = NO;
        
        __weak typeof(self) weakSelf = self;
        
        self.innerThread = [[NSThread alloc] initWithBlock:^{
            [[NSRunLoop currentRunLoop] addPort:[[NSPort alloc] init] forMode:NSDefaultRunLoopMode];
            
            while (weakSelf && !weakSelf.isStopped) {
                [[NSRunLoop currentRunLoop] runMode:NSDefaultRunLoopMode beforeDate:[NSDate distantFuture]];
            }
        }];
        
        [self.innerThread start];
    }
    return self;
}

- (void)executeTask:(MJPermenantThreadTask)task{
    if (!self.innerThread || !task) return;
    
    [self performSelector:@selector(__executeTask:) onThread:self.innerThread withObject:task waitUntilDone:NO];
}

- (void)destroyThread{
    if (!self.innerThread) return;
    
    [self performSelector:@selector(__stop) onThread:self.innerThread withObject:nil waitUntilDone:YES];
}
// 重新建一个线程
- (void)resumeThread{
    if (self.innerThread == nil || self.innerThread.isCancelled) {
        self.stopped = NO;
        
        __weak typeof(self) weakSelf = self;
        
        self.innerThread = [[NSThread alloc] initWithBlock:^{
            [[NSRunLoop currentRunLoop] addPort:[[NSPort alloc] init] forMode:NSDefaultRunLoopMode];
            
            while (weakSelf && !weakSelf.isStopped) {
                [[NSRunLoop currentRunLoop] runMode:NSDefaultRunLoopMode beforeDate:[NSDate distantFuture]];
            }
        }];
        
        [self.innerThread start];
    }
}

// 监听类DXPermenantThread是否销毁
- (void)dealloc{
    NSLog(@"%s", __func__);
    // 对象DXThreadManager销毁之前,停止线程
    [self destroyThread];
}

#pragma mark - private methods
// 停止线程
- (void)__stop{
    self.stopped = YES;
    CFRunLoopStop(CFRunLoopGetCurrent());
    self.innerThread = nil;
}

- (void)__executeTask:(MJPermenantThreadTask)task{
    task();
}

@end

总结一下:,如何使用这个子线程做任务

1.导入这个线程管理类,创建这个线程管理类,使用属性进行保存

#import "DXThreadManager.h"
@property (strong, nonatomic) DXThreadManager *threadManager;

self.threadManager = [[DXPermenantThread alloc] init];

2.执行任务

[self.threadManager executeTask:^{
    NSLog(@"执行任务 - %@", [NSThread currentThread]);
}];

3.销毁线程(可选,默认DXPermenantThread这个对象销毁的时候,线程就会停止)

[self.threadManager destroyThread];

4.重启线程(可选,如果之前的线程已经销毁,例如主动调用了destroyThread方法,需要重新建一个线程,才能继续处理任务)

- (IBAction)resumeThread:(id)sender {
    [self.threadManager resumeThread];
}

注意:这个设计是单个子线程,串行的执行任务