博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
Android 使用handler实现线程间发送消息 (主线程 与 子线程之间)、(子线程 与 子线程之间)...
阅读量:6939 次
发布时间:2019-06-27

本文共 4720 字,大约阅读时间需要 15 分钟。

keyword:Android 使用handler实现线程间发送消息 (主线程 与 子线程之间)、(子线程 与 子线程之间)

相信大家平时都有使用到异步线程往主线程(UI线程)发送消息的情况。

本文主要研究Handler的消息发送。

包含主线程往子线程发送消息,子线程之间互相发送消息。

一、主线程向子线程发送消息。

实现过程比較简单:

主线程发送消息到异步线程。异步线程接收到消息后在再发送一条消息给主线程。

1. 初始化主线程的Handler,用来接收子线程的消息。

2. 启动异步线程。在异步线程中创建Looper,并初始化一个异步线程的Handler。

3. 主线程获取异步线程的Handler(这里涉及到线程间同步的知识)。并向异步线程发送消息。

4. 异步线程Handler接收到消息以后,获取主线程的Handler,并向主线程发送消息。

5. 主线程收到异步线程发来的消息。

注:

1. 这里说的主线程Handler或者异步线程Handler,指的是绑定在相应线程消息队列上的一个Handler对象而已,在Handler的构造函数中传入相应线程的Looper对象就可以。

2. 为什么要使用线程锁来处理,是由于异步线程启动不是实时的。主线程获取异步线程的Handler时有可能为空,假设为空,须要等待异步线程先初始化Handler。

上代码:

package com.example.chen.myapplication;import android.app.Activity;import android.os.Bundle;import android.os.Handler;import android.os.Looper;import android.os.Message;import android.util.Log;/** * 用Handler測试主线程往子线程发送消息 * @author chen */public class HandlerSimpleActivity extends Activity {    private Handler mainHandler;    @Override    protected void onCreate(Bundle savedInstanceState) {        super.onCreate(savedInstanceState);        // 启动异步线程        final AsyncThread asyncThread = new AsyncThread();        asyncThread.start();        // 初始化主线程的Handler        mainHandler = new Handler(Looper.myLooper(), new Handler.Callback() {            @Override            public boolean handleMessage(Message msg) {                // 主线程收到消息                Log.e(HandlerSimpleActivity.class.getSimpleName(),                        "MainHandler Receiver Message curThread = "                                + Thread.currentThread().getName());                return false;            }        });        // 获取异步线程的Handler        Handler handler = asyncThread.getHandler();        if (handler != null) {            Log.e(HandlerSimpleActivity.class.getSimpleName(),                    "MainThread Send Message curThread = "                            + Thread.currentThread().getName());            // 向异步线程发送消息            handler.sendEmptyMessage(0);        }    }    /**     * 异步线程     */    private class AsyncThread extends Thread {        private Handler handler;        @Override        public void run() {            super.run();            Log.e(HandlerSimpleActivity.class.getSimpleName(),                    "AsyncThread Start curThread = "                            + Thread.currentThread().getName());            Looper.prepare();  // 初始化异步线程的消息循环队列            if (handler == null) {                synchronized (AsyncThread.class) { // 线程间安全                    // 为异步线程的消息循环队列新增一个Handler                    handler = new Handler(Looper.myLooper(), new Handler.Callback() {                        @Override                        public boolean handleMessage(Message msg) {                            // 异步线程收到消息                            Log.e(HandlerSimpleActivity.class.getSimpleName(),                                    "AsyncHandler Receiver Message curThread = "                                            + Thread.currentThread().getName());                            // 异步线程发送消息到主线程                            Log.e(HandlerSimpleActivity.class.getSimpleName(),                                    "AsyncThread Send Message curThread = "                                            + Thread.currentThread().getName());                            mainHandler.sendEmptyMessage(0);                            return false;                        }                    });                    // 异步线程Handler初始化完成                    Log.e(HandlerSimpleActivity.class.getSimpleName(),                            "AsyncHandler Inited curThread = "                                    + Thread.currentThread().getName());                    // 释放锁                    AsyncThread.class.notifyAll();                }            }            Looper.loop();        }        /**         * 获取异步线程的Handler         * @return         */        public Handler getHandler() {            if (handler == null) {                synchronized (AsyncThread.class) {  // 线程间安全                    if (handler == null) {                        try {                            // 获取异步线程的handler为空。释放锁,等待异步线程初始化完成。

Log.
e(HandlerSimpleActivity.
class.getSimpleName()
,
"getHandler wait curThread = "
+ Thread.
currentThread().getName())
;
AsyncThread.
class.wait()
;
}
catch (InterruptedException e) { e.printStackTrace()
;
}
// 异步线程Handler初始化完成。主线程继续
Log.
e(HandlerSimpleActivity.
class.getSimpleName()
,
"getHandler notified curThread = "
+ Thread.
currentThread().getName())
;
return
handler
;
}
else {
return
handler
;
} } }
else {
return
handler
;
} } } }

上结果截图:

二、子线程间使用Handler互相发送消息:

2015年7月26日19:47:31   等待下次更新(*^__^*) 嘻嘻……

2015年11月9日更新。线程间通信能够用HandlerThread。有兴趣的朋友能够看看源代码。就一个类。代码也不多,系统的API写的要健壮一些。

关于HandlerThread。大家能够阅读该片博客:

本人Android菜鸟,尽请指正!!

你可能感兴趣的文章
堆排序(java实现)
查看>>
ubuntu server 安装vnc
查看>>
win7关闭关机时的自动终止的功能
查看>>
调试K3网页版需要注意的问题
查看>>
前端开发中的一些用户体验细节
查看>>
第二章:身份验证
查看>>
开发基础(练习题)
查看>>
常用的HTTP响应头
查看>>
PYTHON2.day06
查看>>
http 响应码
查看>>
查找并绘制轮廓[OpenCV 笔记XX]
查看>>
Git系列之一 --- git remote
查看>>
PHP 实现多服务器共享 SESSION 数据
查看>>
Linux系统信息查看命令大全
查看>>
Coursera机器学习编程作业Python实现(Andrew Ng)—— 1.2 Linear regression with multiple variables...
查看>>
Java源码分析-UUID
查看>>
Directx11教程(47) alpha blend(4)-雾的实现
查看>>
opengl 教程(12) 投影矩阵
查看>>
8086汇编——课堂笔记整理3
查看>>
Python批量修改文件名-后缀
查看>>