Android多线程编程

mac2022-06-30  117

一 线程的基本用法

1.创建线程

  方法一:实现Runnable接口的方法定义一个线程。

class MyThread implements Runnable{ @Override public void run() { //处理的具体的逻辑 } }

  然后Thread的构造函数接收一个Runnable参数,并调用start方法,run()方法中的代码就会在子线程中运行了。

/*启动线程*/ MyThread myThread = new MyThread(); new Thread(myThread).start();

 

  方法二:使用匿名类的方式。

new Thread(new Runnable(){ @Override public void run(){ //处理具体的逻辑 } }).strat();

 

2.在子线程中更新UI

在线程中更新UI是不安全的,所以要更新UI,必须要到主线程中更新UI。

 

实例如下:要实现在线程中点击按钮后更改Textview中文字。

布局

1 <LinearLayout xmlns:android="http://schemas.android.com/apk/res/android" 2 android:layout_width="match_parent" 3 android:layout_height="match_parent" 4 android:orientation="vertical"> 5 6 <Button 7 android:id="@+id/change_text" 8 android:layout_width="match_parent" 9 android:layout_height="wrap_content" 10 android:text="change text" /> 11 12 <TextView 13 android:id="@+id/text" 14 android:layout_width="match_parent" 15 android:layout_height="wrap_content" 16 android:layout_gravity="center_horizontal" 17 android:gravity="center_horizontal" 18 android:layout_centerInParent="true" 19 android:text="Hello world" 20 android:textSize="20sp" /> 21 22 </LinearLayout>

MainActivity如下:

1 public class MainActivity extends AppCompatActivity implements View.OnClickListener { 2 3 private TextView text; 4 private Button changeText; 5 6 public static final int UPDATE_TEXT = 1; 7 8 private Handler handler = new Handler(){ 9 10 public void handleMessage(Message msg){ 11 switch (msg.what){ 12 case UPDATE_TEXT: 13 //在这里可以进行ui操作 14 text.setText("change ui"); 15 break; 16 default: 17 break; 18 } 19 } 20 }; 21 22 @Override 23 protected void onCreate(Bundle savedInstanceState) { 24 super.onCreate(savedInstanceState); 25 setContentView(R.layout.activity_main); 26 text = (TextView)findViewById(R.id.text); 27 changeText = (Button) findViewById(R.id.change_text); 28 changeText.setOnClickListener(this); 29 } 30 31 @Override 32 public void onClick(View view) { 33 switch (view.getId()){ 34 case R.id.change_text: 35 new Thread(new Runnable() { 36 @Override 37 public void run() { 38 Message message = new Message(); 39 message.what = UPDATE_TEXT; 40 handler.sendMessage(message); //将Message对象发送出去 41 } 42 }).start(); 43 break; 44 default: 45 break; 46 } 47 } 48 }

可以看到我们在这里先定义了一个整型常量UPDATE_TEXT,用于表示更新的这个动作。

  1.新增一个Hander对象(处理器),重写父类的handleMessage()方法,在这里对Message进行处理。

  2.在点击事件中,创建一个子线程,但在子线程中是新建了一个消息对象Message。将他的携带的消息what字段设置为UPDATE_TEXT。

  3.调用Handler中的sendMessage()方法将这条Message发送。

  4.这是Handler会收到这个消息,并在handlerMessage中对消息进行处理,因为这个是主线程中,所以可以进行相关的ui更改操作。

在线程中更改UI使用的是异步消息处理机制。

这种处理机制由四个部分组成。Message,Handler,MessageQueue和Looper。

(1)Message:

  Message是在线程之间传递的消息,它可以在内部携带少量的信息,用于在不同线程之间交换数据。Message的what、arg1和arg2字段可以携带一些整型数据,使用obj字段可以携带一个Object对象

(2)Handler:

  Handler顾名思义也就是处理者的意思,它主要是用于发送和处理消息的。发送消息一般是使用Handler的sendMessage()方法,而发出的消息经过一系列地辗转处理后,最终会传递到Handler的handleMessage()方法

(3)MessageQueue:

  MessageQueue是消息队列的意思,它主要用于存放所有通过Handler发送的消息。这部分消息会一直存在于消息队列中,等待被处理。每个线程中只会有一个MessageQueue对象

(4)Looper:

  Looper是每个线程中的MessageQueue的管家,调用Looper的loop()方法后,就会进入到一个无限循环当中,然后每当发现MessageQueue()中存在一条消息,就会将它去除,并传递到Handler的handleMessage()方法中。每个线程也只会有一个Looper对象。

整体流程

  首先需要在主线程当中创建一个Handler对象,并重写handleMessage()方法。然后当子线程中需要进行UI操作时,就创建一个Message对象,并通过Handler将这条消息发送出去。之后这条消息会被添加到MessageQueue的队列中等待被处理,而Looper则会一直尝试从MessageQueue中取出待处理消息,最后分发回Handler的handleMessage方法中。由于Handler是在主线程中创建的,所以此时handleMessage()方法中的代码也会在主线程中运行,所以可以安心的进行UI操作。

 

3.使用AsyncTask

由于AsyncTask是一个抽象类,需要有一个子类去继承他。继承时可以为AsyncTask类指定3个泛型参数。

Params 执行AysncTask时需要传入的参数。可同于在后台任务中使用。Progress 后台执行任务时,如果需要在界面上显示当前的进度,则使用这里指定的泛型作为进度单位。Result 任务执行完毕后,如果需要对结果进行返回则使用这里指定的泛型作为返回值类型。 class DownloadTask extends AsyncTask<Void,Void,Void>{ ··· }

需要重写几个方法才能完成定制。经常需要重写的四个方法:

onPreExecute()   在后台任务开始执行之前调用,用于进行一些界面上的初始化操作,比如显示一个进度条对话框等。doInBackground(Params)   该方法中所有代码在子线程中运行,应在这里处理所有耗时任务。任务一旦完成可以通过return语句来将任务的执行结果返回。若AsyncTask第三个泛型参数指定的是Void,则不返回任务执行结果。注意,该方法中不能进行UI操作,若要更新UI操作,比如反馈当前任务的执行进度,可调用publicProgress(Progress…)方法来完成。onProgressUpdate(Progress)   当后台任务中调用了publishProgress(Progress)方法后,onProgressUpdate(Progress)方法就会很快被调用。该方法中携带的参数就是在后台任务重传递进来的。在这个方法中可以对UI进行操作,利用参数中的数值可以对界面元素进行相应的更新。onPostExecute(Result)   当后台任务执行完毕并通过return语句进行返回时,该方法很快被调用,返回的数据会作为参数传递到此方法中,可利用返回的数据来进行一些UI操作,比如说提醒任务执行的结果,以及关闭掉进度条对话框等。

 

示例下载代码:

1 public class DownloadTask extends AsyncTask<Void, Integer, Boolean> { 2 3 /*在后台任务执行开始前调用,用于界面的初始化*/ 4 @Override 5 protected void onPreExecute() { 6 progressDialog.show(); //显示进度对话框 7 } 8 9 /*这个方法中的代码都在子线程中运行,处理耗时任务,结果通过return语句返回。 10 * 这个方法中不可以进行ui操作,要调用publishProgress()方法来ui操作*/ 11 @Override 12 protected Boolean doInBackground(Void... params) { 13 try { 14 while (true) { 15 int downloadPercent = doDownload(); //虚构的方法 16 publishProgress(downloadPercent); 17 if (downloadPercent >= 100) { 18 break; 19 } 20 } 21 } catch (Exception e) { 22 return false; 23 } 24 return true; 25 } 26 27 /*在调用publishProgress()方法后,该方法很快被调用,用来更新ui*/ 28 @Override 29 protected void onProgressUpdate(Integer... values) { 30 //在这里更新下载进度 31 progressDialog.setMessage("Downloaded" + values[0] + "%"); 32 } 33 34 @Override 35 protected void onPostExecute(Boolean result){ 36 progressDialog.dismiss();//关闭进度对话框 37 //在这里提示下载结果 38 if(result){ 39 Toast.makeText(context,"Download succeeded",Toast.LENGTH_LONG).show(); 40 }else { 41 Toast.makeText(context,"Download failed",Toast.LENGTH_LONG).show(); 42 } 43 } 44 }

在doInBackground()方法里进行下载任务,虚构的doDownload()方法计算当下下载的进度并返回。然后通过publishProgress()方法将下载进度传过来,在onProgressUpdate()方法中执行ui更新操作。

下载完后,DoInBackground()会返回一个布尔型变量,onPostExecute()方法被调用,显示下载结果。

如果想启动这个任务,只需执行如下代码:

new DownloadTask().execute();

 

转载于:https://www.cnblogs.com/Mask-D/p/9566724.html

最新回复(0)