热门标签 | HotTags
当前位置:  开发笔记 > 运维 > 正文

使用C++11实现Android系统的Handler机制

这篇文章主要介绍了使用C++11实现Android系统的Handler机制,本文通过实例代码给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下

封面出自:板栗懒得很背景

线程作为系统的基础资源,相信大多数读者都有使用到。一般情况下我们会直接开一个线程做一些耗时操作,处理完之后让线程自动结束,资源被系统回收。这种简单粗暴的方法不少读者、甚至一些大厂的APP都在用。以Java语言为例,我们可以直接new一个Thread对象,然后覆盖run方法,最后调一下start方法便可以成功运行一个线程。如果我们每次异步做一些耗时处理都单独开启一个线程,比如异步加载网络图片这种高并发操作,每张图片都开一个线程的话,必然会造成线程资源的浪费,而且也没有很好的方法去处理跨线程通讯的问题。由于语言层面的低成本导致系统的线程资源被滥用,已经成为了一个很普遍的现象。

new Thread(){

 @Override

 public void run() {

 //Do somethings

 }

}.start()

Handler

  Handler机制通过开启一个子线程,并进入死循环,不停消费其它线程发送过来的消息,从而达到跨线程通讯的目的。Handler主要用于跨线程通讯,但同时也能在一定程度上复用线程,是一种比较理想的线程使用方式。Android系统Handler主要包含以下三部分:

  • Handler
  • Looper
  • Message & MessageQueue

Handler顾名思义就是消息的处理类,同时也是消息发送的代理入口,通过调用Handler的相关接口发送一条消息,最终会被转发到Looper,由Looper把Message加入到队列的尾部。Looper是消息循环驱动的动力所在,我们规定同一个线程只能拥有一个Looper,当Looper准备好之后会让线程进入死循环,如果内部的Message队列不为空时,则会不停的从消息队列头部取出一条Message进行消费,直到队列为空,Looper阻塞线程进入等待状态。Message内部会记录着发送消息的Handler,当被消费时就可以找到对应的Handler进行消息处理,最终形成闭环。

实现

下面尝试使用C++11来实现Android系统Handler机制,该实现主要由AlHandlerThread、AlHandler、AlLooperManager、AlLooper、AlMessageQueue和AlMessage六个类组成。我们规定一个线程只能拥有一个AlLooper,因此需要一个AlLooperManager负责对所有线程的AlLooper对象进行管理,如果当前线程已经拥有了AlLooper对象,则直接使用当前线程的对象,保证AlLooper唯一。而AlMessageQueue则是一个支持线程阻塞和唤醒的消息队列。AlHandlerThread则是一个封装了std::thread和AlLooper的简单线程实现,仅仅是为了方便使用AlLooper,与Android系统中的HandlerThread实现是一致的。

AlHandler

AlHandler提供两个构造函数,第一个只有Callback参数,该构造函数会默认获取当前线程的AlLooper,如果当前没有AlLooper,则会抛出异常。第二个构造函数支持传入一个AlLooper,该AlLooper对象将会从AlHandlerThread获取。sendMessage函数负责把AlMessage转发到AlLooper,值得注意的是,在发送到AlLooper之前会先给AlMessage的成员变量target赋值,也就是当前AlHandler对象的指针。dispatchMessage函数用于在AlLooper中消费消息。

class AlHandler {
public:
 typedef function Callback;
public:
 AlHandler(Callback callback);
 AlHandler(AlLooper *looper, Callback callback);
 void sendMessage(AlMessage *msg) {
 _enqueueMessage(msg);
 }
 void dispatchMessage(AlMessage *msg) {
 if (callback) {
  callback(msg);
 }
 }
private:
 void _enqueueMessage(AlMessage *msg) {
 if (this->looper) {
  msg->target = this;
  this->looper->sendMessage(msg);
 }
 }
private:
 AlLooper *looper = nullptr;
 Callback callback = nullptr;
};

AlLooperManager

AlLooperManager只有一个功能,那就是管理所有创建的AlLooper对象,所以它是一个单例,代码虽然简单,但却很重要。由于操作系统会为每一个线程分配一个唯一的tid(Thread ID,Linux下可以使用pthread_self获取到),所以我们可以通过tid的唯一性来管理所有线程创建的AlLooper对象。该类的create和get函数分别用于创建新的AlLooper对象,以及获取缓存的对象。创建一个对象时首先需要检查缓存中是否存在该线程对应的AlLooper,如果已经存在则应该避免重复创建,直接返回空指针即可。而get函数用于从缓存中获取一个对象,如果缓存中没有则返回空指针。remove用于销毁一个AlLooper,一般会在线程销毁时使用。这几个函数都需要保证线程安全。

private:
 AlLooperManager() : Object() {}
 AlLooperManager(AlLooperManager &e) : Object() {}
 ~AlLooperManager() {}
 /**
 * 为当前线程创建Looper
 * @return 当前线程的Looper
 */
 AlLooper *create(long tid) {
 std::lock_guard guard(mtx);
 auto it = looperMap.find(tid);
 if (looperMap.end() == it) {
  auto *looper = new AlLooper();
  looperMap[tid] = looper;
  return looper;
 }
 return nullptr;
 }
 /**
 * 获取当前线程的Looper
 * @return 当前线程的Looper
 */
 AlLooper *get(long tid) {
 std::lock_guard guard(mtx);
 auto it = looperMap.find(tid);
 if (looperMap.end() == it) {
  return nullptr;
 }
 return it->second;
 }
 /**
 * 销毁当前线程的Looper
 */
 void remove(long tid) {
 std::lock_guard guard(mtx);
 auto it = looperMap.find(tid);
 if (looperMap.end() != it) {
  looperMap.erase(it);
  auto *looper = it->second;
  delete looper;
 }
 }
private:
 static AlLooperManager *instance;
 std::map looperMap;
 std::mutex mtx;
};

AlLooper

AlLooper主要有prepare、myLooper和loop三个静态函数。prepare用于为当前线程准备一个AlLooper,因为我们规定同一个线程只能拥有一个AlLooper对象,如果尝试在一个线程重复调用该函数函数将引发异常。myLooper用于获取当前线程的AlLooper,如果在该函数调用之前没有调用过prepare将会获得一个空指针。loop是AlLooper的核心函数,调用该函数后线程将进入死循环,AlLooper会依次从消息队列头部取出AlMessage进行消费。前面提到AlMessage有一个名为target的成员变量,这个变量是一个AlHandler对象,所以这里直接调用AlHandler::dispatchMessage函数把消息回传,由AlHandler进行处理。sendMessage函数则用于在消息队列尾部插入一条消息。

class AlLooper : public Object {
public:
 /**
 * 为线程准备一个Looper,如果线程已经存在Looper,则报错
 */
 static void prepare() {
 AlLooper *looper = AlLooperManager::getInstance()->create(Thread::currentThreadId());
 assert(nullptr != looper);
 }
 /**
 * 获取当前线程的Looper
 * @return 前线程的Looper
 */
 static AlLooper *myLooper() {
 AlLooper *looper = AlLooperManager::getInstance()->get(Thread::currentThreadId());
 assert(nullptr != looper);
 return looper;
 }
 static void exit();
 /**
 * 循环消费消息
 */
 static void loop() {
 myLooper()->_loop();
 }
 void _loop() {
 for (;;) {
  AlMessage *msg = queue.take();
  if (msg) {
  if (msg->target) {
   msg->target->dispatchMessage(msg);
  }
  delete msg;
  }
  queue.pop();
 }
 }
 void sendMessage(AlMessage *msg) {
 queue.offer(msg);
 }
private:
 AlLooper();
 AlLooper(AlLooper &e) : Object() {}
 ~AlLooper();
private:
 AlMessageQueue queue;
};

AlMessageQueue和AlMessage

AlMessage比较简单,主要包含几个public的成员变量,用于区分消息类型以及附带一些信息。AlMessageQueue则是一个阻塞队列,当尝试从一个空队列获取AlMessage时将会造成线程阻塞,如果其它线程向空队列新增一个AlMessage对象将会唤醒阻塞的线程。这是驱动消息循环消费的重要一环。

class AlMessage {
public:
 int32_t what = 0;
 int32_t arg1 = 0;
 int64_t arg2 = 0;
 Object *obj = nullptr;
}
class AlMessageQueue : public Object {
public:
 AlMessageQueue() {
 pthread_mutex_init(&mutex, nullptr);
 pthread_cond_init(&cond, nullptr);
 }
 virtual ~AlMessageQueue() {
 pthread_mutex_lock(&mutex);
 invalid = true;
 pthread_mutex_unlock(&mutex);
 clear();
 pthread_mutex_destroy(&mutex);
 pthread_cond_destroy(&cond);
 }
 void offer(AlMessage *msg) {
 pthread_mutex_lock(&mutex);
 if (invalid) {
  pthread_mutex_unlock(&mutex);
  return;
 }
 queue.push_back(msg);
 pthread_cond_broadcast(&cond);
 pthread_mutex_unlock(&mutex);
 }
 AlMessage *take() {
 pthread_mutex_lock(&mutex);
 if (invalid) {
  pthread_mutex_unlock(&mutex);
  return nullptr;
 }
 if (size() <= 0) {
  if (0 != pthread_cond_wait(&cond, &mutex)) {
  pthread_mutex_unlock(&mutex);
  return nullptr;
  }
 }
 if (queue.empty()) {
  pthread_mutex_unlock(&mutex);
  return nullptr;
 }
 AlMessage *e = queue.front();
 queue.pop_front();
 pthread_mutex_unlock(&mutex);
 return e;
 }
 int size();
 void clear();
private:
 pthread_mutex_t mutex;
 pthread_cond_t cond;
 std::list queue;
 bool invalid = false;
};

AlHandlerThread

AlLooper准备好后就可以在线程中使用了,这里我们把线程和AlLooper封装到一起方便使用。AlHandlerThread会在内部开启一个线程,该线程会调用run函数,在线程开始运行后依次调用AlLooper的prepare和loop函数即可进入消息消费流程,AlLooper::exit()用于在线程结束前销毁AlLooper对象。

class AlHandlerThread {
public:
 AlLooper *getLooper() {
 return mLooper;
 }
private:
 void run() {
 AlLooper::prepare();
 mLooper = AlLooper::myLooper();
 AlLooper::loop();
 AlLooper::exit();
 }
private:
 std::thread mThread = thread(&AlHandlerThread::run, this);
 AlLooper *mLooper = nullptr;
};

最后我们创建一个AlHandler对象,并传入一个从AlHandlerThread获取的AlLooper对象和一个处理回调函数Callback,便可以让Handler机制运行起来。由于AlLooper可以是任意一个线程的对象,所以便实现了跨线程的通讯。如果我们把AlMessage封装成一个"Task",当我们要处理一个耗时任务时,把任务封装成一个"Task"发送到Handler进行处理,通过该方法可以轻易实现线程的复用,而不需要重复申请销毁线程。

mThread = AlHandlerThread::create(name);

mHandler = new AlHandler(mThread->getLooper(), [this](AlMessage *msg) {

 /// Do something.

});

结语

&#8195;&#8195;以上便是Android系统Handler机制的介绍,以及使用C++11的实现。上面展示的是部分核心代码,省略了很多,实际操作还需要处理很多问题,比如线程安全、线程的退出、AlLooper的销毁等。文章源码出自hwvc项目,感兴趣的读者可以阅读完整的AlHandlerThread源码实现。

hwvc项目:

https://github.com/imalimin/hwvc/tree/develop

AlHandlerThread源码:

https://github.com/imalimin/hwvc/blob/develop/src/common/thread/AlHandlerThread.cpp

到此这篇关于使用C++11实现Android系统的Handler机制的文章就介绍到这了,更多相关C++11 Handler机制内容请搜索以前的文章或继续浏览下面的相关文章希望大家以后多多支持!


推荐阅读
  • 本文详细介绍了如何在Linux系统上安装和配置Smokeping,以实现对网络链路质量的实时监控。通过详细的步骤和必要的依赖包安装,确保用户能够顺利完成部署并优化其网络性能监控。 ... [详细]
  • 在计算机技术的学习道路上,51CTO学院以其专业性和专注度给我留下了深刻印象。从2012年接触计算机到2014年开始系统学习网络技术和安全领域,51CTO学院始终是我信赖的学习平台。 ... [详细]
  • 数据库内核开发入门 | 搭建研发环境的初步指南
    本课程将带你从零开始,逐步掌握数据库内核开发的基础知识和实践技能,重点介绍如何搭建OceanBase的开发环境。 ... [详细]
  • 在Linux系统中配置并启动ActiveMQ
    本文详细介绍了如何在Linux环境中安装和配置ActiveMQ,包括端口开放及防火墙设置。通过本文,您可以掌握完整的ActiveMQ部署流程,确保其在网络环境中正常运行。 ... [详细]
  • 如何配置Unturned服务器及其消息设置
    本文详细介绍了Unturned服务器的配置方法和消息设置技巧,帮助用户了解并优化服务器管理。同时,提供了关于云服务资源操作记录、远程登录设置以及文件传输的相关补充信息。 ... [详细]
  • QUIC协议:快速UDP互联网连接
    QUIC(Quick UDP Internet Connections)是谷歌开发的一种旨在提高网络性能和安全性的传输层协议。它基于UDP,并结合了TLS级别的安全性,提供了更高效、更可靠的互联网通信方式。 ... [详细]
  • 深入理解OAuth认证机制
    本文介绍了OAuth认证协议的核心概念及其工作原理。OAuth是一种开放标准,旨在为第三方应用提供安全的用户资源访问授权,同时确保用户的账户信息(如用户名和密码)不会暴露给第三方。 ... [详细]
  • 本文基于对相关论文和开源代码的研究,详细介绍了LOAM(激光雷达里程计与建图)的工作原理,并对其关键技术进行了分析。 ... [详细]
  • PyCharm下载与安装指南
    本文详细介绍如何从官方渠道下载并安装PyCharm集成开发环境(IDE),涵盖Windows、macOS和Linux系统,同时提供详细的安装步骤及配置建议。 ... [详细]
  • 1:有如下一段程序:packagea.b.c;publicclassTest{privatestaticinti0;publicintgetNext(){return ... [详细]
  • CentOS7源码编译安装MySQL5.6
    2019独角兽企业重金招聘Python工程师标准一、先在cmake官网下个最新的cmake源码包cmake官网:https:www.cmake.org如此时最新 ... [详细]
  • 本文详细介绍了 Dockerfile 的编写方法及其在网络配置中的应用,涵盖基础指令、镜像构建与发布流程,并深入探讨了 Docker 的默认网络、容器互联及自定义网络的实现。 ... [详细]
  • 网络攻防实战:从HTTP到HTTPS的演变
    本文通过一系列日记记录了从发现漏洞到逐步加强安全措施的过程,探讨了如何应对网络攻击并最终实现全面的安全防护。 ... [详细]
  • 360SRC安全应急响应:从漏洞提交到修复的全过程
    本文详细介绍了360SRC平台处理一起关键安全事件的过程,涵盖从漏洞提交、验证、排查到最终修复的各个环节。通过这一案例,展示了360在安全应急响应方面的专业能力和严谨态度。 ... [详细]
  • Android LED 数字字体的应用与实现
    本文介绍了一种适用于 Android 应用的 LED 数字字体(digital font),并详细描述了其在 UI 设计中的应用场景及其实现方法。这种字体常用于视频、广告倒计时等场景,能够增强视觉效果。 ... [详细]
author-avatar
Annie千寻_535
这个家伙很懒,什么也没留下!
PHP1.CN | 中国最专业的PHP中文社区 | DevBox开发工具箱 | json解析格式化 |PHP资讯 | PHP教程 | 数据库技术 | 服务器技术 | 前端开发技术 | PHP框架 | 开发工具 | 在线工具
Copyright © 1998 - 2020 PHP1.CN. All Rights Reserved | 京公网安备 11010802041100号 | 京ICP备19059560号-4 | PHP1.CN 第一PHP社区 版权所有