android UI 单线程模型

hotlinhao 2011-11-24

当一个程序第一次启动时,Android会同时启动一个对应的主线程(MainThread),主线程主要负责处理与UI相关的事件,如:用户的按键事件,用户接触屏幕的事件以及屏幕绘图事件,并把相关的事件分发到对应的组件进行处理。所以主线程通常又被叫做UI线程。在开发Android应用时必须遵守单线程模型的原则:AndroidUI操作并不是线程安全的并且这些操作必须在UI线程中执行。

2.1案例演示

如果在没有理解这样的单线程模型的情况下,设计的程序可能会使程序性能低下,因为所有的动作都在同一个线程中触发。例如当主线程正在做一些比较耗时的操作的时候,如正从网络上下载一个大图片,或者访问数据库,由于主线程被这些耗时的操作阻塞住,无法及时的响应用户的事件,从用户的角度看会觉得程序已经死掉。如果程序长时间不响应,用户还可能得重启系统。为了避免这样的情况,Android设置了一个5秒的超时时间,一旦用户的事件由于主线程阻塞而超过5秒钟没有响应,Android会弹出一个应用程序没有响应的对话框。下面将通过一个案例来演示这种情况:

本程序将设计和实现查看指定城市的当天天气情况的功能,

1.首先,需要选择一个天气查询的服务接口,目前可供选择的接口很多,诸如YAHOO的天气API和Google提供的天气API。本文将选择GOOGLE的天气查询API。该接口提供了多种查询方式,可以通过指定具体城市的经纬度进行查询,也可以通过城市名称进行查询。

2.用户在输入框内输入需要查询的城市名称,然后点击查询按钮

3.当用户点击查询按钮后,使用已经内置在AndroidSDK中的HttpClientAPI来调用GOOGLE的天气查询API,然后解析返回的指定城市的天气信息,并把该天气信息显示在Title上

主要代码如下:

publicclassWeatherReportextendsActivityimplementsOnClickListener{

privatestaticfinalStringGOOGLE_API_URL="http://www.google.com/ig/api?weather=";

privatestaticfinalStringNETWORK_ERROR="网络异常";

privateEditTexteditText;

@Override

publicvoidonCreate(BundlesavedInstanceState){

super.onCreate(savedInstanceState);

setContentView(R.layout.main);

editText=(EditText)findViewById(R.id.weather_city_edit);

Buttonbutton=(Button)findViewById(R.id.goQuery);

button.setOnClickListener(this);

}

@Override

publicvoidonClick(Viewv){

//获得用户输入的城市名称

Stringcity=editText.getText().toString();

//调用Google天气API查询指定城市的当日天气情况

Stringweather=getWetherByCity(city);

//把天气信息显示在title上

setTitle(weather);

}

publicStringgetWetherByCity(Stringcity){

HttpClienthttpClient=newDefaultHttpClient();

HttpContextlocalContext=newBasicHttpContext();

HttpGethttpGet=newHttpGet(GOOGLE_API_URL+city);

try{

HttpResponseresponse=httpClient.execute(httpGet,localContext);

if(response.getStatusLine().getStatusCode()!=HttpStatus.SC_OK){

httpGet.abort();

}else{

HttpEntityhttpEntity=response.getEntity();

returnparseWeather(httpEntity.getContent());

}

}catch(Exceptione){

Log.e("WeatherReport","Failedtogetweather",e);

}finally{

httpClient.getConnectionManager().shutdown();

}

returnNETWORK_ERROR;

}

}

当用户输入城市名称,然后单击按钮进行查询后,程序会调用GoogleAPI的接口获得指定城市的当日天气情况。由于需要访问网络,所以当网络出现异常或者服务繁忙的时候都会使访问网络的动作很耗时。本文为了要演示超时的现象,只需要制造一种网络异常的状况,最简单的方式就是断开网络连接,然后启动该程序,同时触发一个用户事件,比如按一下MENU键,由于主线程因为网络异常而被长时间阻塞,所以用户的按键事件在5秒钟内得不到响应,Android会提示一个程序无法响应的异常。

该对话框会询问用户是继续等待还是强行退出程序。当你的程序需要去访问未知的网络的时候都会可能会发生类似的超时的情况,用户的响应得不到及时的回应会大大的降低用户体验。所以我们需要参试以别的方式来实现

2.1子线程更新UI

显然如果你的程序需要执行耗时的操作的话,如果像上例一样由主线程来负责执行该操作是错误的。所以我们需要在onClick方法中创建一个新的子线程来负责调用GOOGLEAPI来获得天气数据。刚接触Android的开发者最容易想到的方式就是如下:

publicvoidonClick(Viewv){

//创建一个子线程执行耗时的从网络上获取天气信息的操作

newThread(){

@Override

publicvoidrun(){

//获得用户输入的城市名称

Stringcity=editText.getText().toString();

//调用Google天气API查询指定城市的当日天气情况

Stringweather=getWetherByCity(city);

//把天气信息显示在title上

setTitle(weather);

}

}.start();

}

但是很不幸,你会发现Android会提示程序由于异常而终止。为什么在其他平台上看起来很简单的代码在Android上运行的时候依然会出错呢?如果你观察LogCat中打印的日志信息就会发现这样的错误日志:

android.view.ViewRoot$CalledFromWrongThreadException:Onlytheoriginalthreadthatcreatedaviewhierarchycantouchitsviews.

从错误信息不难看出Android禁止其他子线程来更新由UIthread创建的试图。本例中显示天气信息的title实际是就是一个由UIthread所创建的TextView,所以参试在一个子线程中去更改TextView的时候就出错了。这显示违背了单线程模型的原则:AndroidUI操作并不是线程安全的并且这些操作必须在UI线程中执行

2.2MessageQueue

在单线程模型下,为了解决类似的问题,Android设计了一个MessageQueue(消息队列),线程间可以通过该MessageQueue并结合Handler和Looper组件进行信息交换。下面将对它们进行分别介绍:

lMessageQueue

MessageQueue是一个消息队列,用来存放通过Handler发布的消息。消息队列通常附属于某一个创建它的线程,可以通过Looper.myQueue()得到当前线程的消息队列。Android在第一启动程序时会默认会为UIthread创建一个关联的消息队列,用来管理程序的一些上层组件,activities,broadcastreceivers等等。你可以在自己的子线程中创建Handler与UIthread通讯。

Handler

通过Handler你可以发布或者处理一个消息或者是一个Runnable的实例。每个Handler都会与唯一的一个线程以及该线程的消息队列管理。当你创建一个新的Handler时候,默认情况下,它将关联到创建它的这个线程和该线程的消息队列。也就是说,如果你通过Handler发布消息的话,消息将只会发送到与它关联的这个消息队列,当然也只能处理该消息队列中的消息。

主要的方法有:

1)publicfinalbooleansendMessage(Messagemsg)

把消息放入该Handler所关联的消息队列,放置在所有当前时间前未被处理的消息后。

2)publicvoidhandleMessage(Messagemsg)

关联该消息队列的线程将通过调用Handler的handleMessage方法来接收和处理消息,通常需要子类化Handler来实现handleMessage。

Looper

Looper扮演着一个Handler和消息队列之间通讯桥梁的角色。程序组件首先通过Handler把消息传递给Looper,Looper把消息放入队列。Looper也把消息队列里的消息广播给所有的Handler,Handler接受到消息后调用handleMessage进行处理。

1)可以通过Looper类的静态方法Looper.myLooper得到当前线程的Looper实例,如果当前线程未关联一个Looper实例,该方法将返回空。

2)可以通过静态方法Looper.getMainLooper方法得到主线程的Looper实例

线程,消息队列,Handler,Looper之间的关系可以通过一个图来展示:

在了解了消息队列及其相关组件的设计思想后,我们将把天气预报的案例通过消息队列来重新实现:

privateEditTexteditText;

privateHandlermessageHandler;

@Override

publicvoidonCreate(BundlesavedInstanceState){

super.onCreate(savedInstanceState);

setContentView(R.layout.main);

editText=(EditText)findViewById(R.id.weather_city_edit);

Buttonbutton=(Button)findViewById(R.id.goQuery);

button.setOnClickListener(this);

//得到当前线程的Looper实例,由于当前线程是UI线程也可以通过Looper.getMainLooper()得到

Looperlooper=Looper.myLooper();

//此处甚至可以不需要设置Looper,因为Handler默认就使用当前线程的Looper

messageHandler=newMessageHandler(looper);

}

@Override

publicvoidonClick(Viewv){

//创建一个子线程去做耗时的网络连接工作

newThread(){

@Override

publicvoidrun(){

//活动用户输入的城市名称

Stringcity=editText.getText().toString();

//调用Google天气API查询指定城市的当日天气情况

Stringweather=getWetherByCity(city);

//创建一个Message对象,并把得到的天气信息赋值给Message对象

Messagemessage=Message.obtain();

message.obj=weather;

//通过Handler发布携带有天气情况的消息

messageHandler.sendMessage(message);

}

}.start();

}

//子类化一个Handler

classMessageHandlerextendsHandler{

publicMessageHandler(Looperlooper){

super(looper);

}

@Override

publicvoidhandleMessage(Messagemsg){

//处理收到的消息,把天气信息显示在title上

setTitle((String)msg.obj);

}

}

通过消息队列改写过后的天气预报程序已经可以成功运行,因为Handler的handleMessage方法实际是由关联有该消息队列的UIthread调用,而在UIthread中更新title并没有违背Android的单线程模型的原则。

2.3AsyncTask

虽然借助消息队列已经可以较为完美的实现了天气预报的功能,但是你还是不得不自己管理子线程,尤其当你的需要有一些复杂的逻辑以及需要频繁的更新UI的时候,这样的方式使得你的代码难以阅读和理解。

幸运的是Android另外提供了一个工具类:AsyncTask。它使得UIthread的使用变得异常简单。它使创建需要与用户界面交互的长时间运行的任务变得更简单,不需要借助线程和Handler即可实现。

1)子类化AsyncTask

2)实现AsyncTask中定义的下面一个或几个方法

?onPreExecute(),该方法将在执行实际的后台操作前被UIthread调用。可以在该方法中做一些准备工作,如在界面上显示一个进度条。

?doInBackground(Params...),将在onPreExecute方法执行后马上执行,该方法运行在后台线程中。这里将主要负责执行那些很耗时的后台计算工作。可以调用publishProgress方法来更新实时的任务进度。该方法是抽象方法,子类必须实现。

?3.onProgressUpdate(Progress...),在publishProgress方法被调用后,UIthread将调用这个方法从而在界面上展示任务的进展情况,例如通过一个进度条进行展示。

?4.onPostExecute(Result),在doInBackground执行完成后,onPostExecute方法将被UIthread调用,后台的计算结果将通过该方法传递到UIthread.

为了正确的使用AsyncTask类,以下是几条必须遵守的准则:

1)Task的实例必须在UIthread中创建

2)execute方法必须在UIthread中调用

3)不要手动的调用onPreExecute(),onPostExecute(Result),doInBackground(Params...),onProgressUpdate(Progress...)这几个方法

4)该task只能被执行一次,否则多次调用时将会出现异常

下面我们将通过AsyncTask并且严格遵守上面的4条准则来改写天气预报的例子:

publicvoidonCreate(BundlesavedInstanceState){

super.onCreate(savedInstanceState);

setContentView(R.layout.main);

editText=(EditText)findViewById(R.id.weather_city_edit);

Buttonbutton=(Button)findViewById(R.id.goQuery);

button.setOnClickListener(this);

}

publicvoidonClick(Viewv){

//获得用户输入的城市名称

Stringcity=editText.getText().toString();

//必须每次都重新创建一个新的task实例进行查询,否则将提示如下异常信息

//thetaskhasalreadybeenexecuted(ataskcanbeexecutedonlyonce)

newGetWeatherTask().execute(city);

}

classGetWeatherTaskextendsAsyncTask<String,Integer,String>{

@Override

protectedStringdoInBackground(String...params){

Stringcity=params[0];

//调用Google天气API查询指定城市的当日天气情况

returngetWetherByCity(city);

}

protectedvoidonPostExecute(Stringresult){

//把doInBackground处理的结果即天气信息显示在title上

setTitle(result);

}

}

注意这行代码:newGetWeatherTask().execute(city);值得一提的是必须每次都重新创建一个新的GetWeatherTask来执行后台任务,否则Android会提示“ataskcanbeexecutedonlyonce”的错误信息。

经过改写后的程序不仅显得非常的简洁,而且还减少了代码量,大大增强了可读性和可维护性。因为负责更新UI的onPostExecute方法是由UIthread调用,所以没有违背单线程模型的原则。良好的AsyncTask设计大大降低了我们犯错误的几率。

相关推荐