當(dāng)創(chuàng)建一個線程殴玛，并且希望它一直存在時擎宝，但往往我們創(chuàng)建的線程都是執(zhí)行完成之后也就停止了郁惜，不能再次利用水评，那么如何創(chuàng)建一個線程可以讓他可以再次工作呢,這個時候就需要使用到RunLoop了猩系。
1.OC語言實(shí)現(xiàn)
#import <Foundation/Foundation.h>
typedef void (^PermenantThreadTask)(void);
@interface PermenantThread : NSObject
/**
開啟線程
*/
//- (void)run;
/**
在當(dāng)前子線程執(zhí)行一個任務(wù)
*/
- (void)executeTask:(PermenantThreadTask)task;
/**
結(jié)束線程
*/
- (void)stop;
@end
#import "PermenantThread.h"
/** PermenantThread **/
@interface PermenantThread()
@property (strong, nonatomic) NSThread *innerThread;
@property (assign, nonatomic, getter=isStopped) BOOL stopped;
@end
@implementation PermenantThread
#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:(PermenantThreadTask)task
{
if (!self.innerThread || !task) return;
[self performSelector:@selector(__executeTask:) onThread:self.innerThread withObject:task waitUntilDone:NO];
}
- (void)stop
{
if (!self.innerThread) return;
[self performSelector:@selector(__stop) onThread:self.innerThread withObject:nil waitUntilDone:YES];
}
- (void)dealloc
{
NSLog(@"%s", __func__);
[self stop];
}
#pragma mark - private methods
- (void)__stop
{
self.stopped = YES;
CFRunLoopStop(CFRunLoopGetCurrent());
self.innerThread = nil;
}
- (void)__executeTask:(PermenantThreadTask)task
{
task();
}
@end
2.C語言實(shí)現(xiàn)
#import <Foundation/Foundation.h>
typedef void (^PermenantThreadTask)(void);
@interface PermenantThread : NSObject
/**
開啟線程
*/
//- (void)run;
/**
在當(dāng)前子線程執(zhí)行一個任務(wù)
*/
- (void)executeTask:(PermenantThreadTask)task;
/**
結(jié)束線程
*/
- (void)stop;
@end
#import "PermenantThread.h"
/** PermenantThread **/
@interface PermenantThread()
@property (strong, nonatomic) NSThread *innerThread;
@end
@implementation PermenantThread
#pragma mark - public methods
- (instancetype)init
{
if (self = [super init]) {
self.innerThread = [[NSThread alloc] initWithBlock:^{
NSLog(@"begin----");
// 創(chuàng)建上下文（要初始化一下結(jié)構(gòu)體）
CFRunLoopSourceContext context = {0};
// 創(chuàng)建source
CFRunLoopSourceRef source = CFRunLoopSourceCreate(kCFAllocatorDefault, 0, &context);
// 往Runloop中添加source
CFRunLoopAddSource(CFRunLoopGetCurrent(), source, kCFRunLoopDefaultMode);
// 銷毀source
CFRelease(source);
// 啟動
CFRunLoopRunInMode(kCFRunLoopDefaultMode, 1.0e10, false);
// while (weakSelf && !weakSelf.isStopped) {
// // 第3個參數(shù)：returnAfterSourceHandled，設(shè)置為true之碗，代表執(zhí)行完source后就會退出當(dāng)前l(fā)oop
// CFRunLoopRunInMode(kCFRunLoopDefaultMode, 1.0e10, true);
// }
NSLog(@"end----");
}];
[self.innerThread start];
}
return self;
}
//- (void)run
//{
// if (!self.innerThread) return;
//
// [self.innerThread start];
//}
- (void)executeTask:(PermenantThreadTask)task
{
if (!self.innerThread || !task) return;
[self performSelector:@selector(__executeTask:) onThread:self.innerThread withObject:task waitUntilDone:NO];
}
- (void)stop
{
if (!self.innerThread) return;
[self performSelector:@selector(__stop) onThread:self.innerThread withObject:nil waitUntilDone:YES];
}
- (void)dealloc
{
NSLog(@"%s", __func__);
[self stop];
}
#pragma mark - private methods
- (void)__stop
{
CFRunLoopStop(CFRunLoopGetCurrent());
self.innerThread = nil;
}
- (void)__executeTask:(PermenantThreadTask)task
{
task();
}
@end
