当前位置:   article > 正文

android主线程等待子线程,Android 使用handler实现线程间发送消息 (主线程 与 子线程之间)、(子线程 与 子线程之间)...

android主线程等待子线程数据

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。

上代码:

packagecom.example.chen.myapplication;importandroid.app.Activity;importandroid.os.Bundle;importandroid.os.Handler;importandroid.os.Looper;importandroid.os.Message;importandroid.util.Log;/*** 用Handler測试主线程往子线程发送消息*@authorchen*/public classHandlerSimpleActivity extendsActivity {

privateHandler mainHandler;@Overrideprotected voidonCreate(Bundle savedInstanceState) {

super.onCreate(savedInstanceState);// 启动异步线程finalAsyncThread asyncThread = newAsyncThread();asyncThread.start();// 初始化主线程的HandlermainHandler= newHandler(Looper.myLooper(), newHandler.Callback() {

@Overridepublic booleanhandleMessage(Message msg) {

// 主线程收到消息Log.e(HandlerSimpleActivity.class.getSimpleName(),"MainHandler Receiver Message curThread = "+ Thread.currentThread().getName());return false;}

});// 获取异步线程的HandlerHandler handler = asyncThread.getHandler();if(handler != null) {

Log.e(HandlerSimpleActivity.class.getSimpleName(),"MainThread Send Message curThread = "+ Thread.currentThread().getName());// 向异步线程发送消息handler.sendEmptyMessage(0);}

}

/*** 异步线程*/private classAsyncThread extendsThread {

privateHandler handler;@Overridepublic voidrun() {

super.run();Log.e(HandlerSimpleActivity.class.getSimpleName(),"AsyncThread Start curThread = "+ Thread.currentThread().getName());Looper.prepare();// 初始化异步线程的消息循环队列if(handler== null) {

synchronized(AsyncThread.class) { // 线程间安全// 为异步线程的消息循环队列新增一个Handlerhandler= newHandler(Looper.myLooper(), newHandler.Callback() {

@Overridepublic booleanhandleMessage(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*/publicHandler 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());returnhandler;} else{

returnhandler;}

}

} else{

returnhandler;}

}

}

}

上结果截图:

35806667a16bbb7abdbf0a7a3f28b67e.png

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

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

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

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

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

声明:本文内容由网友自发贡献,不代表【wpsshop博客】立场,版权归原作者所有,本站不承担相应法律责任。如您发现有侵权的内容,请联系我们。转载请注明出处:https://www.wpsshop.cn/w/繁依Fanyi0/article/detail/465209?site
推荐阅读
相关标签
  

闽ICP备14008679号