Android 中Looper机制详解

news/2024/11/29 9:34:13/

版本基于：Android R

 

 

0. 前言

在《Android 基于Handler 剖析消息机制》一文中，以 Handler 类为起点详细分析了异步通信，分析了Java 端 Handler 与Looper、MessageQueue、Message 之前的通信关系。

框架如下：

在Java 端的 Looper 中会创建一个 Java 端的 MessageQueue实例，并在loop() 函数中的死循环里通过 queue.next() 不停的获取监听到的下一个 Message，然后将其通过 dispatchMessage() 分发处理。详细看《Android 基于Handler 剖析消息机制》一文第 4.3 节。

在 Java 端的 MessageQueue 实现核心机制是通过 Native 端的 MessageQueue，该类的对象中维护了一个 native Looper，上面说到的 Java 端的next() 函数就是通过 native 端的 epoll 机制 进行阻塞监听。

之前《Android 基于Handler 剖析消息机制》一文只是对 native Looper 做了简单的介绍，本文将重点分析一下 native Looper 实现机制。

1. Looper 类

system/core/libutils/include/utils/Looper.hclass Looper : public RefBase {
protected:virtual ~Looper();public:Looper(bool allowNonCallbacks);bool getAllowNonCallbacks() const;int pollOnce(int timeoutMillis, int* outFd, int* outEvents, void** outData);inline int pollOnce(int timeoutMillis) {return pollOnce(timeoutMillis, nullptr, nullptr, nullptr);}int pollAll(int timeoutMillis, int* outFd, int* outEvents, void** outData);inline int pollAll(int timeoutMillis) {return pollAll(timeoutMillis, nullptr, nullptr, nullptr);}void wake();int addFd(int fd, int ident, int events, Looper_callbackFunc callback, void* data);int addFd(int fd, int ident, int events, const sp<LooperCallback>& callback, void* data);int removeFd(int fd);void sendMessage(const sp<MessageHandler>& handler, const Message& message);void sendMessageDelayed(nsecs_t uptimeDelay, const sp<MessageHandler>& handler,const Message& message);void sendMessageAtTime(nsecs_t uptime, const sp<MessageHandler>& handler,const Message& message);void removeMessages(const sp<MessageHandler>& handler);void removeMessages(const sp<MessageHandler>& handler, int what);bool isPolling() const;static sp<Looper> prepare(int opts);static void setForThread(const sp<Looper>& looper);static sp<Looper> getForThread();private:...const bool mAllowNonCallbacks; // immutableandroid::base::unique_fd mWakeEventFd;  // immutableVector<MessageEnvelope> mMessageEnvelopes; // guarded by mLock...
};

简单了列举了下 Looper 类中的成员，后面根据流程再详细说明。

2. Looper 构造函数

system/core/libutils/Looper.cppLooper::Looper(bool allowNonCallbacks): mAllowNonCallbacks(allowNonCallbacks),mSendingMessage(false),mPolling(false),mEpollRebuildRequired(false),mNextRequestSeq(0),mResponseIndex(0),mNextMessageUptime(LLONG_MAX) {mWakeEventFd.reset(eventfd(0, EFD_NONBLOCK | EFD_CLOEXEC));LOG_ALWAYS_FATAL_IF(mWakeEventFd.get() < 0, "Could not make wake event fd: %s", strerror(errno));AutoMutex _l(mLock);rebuildEpollLocked();
}

参数 allowNonCallbacks 指定该 Looper 中是否允许在 addFd() 的时候可以不设定 callback，如果为true，则在addFd() 时可以不用设定callback，如果为 false，则在 addFd() 的时候需要指定 callback，否则会报错，详细可以查看 addFd() 函数。

构造函数中主要做了两件事情：

  • 创建一个 wakeEventFd；
  • 调用 rebuildEpollLocked() 初始化 epoll；

2.1 rebuildEpollLocked()

system/core/libutils/Looper.cppvoid Looper::rebuildEpollLocked() {//step1，如果是重构epoll 时的逻辑，需要进行resetif (mEpollFd >= 0) {
#if DEBUG_CALLBACKSALOGD("%p ~ rebuildEpollLocked - rebuilding epoll set", this);
#endifmEpollFd.reset();}//step2，分配一个新的epoll，并将wakeEventFd添加到监听mEpollFd.reset(epoll_create1(EPOLL_CLOEXEC));LOG_ALWAYS_FATAL_IF(mEpollFd < 0, "Could not create epoll instance: %s", strerror(errno));struct epoll_event eventItem;memset(& eventItem, 0, sizeof(epoll_event)); // zero out unused members of data field unioneventItem.events = EPOLLIN;eventItem.data.fd = mWakeEventFd.get();int result = epoll_ctl(mEpollFd.get(), EPOLL_CTL_ADD, mWakeEventFd.get(), &eventItem);LOG_ALWAYS_FATAL_IF(result != 0, "Could not add wake event fd to epoll instance: %s",strerror(errno));//step3，是否有其他的request，如果有，也重新加入到epoll中监听//一般request 通过addFd 函数添加for (size_t i = 0; i < mRequests.size(); i++) {const Request& request = mRequests.valueAt(i);struct epoll_event eventItem;request.initEventItem(&eventItem);int epollResult = epoll_ctl(mEpollFd.get(), EPOLL_CTL_ADD, request.fd, &eventItem);if (epollResult < 0) {ALOGE("Error adding epoll events for fd %d while rebuilding epoll set: %s",request.fd, strerror(errno));}}
}

大致流程如上面注释，主要是三步：

  • 如果是重构 epoll 时的逻辑，需要进行reset；
  • 分配一个新的 epoll，并将 wakeEventFd添加到监听；
  • 是否有其他的 request，如果有，也重新加入到epoll中监听；

3. MessageHandler 类

system/core/libutils/include/utils/Looper.hclass MessageHandler : public virtual RefBase {
protected:virtual ~MessageHandler();public:/*** Handles a message.*/virtual void handleMessage(const Message& message) = 0;
};

在 Looper.h 中还定义了 MessageHandler 这样的类，同Java 端的 Handler类，都是用来处理消息的。

当创建好 MessageHandler 对象之后，可以通过 Looper::sendMessage() 函数发送消息到Looper 中，Looper 会在后续的 pollOnce() 中进行监听，最终通过 handleMessage() 函数进行回调处理此次消息。

 

3.1 sendMessage()

在 Looper.h 中我们看到三个详细的函数：

    void sendMessage(const sp<MessageHandler>& handler, const Message& message);void sendMessageDelayed(nsecs_t uptimeDelay, const sp<MessageHandler>& handler,const Message& message);void sendMessageAtTime(nsecs_t uptime, const sp<MessageHandler>& handler,const Message& message);

 但其实前面两个函数最终调用的都是 sendMessageAtTime() 函数：

system/core/libutils/Looper.cppvoid Looper::sendMessage(const sp<MessageHandler>& handler, const Message& message) {nsecs_t now = systemTime(SYSTEM_TIME_MONOTONIC);sendMessageAtTime(now, handler, message);
}void Looper::sendMessageDelayed(nsecs_t uptimeDelay, const sp<MessageHandler>& handler,const Message& message) {nsecs_t now = systemTime(SYSTEM_TIME_MONOTONIC);sendMessageAtTime(now + uptimeDelay, handler, message);
}void Looper::sendMessageAtTime(nsecs_t uptime, const sp<MessageHandler>& handler,const Message& message) {
#if DEBUG_CALLBACKSALOGD("%p ~ sendMessageAtTime - uptime=%" PRId64 ", handler=%p, what=%d",this, uptime, handler.get(), message.what);
#endifsize_t i = 0;{ // acquire lockAutoMutex _l(mLock);size_t messageCount = mMessageEnvelopes.size();while (i < messageCount && uptime >= mMessageEnvelopes.itemAt(i).uptime) {i += 1;}MessageEnvelope messageEnvelope(uptime, handler, message);mMessageEnvelopes.insertAt(messageEnvelope, i, 1);// Optimization: If the Looper is currently sending a message, then we can skip// the call to wake() because the next thing the Looper will do after processing// messages is to decide when the next wakeup time should be.  In fact, it does// not even matter whether this code is running on the Looper thread.if (mSendingMessage) {return;}} // release lock// Wake the poll loop only when we enqueue a new message at the head.if (i == 0) {wake();}
}

这里涉及到了 Looper 中的另外一个成员变量：mMessageEnvelopes，这是一个 Vector 类型变量，用以存放通过 sendMessage() 发送到 Looper 中的消息。

如代码所示，会将 message、message handler、uptime 都存放在一个信封对象中，然后将该信封添加到 mMessageEnvelopes 中。

这里还涉及另外一个成员变量：mSendingMessage，用以标记当前是否正在 handleMessage() 处理消息。当该函数执行的时候，mSendingMessage 被置 true，标记正在处理，在处理函数完成之后会将其再次置 false。

4. LooperCallback 类

system/core/libutils/include/utils/Looper.hclass LooperCallback : public virtual RefBase {
protected:virtual ~LooperCallback();public:/*** Handles a poll event for the given file descriptor.* It is given the file descriptor it is associated with,* a bitmask of the poll events that were triggered (typically EVENT_INPUT),* and the data pointer that was originally supplied.** Implementations should return 1 to continue receiving callbacks, or 0* to have this file descriptor and callback unregistered from the looper.*/virtual int handleEvent(int fd, int events, void* data) = 0;
};

该类用以处理通过 addFd() 添加监听的 fd。在 addFd() 函数中会同步指定 callback，就是这里的 LooperCallback 对象。

 

4.1 addFd()

在 Looper.h 中可以看到该函数的声明：

    int addFd(int fd, int ident, int events, Looper_callbackFunc callback, void* data);int addFd(int fd, int ident, int events, const sp<LooperCallback>& callback, void* data);
system/core/libutils/Looper.cppint Looper::addFd(int fd, int ident, int events, Looper_callbackFunc callback, void* data) {return addFd(fd, ident, events, callback ? new SimpleLooperCallback(callback) : nullptr, data);
}int Looper::addFd(int fd, int ident, int events, const sp<LooperCallback>& callback, void* data) {if (!callback.get()) {if (! mAllowNonCallbacks) {ALOGE("Invalid attempt to set NULL callback but not allowed for this looper.");return -1;}if (ident < 0) {ALOGE("Invalid attempt to set NULL callback with ident < 0.");return -1;}} else {ident = POLL_CALLBACK;}{ // acquire lockAutoMutex _l(mLock);Request request;request.fd = fd;request.ident = ident;request.events = events;request.seq = mNextRequestSeq++;request.callback = callback;request.data = data;if (mNextRequestSeq == -1) mNextRequestSeq = 0; // reserve sequence number -1struct epoll_event eventItem;request.initEventItem(&eventItem);ssize_t requestIndex = mRequests.indexOfKey(fd);if (requestIndex < 0) {int epollResult = epoll_ctl(mEpollFd.get(), EPOLL_CTL_ADD, fd, &eventItem);if (epollResult < 0) {ALOGE("Error adding epoll events for fd %d: %s", fd, strerror(errno));return -1;}mRequests.add(fd, request);} else {int epollResult = epoll_ctl(mEpollFd.get(), EPOLL_CTL_MOD, fd, &eventItem);if (epollResult < 0) {if (errno == ENOENT) {epollResult = epoll_ctl(mEpollFd.get(), EPOLL_CTL_ADD, fd, &eventItem);if (epollResult < 0) {ALOGE("Error modifying or adding epoll events for fd %d: %s",fd, strerror(errno));return -1;}scheduleEpollRebuildLocked();} else {ALOGE("Error modifying epoll events for fd %d: %s", fd, strerror(errno));return -1;}}mRequests.replaceValueAt(requestIndex, request);}} // release lockreturn 1;
}

这里涉及到 Looper 中的另外一个成员变量：mRequests，这是一个KeyedVector 类型的变量，用以存放通过 addFd() 添加的监听请求。

如代码所示，首先确认 mRequests 中是否已经存放该 fd 的监听，如果没有，则通过 epoll_ctl() 将对该 fd 的监听添加到 epoll 中，并将此次的请求添加到 mRequests 中；如果已经存在对该 fd 的监听，则对 epoll 进行更改，并将 mRequests 中的request 进行替换。

 

5. wake()

system/core/libutils/Looper.cppvoid Looper::wake() {
#if DEBUG_POLL_AND_WAKEALOGD("%p ~ wake", this);
#endifuint64_t inc = 1;ssize_t nWrite = TEMP_FAILURE_RETRY(write(mWakeEventFd.get(), &inc, sizeof(uint64_t)));if (nWrite != sizeof(uint64_t)) {if (errno != EAGAIN) {LOG_ALWAYS_FATAL("Could not write wake signal to fd %d (returned %zd): %s",mWakeEventFd.get(), nWrite, strerror(errno));}}
}

通过往 mWakeEventFd 中写个数据来达到唤醒的目的。

6. 


http://www.ppmy.cn/news/569360.html

相关文章

可视化的工时管理：让项目进度真实可见

可视化的工时管理：让项目进度真实可见

在现代项目管理中&#xff0c;工时表软件作为一种强大而有效的工具&#xff0c;能够帮助团队更好地管理项目进度。无论是大小型项目&#xff0c;正确使用工时表软件都可以提高团队的效率和项目的可追踪性。本文将介绍一些关键步骤&#xff0c;以帮助企业利用工时表软件来管理项…
阅读更多...
office 2021下载地址

office 2021下载地址

http://officecdn.microsoft.com/pr/492350f6-3a01-4f97-b9c0-c7c6ddf67d60/media/zh-cn/HomeStudent2021Retail.img
阅读更多...
Adobe Audition CC 2019 下载安装教程

Adobe Audition CC 2019 下载安装教程

一、下载 链接: https://pan.baidu.com/s/1JVw2HjgsF240-1bxLJNISA 提取码: fr33 下载好后解压 解压后的文件如下 二、安装 1.以管理员身份运行Set-up.exe 更改安装位置 创建一个名为“AU2019”文件夹&#xff0c;然后点击确定 点击继续 等待安装完成后&#xff0c;点击关闭…
阅读更多...
Office Professional Plus 2019 下载安装激活

Office Professional Plus 2019 下载安装激活

Office Professional Plus 2019 简体中文版 官方原版 文件名cn_office_professional_plus_2019_x86_x64_dvd_5e5be643.isoSHA1d850365b23e1e1294112a51105a2892b2bd88eb9文件大小3.52GB发布时间2018-10-03序列号不提供&#xff0c;自己解决 下载地址 ed2k://|file|cn_office…
阅读更多...
office 2019中文

office 2019中文

虽然现在Office已经更新到2021版本&#xff0c;但是经典的2019 office依然受到追捧&#xff0c;office 2019通过添加更多功能并将新工具添加到表中来改进office 2016的高级功能&#xff0c;由于office 2016是早期版本&#xff0c;因此可以将一些主要差异精确定位为Microsoft对o…
阅读更多...
Adobe Audition CC 2020中文版

Adobe Audition CC 2020中文版

安装教程 1、在我们下载之家下载Adobe Audition cc 2020并解压缩&#xff0c;双击里面的 Set-up.exe进行安装 2、可以更改安装路径 3、然后等待安装&#xff1a; 4、提示安装完毕 5、在开始菜单&#xff0c;打开Adobe Audition 2020的文件位置。 6、选择Adobe Audition 2020&a…
阅读更多...
Office Professional Plus 2016简体中文版

Office Professional Plus 2016简体中文版

Office Professional Plus 2016简体中文版 官方MSDN 版本号16.0.4266.1003 64位、32位都在这一个镜像里&#xff0c;默认安装为32位版本&#xff0c;想安装64位的请点开office文件夹运行setup64.exe office2016最好用的就是添加了功能搜索&#xff0c;再也不用为找不到…
阅读更多...
官方免费工具（ODT）安装新版 Office2021【视频演示】

官方免费工具（ODT）安装新版 Office2021【视频演示】

导语&#xff1a;现在网络上几乎所有的Office 2021 的iso安装镜像&#xff0c;都不是官方发布的。演示如何使用最新的官方免费安装工具(ODT)在Windows11上安装原版的永久授权的 Office 2021。附离线安装包链接。 使用官方免费工具安装永久授权的正版Office2021 现在网络上几乎所…
阅读更多...
最新文章

Copyright @ 2022~2023