Android中的消息异步处理机制及实现方案

基本介绍

  • 当我们需要执行复杂的计算逻辑，网络请求等耗时操作时，服务器可能不会立即响应请求，如果不将这类操作放在子线程中运行，就会导致主线程被阻塞住，从而影响用户的使用体验
  • 如果想要更新应用程序中的UI控件，则必须在主线程中进行，否则就会出现android.view.ViewRootImpl$CalledFromWrongThreadException异常

代码实践

  • 有些时候，我们需要在子线程中执行一些耗时任务，再根据任务的执行结果来更新相应的UI控件，对此，Android提供了一套异步消息的处理机制，解决了在子线程中进行UI操作的问题，我们先来看看异步消息处理的使用方法，再来分析其中的原理
import androidx.annotation.NonNull;
import androidx.appcompat.app.AppCompatActivity;import android.os.Bundle;
import android.os.Handler;
import android.os.Looper;
import android.os.Message;
import android.view.View;
import android.widget.Button;
import android.widget.TextView;import com.example.myapplication1.R;import java.util.concurrent.TimeUnit;public class EventHandlerActivity extends AppCompatActivity {private static final int CALCULATE_KEY = 2024;private Button calculateBtn;private TextView resultTv;// 创建Handler实例,用于在主线程中更新UIprivate Handler myHandler = new Handler(Looper.getMainLooper()) {@Overridepublic void handleMessage(@NonNull Message msg) {if (msg.what == CALCULATE_KEY) {resultTv.setText("Result: " + msg.obj);}}};@Overrideprotected void onCreate(Bundle savedInstanceState) {super.onCreate(savedInstanceState);setContentView(R.layout.activity_event_handler);calculateBtn = findViewById(R.id.calculateBtn);resultTv = findViewById(R.id.resultTv);calculateBtn.setOnClickListener(new View.OnClickListener() {@Overridepublic void onClick(View v) {// 点击按钮后,开始执行复杂计算calculateFunc();}});}private void calculateFunc() {// 创建一个新线程来执行耗时操作new Thread(new Runnable() {@Overridepublic void run() {long result = factorial(5);// 模拟复杂的耗时计算try {Thread.sleep(3000);} catch (InterruptedException e) {e.printStackTrace();}// 发送消息给Handler,以便在主线程中更新UI// 另外,为了避免频繁地创建和销毁 Message 对象，可以使用 Message.obtain() 方法从消息池中获取一个消息实例,以减少内存分配和垃圾回收的频率Message message = Message.obtain();message.what = CALCULATE_KEY;message.obj = "calculate result = " + result;myHandler.sendMessage(message);// sendMessageDelayed(Message msg, long delayMillis): 在指定的延迟时间后发送Messag, delayMillis为单位为毫秒// myHandler.sendMessageDelayed(message,5000);}}).start();}private long factorial(int num){if (num < 2) return 1;return num * factorial(num - 1);}
}
  • activity_event_handler.xml：
<?xml version="1.0" encoding="utf-8"?>
<RelativeLayout xmlns:android="http://schemas.android.com/apk/res/android"xmlns:app="http://schemas.android.com/apk/res-auto"xmlns:tools="http://schemas.android.com/tools"android:layout_width="match_parent"android:layout_height="match_parent"tools:context=".handle.EventHandlerActivity"><Buttonandroid:id="@+id/calculateBtn"android:layout_width="wrap_content"android:layout_height="wrap_content"android:text="Calculate Factorial"android:textAllCaps="false"/><TextViewandroid:id="@+id/resultTv"android:layout_width="wrap_content"android:layout_height="wrap_content"android:layout_below="@id/calculateBtn"android:layout_marginTop="16dp"/></RelativeLayout>
  • 如上代码，点击calculateBtn按钮，交由工作线程完成计算操作，将计算机结果显示在resultTv（交由主线程完成UI操作）

原理实现

  • Android中的异步消息处理主要由四部分组成：Message、Handler、MessageQueue和Looper，下面对这四部分来进行详细介绍

Message

  • Message是在线程之间传递的消息，可以在内部携带少量的数据，用于在不同线程间交换，其实例包含what
  • Message的what字段是一个整数值，可用来分区不同的消息类型，可为不同的任务或事件分配不同的what值，当调用Handler实例handleMessage方法时，可检查Message对象的what字段来确定如何处理该消息
  • arg1和arg2字段：均为整数类型字段，可携带what之外其他的整数类型数据
  • obj字段：Object类型字段，可携带字符串、数组、对象、Bundle等类型数据

Handler

  • Handler：处理者，主要用于发送和处理消息，发送消息一般是调用Handler实例的**sendMessage()方法，而发出的消息经过一系列辗转处理后，最终会交由handleMessage()**方法来处理
  • Handler是在主线程中创建的，handleMessage()方法也会在主线程中执行，故不存在UI操作引起的线程安全问题

MessageQueue

  • 消息队列，主要用于存放所有通过Handler发送的消息，这部分消息会一直存在于MessageQueue中，等待被处理；每个线程只有一个MessageQueue对象

Looper

  • Looper：每个线程中MessageQueue的管理者，调用loop()之类的方法后，就会进入到消息的循环监听中，每当发现MQ中存在消息，就会将其取出，传递到handler.handleMessage()方法中；每个线程中也只用一个Looper对象

异步处理流程

  • 1）在主线程中创建Handler对象，并重写handleMessage()方法
  • 2）当子线程中需要进行UI操作时，就创建一个Message对象，并通过Handler将Message发送出去
  • 3）发送出的Message会被添加到MessageQueue中等待被处理
  • 4）Looper会一直监听MessageQueue中的消息，一旦发现待处理的消息就取出，再分发到Handler的handleMessage()方法中处理消息
    在这里插入图片描述
    如上，Message经过一系列辗转调用后，由子线程完成耗时操作的处理，再由主线程完成UI操作，通过消息的异步处理机制解决UI操作可能会导致的线程安全问题

其他异步处理的实现

  • 异步处理还可以通过定时任务来实现，一种是Java API提供的Timer类，一种Android的Alarm机制，这两种实现在多数情况下都能实现类似的效果，但Timer不太适用于长期在后台运行的定时任务
  • 为能让电池耐用，Android手机会在长时间不操作的情况下自动让CPU进入到睡眠状态，这可能会导致Timer中的定时任务无法正常运行；而Alarm有唤醒CPU功能，可保证在大多数情况下需要执行定时任务时CPU都能正常工作
    下面重点介绍下Alarm的基本使用：

Alarm机制

  • Android的Alarm机制是一种系统服务，可在将来的某个时间点触发定时操作，即使你的应用程序不在运行；这个机制由AlarmManager类提供，它可以用于执行定时任务，比如在特定时间发送通知、启动服务或者执行其他后台操作

主要组件：

  • AlarmManager：系统服务，负责管理和触发闹钟，可通过getSystemService(Context.ALARM_SERVICE)获取实例
  • PendingIntent：描述将要执行操作的意图对象，当闹钟触发时，AlarmManager会发送对应的PendingIntent
  • AlarmManagerService：AlarmManager的服务端实现，运行在系统进程中，负责处理闹钟的触发

基本使用如下：

    public void sendAlarm(){Intent intent = new Intent(ALARM_ACTION);// 创建用于广播的延迟意图PendingIntent pendingIntent = PendingIntent.getBroadcast(context,0,intent,PendingIntent.FLAG_IMMUTABLE);// 从系统服务中获取闹钟管理器AlarmManager alarmManager = (AlarmManager) context.getSystemService(Context.ALARM_SERVICE);// 闹钟的触发时机long triggerTime = SystemClock.elapsedRealtime() + 2 * 1000;if (Build.VERSION.SDK_INT >= Build.VERSION_CODES.M) {// 允许在空闲时发送广播(Android6.0之后新增的方法)alarmManager.setAndAllowWhileIdle(AlarmManager.ELAPSED_REALTIME_WAKEUP,triggerTime, pendingIntent);} else {// 设置一次性闹钟,延迟若干秒后,携带延迟意图发送闹钟广播(Android6.0之后,set方法在暗屏时不保证发送广播)alarmManager.set(AlarmManager.ELAPSED_REALTIME_WAKEUP,triggerTime,pendingIntent);}// 设置重复闹钟,每隔一定时间间隔就发送闹钟广播(从Android4.4开始,setRepeating方法不保证按时发送广播)//  alarmManager.setRepeating(AlarmManager.RTC_WAKEUP,System.currentTimeMillis(),1000,pendingIntent);// 取消闹钟// alarmManager.cancel(pendingIntent);// 获取下一个闹钟的信息// alarmManager.getNextAlarmClock();}
使用说明
  • AlarmManager部分源代码如下：
@SystemService(Context.ALARM_SERVICE)
public class AlarmManager {private static final String TAG = "AlarmManager";// .../** @hide */@IntDef(prefix = { "RTC", "ELAPSED" }, value = {RTC_WAKEUP,RTC,ELAPSED_REALTIME_WAKEUP,ELAPSED_REALTIME,})// ...@Retention(RetentionPolicy.SOURCE)public @interface AlarmType {}
public void set(@AlarmType int type, long triggerAtMillis, @NonNull PendingIntent operation) {setImpl(type, triggerAtMillis, legacyExactLength(), 0, 0, operation, null, null,(Handler) null, null, null);}//  ...
}

参数说明：

  • type：指定AlarmManager的工作类型，有四个选项：RTC_WAKEUP、RTC、ELAPSED_REALTIME_WAKEUP、ELAPSED_REALTIME，
    RTC_WAKEUP：让定时任务的触发时间从1970年1月1日0点开始算起，不会唤醒CPU；
    RTC：让定时任务的触发时间从1970年1月1日0点开始算起，不会唤醒CPU
    同理，
    ELAPSED_REALTIME_WAKEUP：让定时任务的触发时机从系统开机算起，会唤醒CPU；
    ELAPSED_REALTIME：让定时任务的触发时机从系统开机算起，但不会唤醒CPU
    =》带WAKEUP的会唤醒CPU，带ELAPSED_REALTIME的从系统开机算起
  • triggerAtMillis：定时任务触发的时间，单位为毫秒
    SystemClock.elapsedRealtime()：从系统开机至今所经历的毫秒数
    System.currentTimeMillis()：从1970年1月1日0点至今所经历的毫秒数
  • PendingIntent对象：一般调用getService()或getBroadcast()方法来获取执行服务或广播的PendingIntent；当定时任务被触发时，服务的onStartCommand()或广播接收器onReceive()方法就可得到执行

扩展

前面我们知道了如何异步地处理消息，实现原理，现在再来全面地看看消息异步处理解决的问题：

  • 1）线程安全：Android UI 是非线程安全的，即所有的 UI 操作必须在主线程中执行；任何在工作线程中直接对 UI 进行操作都会导致不可预知的行为，甚至可能导致应用崩溃；消息异步处理机制确保了所有的 UI 更新都在主线程中执行，从而保证了线程安全
  • 2）避免ANR（Application Not Responding）：如果主线程因为长时间运行的任务（如数据库操作，执行复杂计算，网络请求）而被阻塞，系统会认为应用无响应，可能会触发ANR；消息异步处理机制允许这类耗时任务在工作线程中执行，从而避免了主线程的阻塞，减少ANR的发生
  • 3）控制线程的生命周期：使用Handler和Looper，开发者可精细地控制线程的生命周期（如在线程完成所有任务后退出，或在线程空闲时清理资源）
  • 4）支持延时消息和定时任务：Handler提供了发送延时消息的功能，允许在将来的某个时间点执行任务
  • 5）提高用户体验：通过在工作线程中执行耗时任务，用户界面可以保持响应，提供流畅的用户体验；用户可以继续与应用交互，而不会因为后台任务的执行而感到延迟

实现异步处理的方式：Handler（sendMessage和sendMessageDelayed方法）、Timer、Alarm机制、WorkManager、Coroutine，篇幅受限，这里不多讲解

参考资料：

  • 《Android第一行代码》第二版

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/diannao/28115.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

ASM字节码操纵框架实现AOP

ASM字节码操纵框架实现AOP

前言 使用ASM改写字节码实现Aop&#xff0c;是最快的Aop实现方式。 我猜你肯定懂AOP 凡是学习Spring框架&#xff0c;必然会深入了解AOP的原理以及实现。这里做下简单总结 Spring默认采取的是动态代理机制实现AOP&#xff0c;当动态代理不可用时&#xff08;代理类无接口&a…
阅读更多...
Mac M3 Pro安装Hadoop-3.3.6

Mac M3 Pro安装Hadoop-3.3.6

1、下载Hadoop安装包 可以到官方网站下载&#xff0c;也可以使用网盘下载 官网下载地址&#xff1a;Hadoop官网下载地址 网盘地址&#xff1a;https://pan.baidu.com/s/1p4BXq2mvby2B76lmpiEjnA?pwdr62r提取码: r62r 2、解压并添加环境变量 # 将安装包移动到指定目录 mv …
阅读更多...
FPGA - 数 - 加减乘除

FPGA - 数 - 加减乘除

一&#xff0c;数的表示 首先&#xff0c;将二进制做如下解释&#xff1a; 2的0次方1 2的1次方2 2的2次方4 2的3次方8 ..... 以此类推&#xff0c;那么任何整数&#xff0c;或者说任意一个自然数均可以采用这种方式来表示。 例如&#xff0c;序列10101001&#xff0c;根据上述…
阅读更多...
Unity贪吃蛇改编【详细版】

Unity贪吃蛇改编【详细版】

Big and small greedy snakes 游戏概述 游戏亮点 通过对称的美感&#xff0c;设置两条贪吃蛇吧&#xff0c;其中一条加倍成长以及加倍减少&#xff0c;另一条正常成长以及减少&#xff0c;最终实现两条蛇对整个界面的霸占效果。 过程中不断记录两条蛇的得分情况&#xff0c…
阅读更多...
【Unity】RPG2D龙城纷争（二）关卡、地块

【Unity】RPG2D龙城纷争（二）关卡、地块

更新日期&#xff1a;2024年6月12日。 项目源码&#xff1a;后续章节发布 索引 简介地块&#xff08;Block&#xff09;一、定义地块类二、地块类型三、地块渲染四、地块索引 关卡&#xff08;Level&#xff09;一、定义关卡类二、关卡基础属性三、地块集合四、关卡初始化五、关…
阅读更多...
VCG显示——汉字，数字，图像

VCG显示——汉字，数字，图像

详细的介绍资料&#xff1a; 【从零开始走进FPGA】 玩转VGA http://www.cnblogs.com/spartan/archive/2011/08/16/2140546.html 【FPGA实验】基于DE2-115平台的VGA显示_vga接口实验 de2-115-CSDN博客 【FPGA】VGA显示文字、彩条、图片——基于DE2-115-CSDN博客 一.VCG原理 1.1…
阅读更多...
时序预测 | MATLAB实现TCN-Transformer时间序列预测

时序预测 | MATLAB实现TCN-Transformer时间序列预测

时序预测 | MATLAB实现TCN-Transformer时间序列预测 目录 时序预测 | MATLAB实现TCN-Transformer时间序列预测预测效果基本介绍程序设计参考资料 预测效果 基本介绍 1.MATLAB实现TCN-Transformer时间序列预测&#xff1b; 2.运行环境为Matlab2023b及以上&#xff1b; 3.data为数…
阅读更多...
Python **运算符（python**kwargs：参数解包）（kwargs：keyword arguments）

Python **运算符（python**kwargs：参数解包）（kwargs：keyword arguments）

文章目录 Python中的 ** 运算符&#xff1a;参数解包参数解包基础语法和示例 在函数定义中使用 **示例代码 使用场景和好处1. 灵活性&#xff1a;使用 **kwargs 允许函数设计得更加灵活&#xff0c;可以接受未来可能增加的新参数而无需修改函数定义。2. 可读性和可维护性&#…
阅读更多...
Kali中安装和使用docker的学习笔记

Kali中安装和使用docker的学习笔记

一、常见命令 ctrl 、shift、 &#xff1a; 窗口变大&#xff1b; ctrl 、- &#xff1a;窗口变小&#xff1b; ctrl L&#xff1a; 清屏 &#xff1b; sudo su : 切换root 用户&#xff1b; ip addr / ifconfig: 获取IP地址&#xff1b; systemctl start ssh…
阅读更多...
B端颜值无所谓？麻痹自己可以，麻痹业务人员和客户试一试。

B端颜值无所谓？麻痹自己可以，麻痹业务人员和客户试一试。

很多老铁觉得B端系统颜值和体验无所谓&#xff0c;功能好就行了&#xff0c;我不认同这种说法&#xff0c;我觉得优秀的B端系统应该是内外兼修的&#xff0c;而不是偏科的。你想一想你费尽研发的系统&#xff0c;就是因为颜值问题&#xff0c;你的业务人员没信息推销&#xff0…
阅读更多...
北方工业大学24计算机考研情况，学硕专硕都是国家线复试！

北方工业大学24计算机考研情况，学硕专硕都是国家线复试！

北方工业大学&#xff08;North China University of Technology&#xff0c;NCUT&#xff09;&#xff0c;简称“北方工大”&#xff0c;位于北京市&#xff0c;为一所以工为主、文理兼融&#xff0c;具有学士、硕士、博士培养层次的多科性高等学府&#xff0c;是中华人民共和…
阅读更多...
GitLab教程（四）：分支（branch）和合并（merge）

GitLab教程（四）：分支（branch）和合并（merge）

文章目录 1.分支&#xff08;branch&#xff09;&#xff08;1&#xff09;分支的概念&#xff08;2&#xff09;branch命令 2.合并&#xff08;merge&#xff09;&#xff08;1&#xff09;三个命令pullfetchmergegit fetchgit mergegit pull &#xff08;2&#xff09;合并冲…
阅读更多...
【计算机网络仿真实验-实验2.6】带交换机的RIP路由协议

【计算机网络仿真实验-实验2.6】带交换机的RIP路由协议

实验2.6 带交换机的rip路由协议 1. 实验拓扑图 2. 实验前查看是否能ping通 不能 3. 三层交换机配置 switch# configure terminal switch(config)# hostname s5750 !将交换机更名为S5750 S5750# configure terminal S5750(config)#vlan 10 S5750(config-vlan)#exit S57…
阅读更多...
PyTorch 维度变换-Tensor基本操作

PyTorch 维度变换-Tensor基本操作

以如下 tensor a 为例&#xff0c;展示常用的维度变换操作 >>> a torch.rand(4,3,28,28) >>> a.shape torch.Size([4, 3, 28, 28])view / reshape 两者功能完全相同: a.view(shape) >>> a.view(4,3,28*28) ## a.view(4,3,28,28) 可恢复squeeze…
阅读更多...
【LLM】吴恩达『微调大模型』课程完全笔记

【LLM】吴恩达『微调大模型』课程完全笔记

Finetuning Large Language Models 版权说明&#xff1a; 『Finetuning Large Language Models』是DeepLearning.AI出品的免费课程&#xff0c;版权属于DeepLearning.AI(https://www.deeplearning.ai/)。 本文是对该课程内容的翻译整理&#xff0c;只作为教育用途&#xff0c;不…
阅读更多...
数据分析必备：一步步教你如何用matplotlib做数据可视化（2）

数据分析必备：一步步教你如何用matplotlib做数据可视化（2）

1、Matplotlib Anaconda Anaconda是Python和R编程语言的免费开源发行版&#xff0c;用于大规模数据处理&#xff0c;预测分析和科学计算。 该分发使包管理和部署变得简单容易。 Matplotlib和许多其他有用的(数据)科学工具构成了分发的一部分。 包版本由包管理系统Conda管理。 …
阅读更多...
旅游网站（携程旅行网页学习 vue3+element）

旅游网站（携程旅行网页学习 vue3+element）

旅游网站 1. 创建项目 在你要创建项目的路径下打开vscode&#xff0c;新建终端&#xff0c;然后输入vue ui,进入Vue项目管理器。选择“创建”&#xff0c;确定项目路径&#xff0c;并点击“在此创建新项目”。在项目文件夹中输入项目名称&#xff0c;点击下一步&#xff1b;选…
阅读更多...
CMU最新论文：机器人智慧流畅的躲避障碍物论文详细讲解

CMU最新论文：机器人智慧流畅的躲避障碍物论文详细讲解

CMU华人博士生Tairan He最新论文&#xff1a;Agile But Safe: Learning Collision-Free High-Speed Legged Locomotion 代码开源&#xff1a;Code: https://github.com/LeCAR-Lab/ABS B站实际效果展示视频地址&#xff1a;bilibili效果地址 我会详细解读论文的内容,让我们开始吧…
阅读更多...
Python读取wps中的DISPIMG图片格式

Python读取wps中的DISPIMG图片格式

需求&#xff1a; 读出excel的图片内容&#xff0c;这放在微软三件套是很容易的&#xff0c;但是由于wps的固有格式&#xff0c;会出现奇怪的问题&#xff0c;只能读出&#xff1a;类似于 DISPIMG(“ID_2B83F9717AE1XXXX920xxxx644C80DB1”,1) 【该DISPIMG函数只有wps才拥有】 …
阅读更多...
关于使用‘rt-thread-master‘包从新创建对应开发板型号工程遇到相关问题

关于使用‘rt-thread-master‘包从新创建对应开发板型号工程遇到相关问题

问题1:裁剪完成后在ENV中使用命令每次使用scons --targetmdk5重新生成工程后在工程中自己选择的单片机型号会变成默认问题 解决: 通过生成的“template.uvprojx”打开工程&#xff0c;在devicezhong 更改成自己要选择的单片机型号&#xff0c;然后保存&#xff1b;再次通过&qu…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023