Android开发中的Handler线程初窥，及HandlerThread异步通信的实现

最近学习Android，学习的时候会用Java的一些机制去理解，但是往往还是有些区别的。

下面我们来看看Android下面的线程使用方法，这里通常会用到Handler。

Handler的作用就是一个队列，先进先出，实现了异步机制。

下面是这个工程的main.xml配置文件：（两个例子的使用同一个xml）

[java] view plain copy print ?

<?xmlversion="1.0"encoding="utf-8"?>
<LinearLayoutxmlns:android="http://schemas.android.com/apk/res/android"
android:orientation="vertical"
android:layout_width="fill_parent"
android:layout_height="fill_parent"
>
<ProgressBar
android:id="@+id/bar"
style="?android:attr/progressBarStyleHorizontal"
android:layout_width="200dp"
android:layout_height="wrap_content"
android:visibility="gone"
/>
<Button
android:id="@+id/startButton"
android:layout_width="fill_parent"
android:layout_height="wrap_content"
android:text="start"
/>
</LinearLayout>

[java] view plain copy print ?

packagecom.cyl;
importandroid.app.Activity;
importandroid.os.*;
importandroid.widget.*;
importandroid.view.View;
importandroid.view.View.OnClickListener;
publicclassProgressBarHandlerextendsActivity{
privateProgressBarbar;
privateButtonstart;
privateHandlerprogressHandler;
RunnableprogressThread;
@Override
publicvoidonCreate(BundlesavedInstanceState){
super.onCreate(savedInstanceState);
setContentView(R.layout.main);
//测试当前Activity线程
//打印的结果是：ActivityThread:1
System.out.println("ActivityThread:"+Thread.currentThread().getId());
bar=(ProgressBar)this.findViewById(R.id.bar);
start=(Button)this.findViewById(R.id.startButton);
//实现了Handler的内部类
progressHandler=newHandler(){
@Override
publicvoidhandleMessage(Messagemsg){
bar.setProgress(msg.arg1);
//经过证明Thread均是同一线程。
//打印的结果是：HandlerThread:1
System.out.println("HandlerThread:"+Thread.currentThread().getId());
progressHandler.post(progressThread);
//模拟在90%时停止，removeCallbacks移除线程不能放在Runnable中，否则可能会出现Bug，无法移除。
if(msg.getData().getInt("percent")>=90){
progressHandler.removeCallbacks(progressThread);
}
}
};
//当在程序启动的时候就调用Handler进行加载处理
//并且线程的执行时间很长，且不可预测，那么程序就会处于一个假死状态
//progressHandler.post(progressThread);
start.setOnClickListener(newOnClickListener(){
@Override
publicvoidonClick(Viewv){
bar.setVisibility(ProgressBar.VISIBLE);
progressHandler.post(progressThread);
}
});
//实现了Runnable的内部类
progressThread=newRunnable(){
intpercent=0;
@Override
publicvoidrun(){
percent+=5;
//打印的结果是：RunnableThread:1
System.out.println("RunnableThread:"+Thread.currentThread().getId());
//通过Message对象传递参数
Messagemsg=newMessage();
Bundlebundle=newBundle();
bundle.putInt("percent",percent);
msg.setData(bundle);
progressHandler.sendMessage(msg);
try{
System.out.println("sleep...");
Thread.sleep(1000);
//当在onCreate方法开始就调用progressHandler.post()时，我们设置时间足够长，模拟假死状态。
//主线程处于等待状态，界面无法显示。
//Thread.sleep(10000);
System.out.println("wakeup...");
}catch(Exceptione){
e.printStackTrace();
}
}
};
}
}

在上面的例子中，Thread使用的是同一个，按照Java的常理应该是不同的，但是这里确实是同一个，大家可以自己测试下。

Handler与主线程是同一线程时，如果程序在设计的时候需要线程初始化较长时间或者下载文件，这种情况下，主线程是出于等待状态的，甚至出现假死现象。

在cmd100.com的视频讲解中，mars老师也讲的很清楚了，我大部分是参考其源代码再做修改。

解决办法是是用HandlerThread类来创建独立于主线程的新线程，实现异步机制，不会影响到主线程的运行。

解决代码如下

[java] view plain copy print ?

packagecom.cyl;
importandroid.app.Activity;
importandroid.os.*;
importandroid.widget.*;
importandroid.view.View;
importandroid.view.View.OnClickListener;
publicclassProgressBarHandlerThreadextendsActivity{
/**Calledwhentheactivityisfirstcreated.*/
ProgressBarbar;
Buttonstart;
MyHandlermyHandler;
RunnableprogressThread;
@Override
publicvoidonCreate(BundlesavedInstanceState){
super.onCreate(savedInstanceState);
setContentView(R.layout.main);
System.out.println("ActivityThread:"+Thread.currentThread().getId());
bar=(ProgressBar)this.findViewById(R.id.bar);
start=(Button)this.findViewById(R.id.startButton);
//使用HandlerThread来实现真正的异步线程，不会与主线程公用线程了。
HandlerThreadhandlerThread=newHandlerThread("handler_thread");
//使用getLooper()方法之前，先调start()方法
handlerThread.start();
myHandler=newMyHandler(handlerThread.getLooper());
start.setOnClickListener(newOnClickListener(){
@Override
publicvoidonClick(Viewv){
bar.setVisibility(ProgressBar.VISIBLE);
myHandler.post(progressThread);
}
});
//实现了Runnable的内部类
progressThread=newRunnable(){
intpercent=0;
@Override
publicvoidrun(){
percent+=5;
//打印的结果是：ActivityThread:8
System.out.println("RunnableThread:"+Thread.currentThread().getId());
//通过Message对象传递参数
Messagemsg=newMessage();
Bundlebundle=newBundle();
bundle.putInt("percent",percent);
msg.setData(bundle);
myHandler.sendMessage(msg);
try{
Thread.sleep(1000);
}catch(Exceptione){
e.printStackTrace();
}
}
};
}
classMyHandlerextendsHandler{
publicMyHandler(Looperlooper){
super(looper);
}
@Override
publicvoidhandleMessage(Messagemsg){
bar.setProgress(msg.arg1);
//打印的结果是：MyHandlerThread:8
System.out.println("MyHandlerThread:"+Thread.currentThread().getId());
myHandler.post(progressThread);
if(msg.arg1>=90){
myHandler.removeCallbacks(progressThread);
}
}
}
}

更多相关文章

随机推荐