技术标签: PendingResult goAsync Android App 异步任务 广播 android
【需求】:监听Android系统中某个广播,在广播onReceive方法中收集和处理系统的信息,(比如设备型号,IMEI, 手机内存大小等信息),然后上报给服务器端。
要完成该功能的话,要在广播中处理事件上报,涉及到往服务器上报数据,又与网络请求挂钩,肯定不能在主线程中做太过耗时的任务,这样子阻塞主线程,容易引起ANR.
为了把功能做的稳定一点,我们得先理一理下面的概念:
1. 广播生命周期
从开始执行回调方法onReceiver() 到 结束;
前台广播默认的生命周期时间为10秒, 后台广播默认的生命周期为60秒;
// How long we allow a receiver to run before giving up on it.
static final int BROADCAST_FG_TIMEOUT = 10*1000;
static final int BROADCAST_BG_TIMEOUT = 60*1000;
在发送广播时,可以通过设置Intent.FLAG_RECEIVER_FOREGROUND属性来将广播定义 为前台广播,如果未定义,默认为后台广播。
2. 广播对所在进程的影响
BroadcastReceiver 的状态(无论它是否在运行)会影响其所在进程的状态,而其所在进程的状态又会影响它被系统终结的可能性。例如,当进程执行接收器(即当前在运行其 onReceive() 方法中的代码)时,它被认为是前台进程。除非遇到极大的内存压力,否则系统会保持该进程运行。
但是,一旦从 onReceive() 返回代码,BroadcastReceiver 就不再活跃。接收器的宿主进程变得与在其中运行的其他应用组件一样重要。如果该进程仅托管清单声明的接收器(这对于用户从未与之互动或最近没有与之互动的应用很常见),则从 onReceive() 返回时,系统会将其进程视为低优先级进程,并可能会将其终止,以便将资源提供给其他更重要的进程使用。
因此,您不应在广播接收器启动长时间运行的后台线程。onReceive() 完成后,系统可以随时终止进程来回收内存,在此过程中,也会终止进程中运行的派生线程 。意思就是说:如果在onReceive所在的主线程,在new一个子线程去做任务的话,最好保证子线程在10秒内完成并返回请求结果。
3. 如何给广播所在的进程续命
那有没有方法可以延长广播所在进程生命的方法呢? 这也是本篇文章重点要讨论的,我们可以从进程和应用生命周期这个角度先去理解一下。
在大多数情况下,每个 Android 应用都在各自的 Linux 进程中运行。当需要运行应用的一些代码时,系统会为应用创建此进程,并使其保持运行,直到不再需要它且系统需要回收其内存以供其他应用使用。
如果执行完onReceive方法,则系统会认为 BroadcastReceiver 不再处于活动状态,因此不再需要保留此进程,除非其中有其他应用组件(比如service)处于活动状态,也可以理解为广播进程中还存有前台活动,否则系统可能会随时终止进程以回收内存,当然也会终止在进程中运行的衍生线程。
如何理解上一句话呢? 我们先在讲一下前台进程这个概念:
前台进程是用户目前执行操作所需的进程。如果以下任一条件成立,则进程会被认为位于前台:
3.1 它正在用户的互动屏幕上运行一个 Activity(其 onResume() 方法已被调用)。
3.2 它有一个 BroadcastReceiver 目前正在运行(其 BroadcastReceiver.onReceive() 方法正在行)。
3.3 它有一个 Service 目前正在执行其某个回调(Service.onCreate()、Service.onStart() 或 Service.onDestroy())中的代码。
上述进程的生命周期基本能善始善终,只有在系统中内存过低,导致连这些进程都无法继续运行,才会在最后一步终止这些进程。
好了,说了这么多,就是为了使 广播接收者所在进程 在生命周期时间范围(10/60秒)内,尽量存活久一点,我们也往这个方向去给解决方案。
[第一种方案] : 使用 goAsync() 方法,得到PendingResult 对象,它允许实现将与其相关的工作转移到另一个线程,以避免UI 线程ANR。任务完成后,调用PendingResult.finish()方法,其实目的也是为了是广播进程存在时间更久一点,好让异步线程把任务做完。
广播发送端:
//发送后台广播 生命周期为60s
Intent broadcastIntent = new Intent(MainActivity.this, MyBroadcastReceiver.class);
broadcastIntent.setAction("com.android.action.test_broadcast"); //自定义的Action
sendBroadcast(broadcastIntent);
//发送前台广播 生命周期为10s
Intent broadcastIntent = new Intent(MainActivity.this, MyBroadcastReceiver.class);
broadcastIntent.setAction("com.android.action.test_broadcast"); //自定义的Action
broadcastIntent.setFlags(Intent.FLAG_RECEIVER_FOREGROUND); //设置前台广播的标志
sendBroadcast(broadcastIntent);
广播接收端 实例代码如下:
public class MyBroadcastReceiver extends BroadcastReceiver {
private static final String TAG = "MyBroadcastReceiver";
@Override
public void onReceive(Context context, Intent intent) {
final PendingResult pendingResult = goAsync(); //开始
//AsyncTask,其内部原理也是新启一个线程去执行任务
Task asyncTask = new Task(pendingResult, intent);
asyncTask.execute();
Log.e(TAG, "====线程==="+ Thread.currentThread().getName() + "===" +
"线程ID===="+ Thread.currentThread().getId()) ;
}
private static class Task extends AsyncTask<String, Integer, String> {
private final PendingResult pendingResult;
private final Intent intent;
private Task(PendingResult pendingResult, Intent intent) {
this.pendingResult = pendingResult;
this.intent = intent;
}
@Override
protected String doInBackground(String... strings) {
StringBuilder sb = new StringBuilder();
sb.append("Action: " + intent.getAction() + "\n");
String log = sb.toString();
Log.d(TAG, log);
// 模拟耗时任务
try {
Log.e(TAG, "====线程开始睡眠===="+ Thread.currentThread().getName() + "===" +"线程ID===="+ Thread.currentThread().getId()) ;
Thread.sleep(10 * 1000); // 前台广播的生命极限值
Thread.sleep(60 * 1000); // 后台广播的生命极限值
} catch (InterruptedException e) {
e.printStackTrace();
}
return log;
}
@Override
protected void onPostExecute(String s) {
super.onPostExecute(s);
Log.e(TAG, "====这里是什么线程??==="+ Thread.currentThread().getName() + "===" +"线程ID===="+ Thread.currentThread().getId()) ;
// Must call finish() so the BroadcastReceiver can be recycled.
pendingResult.finish(); //任务结束一定要调用
}
}
}
打印log如下:
E MyBroadcastReceiver: ====线程===main===线程ID====2
E MyBroadcastReceiver: ====线程开始睡眠====AsyncTask #1===线程ID====372
E MyBroadcastReceiver: ====这里是什么线程??===main===线程ID====2
这里可以看出:
1. 执行onReceive方法是在主线程, AsyncTask的 doInBackground方法是在子线程执行, onPostExecute方法就是把子线程中的任务结果返回给主线程,然后UI显示出来。
2. 当发送前台广播时,我们用Thread.sleep(10s)模拟耗时任务,则必报ANR。
3. 当发送后台广播时,我们用Thread.sleep(60s)模拟耗时任务,则必要ANR。
所以在广播onReceive方法中,开启一个线程做异步任务然后配合 PendingResult 的使用,一般情况下,从服务器下载数据和上报数据给服务器,数据量不是很大的话,此方案是可以满足需求的。
【第二种方案】: onReceive 中使用 IntentService ,IntentService也是异步任务,当任务完成后,把数据回传给onReceive ,网上有很多这样子的例子,大家可以去参考,
其实原理在上面也描述过,就是我在广播接收者进程中,再启动了一个服务,服务它肯定会回调Service.onCreate()等方法,相当于多加入了一个前台活动,那么进程也就不会那么快被回收,这样子就尽量保证你的任务能正常执行完。
【第三种方案】: onReceive 中使用 HandlerThread + PendingResult 联动 代码如下:
广播接收类:
public class MyTestReceiver extends BroadcastReceiver {
private AsyncHandler asyncHandler;
//子线程的Handler
private Handler threadHandler;
private Handler uiHandler = new Handler() {
@Override
public void handleMessage(@NonNull Message msg) {
super.handleMessage(msg);
Bundle object = msg.getData();
Log.d("TEST", "====信息===: "+object.getString("MSG_KEY_MAIN"));
}
};
@Override
public void onReceive(Context context, Intent intent) {
//获取AsyncHandler类的单例对象
asyncHandler = AsyncHandler.getInstance();
//把主线程中的uiHandler传入到子线程中
asyncHandler.setuiHandlerCallBack(uiHandler);
//获取子线程的threadHandler
threadHandler = asyncHandler.getThreadHandlerCallBack();
//通过子线程的handler发送消息
Message msg = Message.obtain();
Bundle bundle = new Bundle();
bundle.putString("MSG_KEY_THREAD", "我是通过threadHandler从主线程 发送到 子线程的消息");
msg.setData(bundle);
threadHandler.sendMessage(msg);
final PendingResult pendingResult = goAsync();
AsyncHandler.post(new Runnable() {
@Override
public void run() {
handleIntent(context, intent);//耗时操作
// Must call finish() so the BroadcastReceiver can be recycled.
pendingResult.finish();
Log.d("TEST", "调用 pendingResult.finish() 广播可以回收了");
}
});
}
private void handleIntent(Context context, Intent intent) {
try {
Log.d("TEST", "===模拟耗时任务=开始===");
Thread.sleep(8 * 1000);
Log.d("TEST", "===模拟耗时任务=结束===");
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
HandlerThread 类:
public class AsyncHandler {
//此类的核心原理还是利用 HandlerThread 去做异步任务
private static final HandlerThread sHandlerThread = new HandlerThread("AsyncHandler");
private static final Handler sthreadHandler;
private static Handler uiHandler; //主线程中的Handler
/*饿汉单例模式 begin*/
private AsyncHandler() {}
public static final AsyncHandler asyncHandler = new AsyncHandler();
public static AsyncHandler getInstance() {
return asyncHandler;
}
/*饿汉单例模式 end*/
//把主线程中的uiHandler传递过来
public void setuiHandlerCallBack(Handler uiHandler) {
this.uiHandler = uiHandler;
}
//提供获取子线程中threadHandler的方法
public Handler getThreadHandlerCallBack() {
return sthreadHandler;
}
static {
sHandlerThread.start(); //启动
sthreadHandler = new Handler(sHandlerThread.getLooper()){
@Override
public void handleMessage(@NonNull Message message) {
super.handleMessage(message);
Bundle object = message.getData();
Log.d("TEST", "====信息===: "+object.getString("MSG_KEY_THREAD"));
//用主线程的Handler与主线程通信
Message msg = Message.obtain();
Bundle bundle = new Bundle();
bundle.putString("MSG_KEY_MAIN", "我是通过uiHandler从子线程 发送到 主线程的消息");
msg.setData(bundle);
uiHandler.sendMessage(msg);
}
};
}
public static void post(Runnable r) {
sthreadHandler.post(r);
}
public static void postDelayed(Runnable r, long delayedMills) {
sthreadHandler.postDelayed(r, delayedMills);
}
}
发送广播类:
public class MainTestActivity extends AppCompatActivity {
@Override
protected void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
setContentView(R.layout.activity_main_test);
Button button = findViewById(R.id.button);
button.setOnClickListener(new View.OnClickListener() {
@Override
public void onClick(View v) {
//发送前台广播
Intent broadcastIntent = new Intent();
broadcastIntent.setAction("com.android.action.broadcast_test");
broadcastIntent.setFlags(Intent.FLAG_RECEIVER_FOREGROUND);
sendBroadcast(broadcastIntent);
Log.d("TEST", "=====启动 MyTestReceiver=====");
}
});
}
}
打印log如下:
14:15:04.236 3385 3385 D TEST : =====启动 MyTestReceiver=====
14:15:04.249 3385 3465 D TEST : ====信息===: 我是通过threadHandler从主线程 发送到 子线程的消息
14:15:04.249 3385 3465 D TEST : ===模拟耗时任务=开始===
14:15:04.260 3385 3385 D TEST : ====信息===: 我是通过uiHandler从子线程 发送到 主线程的消息
14:15:12.249 3385 3465 D TEST : ===模拟耗时任务=结束===
14:15:12.250 3385 3465 D TEST : 调用 pendingResult.finish() 广播可以回收了
此Demo 中还包含了主线程中的uiHandler 和 子线程中的 threadHandler 发送消息的代码,写在这个demo中,也是为了更好的理解两个不同的线程可以通过Handler传递和处理简单的消息。
【第四种方案】:如果把第三种方案理解清楚了,上一个简洁版本的代码,如下:
public class TestBroadcast extends BroadcastReceiver {
private static Handler mAsyncHandler;
static {
HandlerThread thr = new HandlerThread("thread async");
thr.start();
mAsyncHandler = new Handler(thr.getLooper());
}
@Override
public void onReceive(Context context, Intent intent) {
final PendingResult result = goAsync(); //开始
Runnable worker = new Runnable() {
@Override
public void run() {
onReceiveAsync(context, intent);
result.finish(); // 结束
}
};
mAsyncHandler.post(worker);
}
private void onReceiveAsync(Context context, Intent intent) {
//做任务的代码
}
}
文章浏览阅读3.8k次,点赞9次,收藏28次。直接上一个工作中碰到的问题,另外一个系统开启多线程调用我这边的接口,然后我这边会开启多线程批量查询第三方接口并且返回给调用方。使用的是两三年前别人遗留下来的方法,放到线上后发现确实是可以正常取到结果,但是一旦调用,CPU占用就直接100%(部署环境是win server服务器)。因此查看了下相关的老代码并使用JProfiler查看发现是在某个while循环的时候有问题。具体项目代码就不贴了,类似于下面这段代码。while(flag) {//your code;}这里的flag._main函数使用while(1)循环cpu占用99
文章浏览阅读347次。idea shift f6 快捷键无效_idea shift +f6快捷键不生效
文章浏览阅读135次。Ecmacript 中没有DOM 和 BOM核心模块Node为JavaScript提供了很多服务器级别,这些API绝大多数都被包装到了一个具名和核心模块中了,例如文件操作的 fs 核心模块 ,http服务构建的http 模块 path 路径操作模块 os 操作系统信息模块// 用来获取机器信息的var os = require('os')// 用来操作路径的var path = require('path')// 获取当前机器的 CPU 信息console.log(os.cpus._node模块中有很多核心模块,以下不属于核心模块,使用时需下载的是
文章浏览阅读10w+次,点赞435次,收藏3.4k次。SPSS 22 下载安装过程7.6 方差分析与回归分析的SPSS实现7.6.1 SPSS软件概述1 SPSS版本与安装2 SPSS界面3 SPSS特点4 SPSS数据7.6.2 SPSS与方差分析1 单因素方差分析2 双因素方差分析7.6.3 SPSS与回归分析SPSS回归分析过程牙膏价格问题的回归分析_化工数学模型数据回归软件
文章浏览阅读7.5k次。如何利用hutool工具包实现邮件发送功能呢?1、首先引入hutool依赖<dependency> <groupId>cn.hutool</groupId> <artifactId>hutool-all</artifactId> <version>5.7.19</version></dependency>2、编写邮件发送工具类package com.pc.c..._hutool发送邮件
文章浏览阅读867次,点赞2次,收藏2次。docker安装elasticsearch,elasticsearch-head,kibana,ik分词器安装方式基本有两种,一种是pull的方式,一种是Dockerfile的方式,由于pull的方式pull下来后还需配置许多东西且不便于复用,个人比较喜欢使用Dockerfile的方式所有docker支持的镜像基本都在https://hub.docker.com/docker的官网上能找到合..._docker安装kibana连接elasticsearch并且elasticsearch有密码
文章浏览阅读1.3w次,点赞57次,收藏92次。整理 | 郑丽媛出品 | CSDN(ID:CSDNnews)近年来,随着机器学习的兴起,有一门编程语言逐渐变得火热——Python。得益于其针对机器学习提供了大量开源框架和第三方模块,内置..._beeware
文章浏览阅读7.9k次。//// ViewController.swift// Day_10_Timer//// Created by dongqiangfei on 2018/10/15.// Copyright 2018年 飞飞. All rights reserved.//import UIKitclass ViewController: UIViewController { ..._swift timer 暂停
文章浏览阅读986次,点赞2次,收藏2次。1.硬性等待让当前线程暂停执行,应用场景:代码执行速度太快了,但是UI元素没有立马加载出来,造成两者不同步,这时候就可以让代码等待一下,再去执行找元素的动作线程休眠,强制等待 Thread.sleep(long mills)package com.example.demo;import org.junit.jupiter.api.Test;import org.openqa.selenium.By;import org.openqa.selenium.firefox.Firefox.._元素三大等待
文章浏览阅读3k次,点赞4次,收藏14次。Java软件工程师职位分析_java岗位分析
文章浏览阅读2k次。Java:Unreachable code的解决方法_java unreachable code
文章浏览阅读1w次。1、html中设置标签data-*的值 标题 11111 222222、点击获取当前标签的data-url的值$('dd').on('click', function() { var urlVal = $(this).data('ur_如何根据data-*属性获取对应的标签对象