Android AsyncTask实现异步处理任务的方法详解
AndroidAsyncTask实现异步处理任务的方法详解
在开发Android应用时必须遵守单线程模型的原则:AndroidUI操作并不是线程安全的并且这些操作必须在UI线程中执行。
Android单线程模型概念详解:https://www.nhooo.com/article/112165.htm
在单线程模型中始终要记住两条法则:
不要阻塞UI线程
确保只在UI线程中访问AndroidUI工具包
当一个程序第一次启动时,Android会同时启动一个对应的主线程(MainThread),主线程主要负责处理与UI相关的事件,如:用户的按键事件,用户接触屏幕的事件以及屏幕绘图事件,并把相关的事件分发到对应的组件进行处理。所以主线程通常又被叫做UI线程。
比如说从网上获取一个网页,在一个TextView中将其源代码显示出来,这种涉及到网络操作的程序一般都是需要开一个线程完成网络访问,但是在获得页面源码后,是不能直接在网络操作线程中调用TextView.setText()的.因为其他线程中是不能直接访问主UI线程成员
Android提供了几种在其他线程中访问UI线程的方法。
Activity.runOnUiThread(Runnable) View.post(Runnable) View.postDelayed(Runnable,long) Hanlder
这些类或方法同样会使你的代码很复杂很难理解。然而当你需要实现一些很复杂的操作并需要频繁地更新UI时这会变得更糟糕。
为了解决这个问题,Android1.5提供了一个工具类:AsyncTask,它使创建需要与用户界面交互的长时间运行的任务变得更简单。不需要借助线程和Handler即可实现。
AsyncTask是抽象类.AsyncTask定义了三种泛型类型Params,Progress和Result。
◆Params启动任务执行的输入参数,比如HTTP请求的URL。
◆Progress后台任务执行的百分比。
◆Result后台执行任务最终返回的结果,比如String。
AsyncTask的执行分为四个步骤,每一步都对应一个回调方法,这些方法不应该由应用程序调用,开发者需要做的就是实现这些方法。
子类化AsyncTask
实现AsyncTask中定义的下面一个或几个方法
onPreExecute(),该方法将在执行实际的后台操作前被UIthread调用。可以在该方法中做一些准备工作,如在界面上显示一个进度条。
doInBackground(Params...),将在onPreExecute方法执行后马上执行,该方法运行在后台线程中。这里将主要负责执行那些很耗时的后台计算工作。可以调用publishProgress方法来更新实时的任务进度。该方法是抽象方法,子类必须实现。
onProgressUpdate(Progress...),在publishProgress方法被调用后,UIthread将调用这个方法从而在界面上展示任务的进展情况,例如通过一个进度条进行展示。
onPostExecute(Result),在doInBackground执行完成后,onPostExecute方法将被UIthread调用,后台的计算结果将通过该方法传递到UIthread.
为了正确的使用AsyncTask类,以下是几条必须遵守的准则:
1)Task的实例必须在UIthread中创建
2)execute方法必须在UIthread中调用
3)不要手动的调用onPreExecute(),onPostExecute(Result),doInBackground(Params...),onProgressUpdate(Progress...)这几个方法
4)该task只能被执行一次,否则多次调用时将会出现异常
从网上获取一个网页,在一个TextView中将其源代码显示出来
packagetest.list; importjava.io.ByteArrayOutputStream; importjava.io.InputStream; importjava.util.ArrayList; importorg.apache.http.HttpEntity; importorg.apache.http.HttpResponse; importorg.apache.http.client.HttpClient; importorg.apache.http.client.methods.HttpGet; importorg.apache.http.impl.client.DefaultHttpClient; importandroid.app.Activity; importandroid.app.ProgressDialog; importandroid.content.Context; importandroid.content.DialogInterface; importandroid.os.AsyncTask; importandroid.os.Bundle; importandroid.os.Handler; importandroid.os.Message; importandroid.view.View; importandroid.widget.Button; importandroid.widget.EditText; importandroid.widget.TextView; publicclassNetworkActivityextendsActivity{ privateTextViewmessage; privateButtonopen; privateEditTexturl; @Override publicvoidonCreate(BundlesavedInstanceState){ super.onCreate(savedInstanceState); setContentView(R.layout.network); message=(TextView)findViewById(R.id.message); url=(EditText)findViewById(R.id.url); open=(Button)findViewById(R.id.open); open.setOnClickListener(newView.OnClickListener(){ publicvoidonClick(Viewarg0){ connect(); } }); } privatevoidconnect(){ PageTasktask=newPageTask(this); task.execute(url.getText().toString()); } classPageTaskextendsAsyncTask{ //可变长的输入参数,与AsyncTask.exucute()对应 ProgressDialogpdialog; publicPageTask(Contextcontext){ pdialog=newProgressDialog(context,0); pdialog.setButton("cancel",newDialogInterface.OnClickListener(){ publicvoidonClick(DialogInterfacedialog,inti){ dialog.cancel(); } }); pdialog.setOnCancelListener(newDialogInterface.OnCancelListener(){ publicvoidonCancel(DialogInterfacedialog){ finish(); } }); pdialog.setCancelable(true); pdialog.setMax(100); pdialog.setProgressStyle(ProgressDialog.STYLE_HORIZONTAL); pdialog.show(); } @Override protectedStringdoInBackground(String...params){ try{ HttpClientclient=newDefaultHttpClient(); //params[0]代表连接的url HttpGetget=newHttpGet(params[0]); HttpResponseresponse=client.execute(get); HttpEntityentity=response.getEntity(); longlength=entity.getContentLength(); InputStreamis=entity.getContent(); Strings=null; if(is!=null){ ByteArrayOutputStreambaos=newByteArrayOutputStream(); byte[]buf=newbyte[128]; intch=-1; intcount=0; while((ch=is.read(buf))!=-1){ baos.write(buf,0,ch); count+=ch; if(length>0){ //如果知道响应的长度,调用publishProgress()更新进度 publishProgress((int)((count/(float)length)*100)); } //让线程休眠100ms Thread.sleep(100); } s=newString(baos.toByteArray());} //返回结果 returns; }catch(Exceptione){ e.printStackTrace(); } returnnull; } @Override protectedvoidonCancelled(){ super.onCancelled(); } @Override protectedvoidonPostExecute(Stringresult){ //返回HTML页面的内容 message.setText(result); pdialog.dismiss(); } @Override protectedvoidonPreExecute(){ //任务启动,可以在这里显示一个对话框,这里简单处理 message.setText(R.string.task_started); } @Override protectedvoidonProgressUpdate(Integer...values){ //更新进度 System.out.println(""+values[0]); message.setText(""+values[0]); pdialog.setProgress(values[0]); } } }
感谢阅读,希望能帮助到大家,谢谢大家对本站的支持!