QueuedInputListener#flush方法
该方法在InputReader#loopOnce最后触发。flush刷新将遍历QueuedInputListener中mArgsQueue的数组元素，触发每一个元素NotifyArgs的notify方法，交给内部InputDispatcher，清空数组。
void QueuedInputListener::flush() {
size_t count = mArgsQueue.size();
for (size_t i = 0; i < count; i++) {
NotifyArgs* args = mArgsQueue[i];
args->notify(mInnerListener);
delete args;
}
刷新完毕清空数组
mArgsQueue.clear();
}
NotifyMotionArgs#notify方法，调用派发者InputDispatcher的通知notifyMotion，将自己交给派发者。
void NotifyMotionArgs::notify(const sp<InputListenerInterface>& listener) const {
listener->notifyMotion(this);
}
InputDispatcher实现了通知各类事件的方法notifyXXX(XXX)。
这样，从数组取出每一个事件，调用一次InputDispatcher的notifyMotion方法处理，事件交给InputDispatcher。
InputDispatcher#notifyMotion方法
这时仍然是读取线程InputReaderThread在处理事务，notifyMotion方法之后会唤醒分发线程，接下来的任务就由分发线程处理了。
void InputDispatcher::notifyMotion(const NotifyMotionArgs* args) {
...
//将NotifyMotionArgs的数据封装为MotionEntry
MotionEntry* newEntry = new MotionEntry(args->eventTime,
args->deviceId, args->source, policyFlags,
args->action, args->actionButton, args->flags,
args->metaState, args->buttonState,
args->edgeFlags, args->xPrecision, args->yPrecision, args->downTime,
args->displayId,
args->pointerCount, args->pointerProperties, args->pointerCoords, 0, 0);
插入InputDispatcher的mInboundQueue队列中
needWake = enqueueInboundEventLocked(newEntry);
...
//需要唤醒分发线程
if (needWake) {
mLooper->wake();
}
}
数据封装成MotionEntry，封装的触屏信息MotionEntry插入InputDispatcher的mInboundQueue队列。
InputDispatcher#enqueueInboundEventLocked方法
Queue<EventEntry> mInboundQueue;
bool InputDispatcher::enqueueInboundEventLocked(EventEntry* entry) {
bool needWake = mInboundQueue.isEmpty();//队列为空时，唤醒
mInboundQueue.enqueueAtTail(entry);//插入到尾部
...
}
注意：mLooper属于InputDispatcher，InputManager创建InputDispatcher时，在其构造方法同时创建mLooper，创建的线程是服务线程，并非读取或分发线程
这里只是借用了Looper提供的epoll唤醒与休眠机制，在分发线程中InputDispatcherThread中使用mLooper休眠，读取线程负责唤醒。
InputDispatcherThread分发线程被唤醒
在InputDispatcherThread线程threadLoop循环中，触发InputDispatcher的dispatchOnce方法。
InputDispatcher#dispatchOnce方法
void InputDispatcher::dispatchOnce() {
//下次唤醒事件，设置无限大
nsecs_t nextWakeupTime = LONG_LONG_MAX;
{ // acquire lock
AutoMutex _l(mLock);
...
//mCommandQueue为空时，触发dispatchOnceInnerLocked
if (!haveCommandsLocked()) {
dispatchOnceInnerLocked(&nextWakeupTime);
}
if (runCommandsLockedInterruptible()) {//mCommandQueue为空时是false
nextWakeupTime = LONG_LONG_MIN;
}
} // release lock
nsecs_t currentTime = now();
//计算下一次唤醒时间，比当前时间大。
int timeoutMillis = toMillisecondTimeoutDelay(currentTime, nextWakeupTime);
mLooper->pollOnce(timeoutMillis);
}
利用Looper在epoll_wait处进入休眠，休眠timeoutMillis时间仍无事件，threadLoop会一直循环，继续dispatchOnce。
当被唤醒时，执行循环进入dispatchOnceInnerLocked取出队列中的事件。
mPendingEvent = mInboundQueue.dequeueAtHead();
//判断事件类型
switch (mPendingEvent->type) {
...
case EventEntry::TYPE_MOTION: {
MotionEntry* typedEntry = static_cast<MotionEntry*>(mPendingEvent);
...
done = dispatchMotionLocked(currentTime, typedEntry,
&dropReason, nextWakeupTime);
break;
}
...
}
wake唤醒
Looper借助epoll机制实现线程休眠，它本身内部有套接字mWakeEventFd，在rebuildEpollLocked建立时，注册到epoll_ctl监听。因此wake方法就是向mWakeEventFd套接字发送一段字符，促使epoll_wait处的线程能监听到，从而InputDispatcherThread线程被唤醒。
综上，InputDispatcherThread线程负责事件的具体分发。InputDispatcher#dispatchMotionLocked处理MotionEntry。
下一步是将事件交给具体的进程。
Happy
End
^ ^
