当系统的输入源不足以满足我们的需求的时候, 我们可以自定义输入源. 看了苹果的官方文档, 也没有知道为什么, 所以妄自猜测下, 可能是当系统的输入源不足以满足我们的需求的时候, 我们需要自定义输入源.
定义输入源
网上大部分配置sources的demo, 核心代码都出自这里, 下面简单的对自定义source的类图进行分析.
核心类是CCRunLoopInputSource也就是自定义的输入源. CCRunLoopCustomInputSourceThread是自定义输入源生存的环境.
创建自定义输入源需要定义以下内容
- 1 输入源要处理的信息.
- 2 输入源被添加到Runloop时的调度例程.
- 3 输入源被告知有事件要处理的调度例程.
- 4 输入源被取消时的调度例程.
typedef struct {
CFIndex version;
void * info;
const void *(*retain)(const void *info);
void (*release)(const void *info);
CFStringRef (*copyDescription)(const void *info);
Boolean (*equal)(const void *info1, const void *info2);
CFHashCode (*hash)(const void *info);
void (*schedule)(void *info, CFRunLoopRef rl, CFRunLoopMode mode);
void (*cancel)(void *info, CFRunLoopRef rl, CFRunLoopMode mode);
void (*perform)(void *info);
} CFRunLoopSourceContext;
// CCRunLoopInputSource.m
- (instancetype)init
{
self = [super init];
if (self) {
CFRunLoopSourceContext context = {0, (__bridge void *)(self), NULL, NULL, NULL, NULL, NULL,
&runLoopSourceScheduleRoutine,
&runLoopSourceCancelRoutine,
&runLoopSourcePerformRoutine};
_runLoopSource = CFRunLoopSourceCreate(kCFAllocatorDefault, 0, &context);
_commands = [NSMutableArray array];
}
return self;
}
在CFRunLoopSourceCreate创建输入源的时候, 需要传入CFRunLoopSourceContext结构体指针, 这里第二个参数的info传的是self, 当系统回调时候会把这个信息当成上下文回调, 此外还定义了schedule, perform, cancel三个函数指针, 分别对应事件源被加到Runloop, 输入源被告知有事件要处理, 和输入源失效的函数回调.
当调用以下方法
- (void)addToCurrentRunLoop
{
CFRunLoopRef runLoop = CFRunLoopGetCurrent();
CFRunLoopAddSource(runLoop, _runLoopSource, kCFRunLoopDefaultMode);
}
会导致runLoopSourceScheduleRoutine函数回调,
void runLoopSourceScheduleRoutine (void *info, CFRunLoopRef runLoopRef, CFStringRef mode)
{
CCRunLoopInputSource *runLoopInputSource = (__bridge CCRunLoopInputSource *)info;
CCAppDelegate *appDelegate = [UIApplication sharedApplication].delegate;
CCRunLoopContext *runLoopContext = [[CCRunLoopContext alloc] initWithSource:runLoopInputSource runLoop:runLoopRef];
[appDelegate performSelectorOnMainThread:@selector(registerSource:) withObject:runLoopContext waitUntilDone:NO];
}
这里只是把回调的事件源封装成CCRunLoopContext再抛出去, 这里是抛给CCAppDelegate, 实际上抛给哪个类处理都是可以的.
当执行
- (void)fireAllCommandsOnRunLoop:(CFRunLoopRef)runLoop
{
NSLog(@"Current Thread: %@", [NSThread currentThread]);
CFRunLoopSourceSignal(_runLoopSource);
CFRunLoopWakeUp(runLoop);
}
实际上是把当前事件源标记为有事件要处理, 然后调用CFRunLoopWakeUp唤起线程, 类似我们的
[self.view setNeedsLayout];
[self.view layoutIfNeeded];
将当前画布标记为dirty, 然后触发重绘.
线程被wakeup后, 会执行上一篇博文里面步骤9, 处理source1和timer, 这里当然就是source1了,
void runLoopSourcePerformRoutine (void *info)
{
CCRunLoopInputSource *runLoopInputSource = (__bridge CCRunLoopInputSource *)info;
[runLoopInputSource inputSourceFired];
}
实际是执行了runLoopSourcePerformRoutine回调, 这里我们看到只是将回调传递来的事件源info取出来, 并执行inputSourceFired
- (void)inputSourceFired
{
NSLog(@"Enter inputSourceFired");
// Test
if (_testPrintString) {
if ([self.delegate respondsToSelector:@selector(activeInputSourceForTestPrintStringEvent:)]) {
[self.delegate activeInputSourceForTestPrintStringEvent:_testPrintString];
}
}
NSLog(@"Exit inputSourceFired");
}
这里调用了代理方法activeInputSourceForTestPrintStringEvent, 将, 最终CCRunLoopInputSource的代理CCRunLoopCustomInputSourceThread将处理这个事件.
- (void)activeInputSourceForTestPrintStringEvent:(NSString *)string
{
NSLog(@"activeInputSourceForTestPrintStringEvent : %@", string);
}
当然这里的代理不一定要是CCRunLoopCustomInputSourceThread, 也可以是其它的类.
当调用
- (void)invalidate
{
CFRunLoopRef runLoop = CFRunLoopGetCurrent();
CFRunLoopRemoveSource(runLoop, _runLoopSource, kCFRunLoopDefaultMode);
}
使一个事件源失效的时候, 会触发runLoopSourceCancelRoutine回调
void runLoopSourceCancelRoutine (void *info, CFRunLoopRef runLoopRef, CFStringRef mode)
{
CCRunLoopInputSource *runLoopInputSource = (__bridge CCRunLoopInputSource *)info;
CCAppDelegate *appDelegate = [UIApplication sharedApplication].delegate;
CCRunLoopContext *runLoopContext = [[CCRunLoopContext alloc] initWithSource:runLoopInputSource runLoop:runLoopRef];
[appDelegate performSelectorOnMainThread:@selector(removeSource:) withObject:runLoopContext waitUntilDone:YES];
}
下面看下AppDelegate的代码
@implementation CCAppDelegate (RunLoop)
- (void)registerSource:(CCRunLoopContext *)sourceContext
{
if (!self.sources) {
self.sources = [NSMutableArray array];
}
[self.sources addObject:sourceContext];
}
- (void)removeSource:(CCRunLoopContext *)sourceContext
{
[self.sources enumerateObjectsUsingBlock:^(id obj, NSUInteger idx, BOOL *stop) {
CCRunLoopContext *context = obj;
if ([context isEqual:sourceContext]) {
[self.sources removeObject:context];
*stop = YES;
}
}];
}
- (void)testInputSourceEvent
{
CCRunLoopContext *runLoopContext = [self.sources objectAtIndex:0];
CCRunLoopInputSource *inputSource = runLoopContext.runLoopInputSource;
[inputSource addTestPrintCommandWithString:[[NSDate date] description]];
[inputSource fireAllCommandsOnRunLoop:runLoopContext.runLoop];
}
@end
这里维护了一个输入源的数组, 用来区分不同的输入源. 对于不同的输入源我们可以在testInputSourceEvent选择不同的输入源进行触发.
[inputSource addTestPrintCommandWithString:[[NSDate date] description]];
上面的方法, 我理解是进行数据的传递, 作者也设计了更加通用的接口
- (void)addCommand:(NSInteger)command data:(NSData *)data;
不过demo里面没有使用到.
这里实际上是建立了一个通道和线程状态切换的机制
臆想:
这个通道是线程之间传递数据, 唤醒休眠线程的一套机制, 我们完全可以自定义一个输入源, 用来处理服务器发来的数据.
步骤如下:
- 1 初始化线程的时候创建输入source, 并添加.
- 2 当有数据过来的时候调用
CFRunLoopSourceSignal和CFRunLoopWakeUp, 并将当前数据的回调模块信息保存到CFRunLoopSourceSignal. - 3 在子线程里进行数据解析等一些耗时操作.
- 4 当数据解析完, 将数据封装成
CCRunLoopContext, 找到回调模块, 在主线程进行回调(performSelectorOnMainThread).
相对比dispatch_async这样做的好处是, 在触发事件前, 可以保存一些数据到自定义source, 这样在回调的时候可以很方便的找到指定的方法进行回调, 有点类似运行时的效果.
