热门标签 | HotTags
当前位置:  开发笔记 > Android > 正文

Android多线程处理之多线程详解

本文主要介绍Android多线程处理的知识资料,这里整理下来详细的知识,和简单代码实现和实现效果图,有需要的朋友可以参考下

handler.post(r)其实这样并不会新起线程,只是执行的runnable里的run()方法,却没有执行start()方法,所以runnable走的还是UI线程。

1.如果像这样,是可以操作ui,但是run还是走在主线程,见打印出来的Log线程名字是main,说明是主线程。

这就是为什么可以直接在run方法里操作ui,因为它本质还是ui线程

handler.post(new Runnable(){

  public void run(){

  Log.e("当前线程:",Thread.currrentThread.getName());//这里打印de结果会是main

  setTitle("哈哈");

   }

});

2.通过HandlerThread获取到looper却是可以新起线程,但是在这里的run方法里操作ui是不可能的,但是这显然有个缺点,如果你执行多次post(r)方法其实走的还是HandlerThread线程。假如你执行5次,n次,其实还是一次并且它们是串行的。假如下载5张图片,你会看到图片是下完第一张,才会去下第二张。

实践证明,只有是拥有主线程looper的handler才可以操作ui,而在主线程操作ui可以在handler的handlerMessage()方法中操作Ui,也可以在handler的post(r)的run方法里操作Ui.

HandlerThread ht = new HandlerThread("handler thread");

ht.start();

handler = new Handler(ht.getLooper());

handler.post(new Runnable(){//这里run()方法其实还是在等ht.start()调用

  public void run(){

  Log.e("当前线程:",Thread.currrentThread.getName());//这里打印的会是handler thread

  setTitle("哈哈");//这样必定报错

  //android.view.ViewRoot$CalledFromWrongThreadException: Only the original thread that created a view hierarchy can touch its views.

   }

});

这样该怎么办呢,呵呵,可以无参构建一个handler。用这个handler来发送消息和处理消息,用上面的handler来开启新线程。

mainHandler = new Handler(){

  protecket void handlerMessage(Message msg){

    setTitle("哈哈");//这样就不会报错啦

  }

}

handler.post(new Runnable(){//这里run()方法其实还是在等ht.start()调用

  public void run(){

  Log.e("当前线程:",Thread.currrentThread.getName());//这里打印的会是handler thread

  mainHandler.sendEmpetMessage();//用mainHandler来发送消息

  //setTitle("哈哈");//这样必定报错

  //android.view.ViewRoot$CalledFromWrongThreadException: Only the original thread that created a view hierarchy can touch its views.

   }

});

打印Log:

3.其实第2个方法显得麻烦而且低效,用了2个handler,一个用来发起线程,一个用于处理消息。发起线程的handler必须拥有looper,所以还要实例化一个HanderThread;而处理消息的handler则不需要looper,因为它默认拥有主线程的looper,所以可以在这个handler处理ui。

其实可以只需要实例化一个handler,在主线程里构建一个无参的handler,然后由它发送和处理消息。而创建线程的任务就不用handler了,直接用new Thread(r).start();然后在r的run()方法里面处理逻辑事务。

用这样的模式下载5张图片,你就可能不会看到图片一张挨着一张展示出来,可能第2张先出来,也可能同时出来3张,5条线程很随机的。

private void loadImagesByThread(final String url,final int id){//通过Thread来new 出多个线程 
     
    new Thread(new Runnable(){ 
 
      @Override 
      public void run() { 
        // TODO Auto-generated method stub 
        Log.e("当前线程:", ""+Thread.currentThread().getName()); 
        Drawable drawable = null; 
        try { 
          drawable = Drawable.createFromStream(new URL(url).openStream(), "image.gif"); 
        } catch (MalformedURLException e) { 
          // TODO Auto-generated catch block 
          e.printStackTrace(); 
        } catch (IOException e) { 
          // TODO Auto-generated catch block 
          e.printStackTrace(); 
        } 
        Message msg = mainHandler.obtainMessage(); 
        msg.what = 2012; 
        msg.arg1 = id; 
        msg.obj = drawable; 
        msg.sendToTarget(); 
         
      } 
       
    }).start(); 
  } 

打印Log:

4.AsyncTask

用异步任务架构多任务模型其实也不是很健壮,得创建多个AsyncTask实例。一个AsyncTask仅执行一次,不能重复执行,快餐类的线程,一次用完。

实现AsyncTask子类,最重要的两个方法,一个是doInBackground(params);一个是onPostExecute(result)。在doInBackground()方法里处理耗时事务,并把结果返回,返回的值将在onPostExecute方法作为参数,然后就可以在onPostExecute()把结果展示在ui上面了。

步骤:

①实例化AsyncTask:

实例化AsyncTask然后通过task.exec(pamas);传进去参数,这个参数列表是动态的,可以是一个也可以使多个,长度可变。

  AsyncTask,第一个参数会传进去这个方法doInBackground(params),第二个参数是数据更新的值,第三个是处理事务返回的结果。

②onPreExecute方法:

这个方法没有参数,也没有返回值,可以在这个方法里,做一些提醒。比如show一个Dialog,或者弹个Toast告诉用户开始下载啦。

③doInBackground(params)方法:

进入AsyncTask内部结构,首先将执行reslut doInBackground(params)方法,这个方法将处理耗时事务,exec()的参数将会传进这个方法做参数,而返回值将会作为onPostExecute()的参数。如果要更新进度的话,需执行publicProgress()方法。

④onProgressUpdate(values)方法:

这个方法的参数必须在doInBackground()方法里执行publicProgress()方法,这个方法将会把参数传递进onProgressUpdate()方法里,然后可以在这个方法做一些ui上的更新展示,比如进度条的值就可以通过这个values值动态改变。

⑤onPostExecute(result)方法:

这里就是事务处理完毕的走的方法,doInBackground方法执行的结果将传到这里,如果这个方法返回了数据。在这个方法里可以处理Ui,可以把处理完的数据展示在ui上。比如图片啊,文字啊,一切你想要的结果。

private void loadImageByAsyncTask(final String url,final int id){//构建异步任务,这样就不用handler来处理消息了 
    DownloadTask task = new DownloadTask(); 
    task.execute(""+id,url);//AsyncTask不可重复执行 
  } 
   
  class DownloadTask extends AsyncTask{ 
 
    int id; 
    @Override 
    protected Drawable doInBackground(String... params) {//params保存url和控件id两个数据 
      // TODO Auto-generated method stub 
      Log.e("当前线程:", ""+Thread.currentThread().getName()); 
      Drawable drawable = null; 
      this.id = Integer.parseInt(params[0]); 
      try { 
        drawable = Drawable.createFromStream(new URL(params[1]).openStream(), "image.gif"); 
      } catch (MalformedURLException e) { 
        // TODO Auto-generated catch block 
        e.printStackTrace(); 
      } catch (IOException e) { 
        // TODO Auto-generated catch block 
        e.printStackTrace(); 
      } 
       
      return drawable; 
    } 
 
    @Override 
    protected void onPostExecute(Drawable result) { 
      // TODO Auto-generated method stub 
      super.onPostExecute(result); 
      ((ImageView)MainActivity.this.findViewById(id)).setImageDrawable(result); 
    } 
 
    @Override 
    protected void onPreExecute() { 
      // TODO Auto-generated method stub 
      super.onPreExecute(); 
    } 
 
    @Override 
    protected void onProgressUpdate(Integer... values) { 
      // TODO Auto-generated method stub 
      super.onProgressUpdate(values); 
    } 
 
     
  } 

这里打印的log

 

5.ExecutorServie线程池

通过Executors的静态方法来创建,一般有三种:

1.单线程 :Executors.newSingleThreadExecutor();

2.固定数量线程 :Executors.newFixedThreadPool();

3.动态线程 :Executors.newCachedThreadPool();

这里我们用固定5个线程来应用,使用方法是创建ExecutorService对象,然后执行submit(r)可以发起一个Runnable对象。用线程池来管理的好处是,可以保证系统稳定运行,适用与有大量线程,高工作量的情景下使用,假如要展示1000张图片如果创建1000个线程去加载,保证系统会死掉。用线程池就可以避免这个问题,可以用5个线程轮流执行,5个一组,执行完的线程不直接回收而是等待下次执行,这样对系统的开销就可以减小不少。

private void loadImagesByExecutors(final String url,final int id){ 
    service.submit(new Runnable(){ 
       
      @Override 
      public void run() { 
        // TODO Auto-generated method stub 
        Log.e("当前线程:", ""+Thread.currentThread().getName()); 
         
        try { 
          final Drawable drawable = Drawable.createFromStream(new URL(url).openStream(), "image.gif"); 
          mainHandler.post(new Runnable(){ 
 
            @Override 
            public void run() {//这将在主线程运行 
              // TODO Auto-generated method stub 
              ((ImageView)MainActivity.this.findViewById(id)).setImageDrawable(drawable); 
            } 
          }); 
           
        } catch (MalformedURLException e) { 
          // TODO Auto-generated catch block 
          e.printStackTrace(); 
        } catch (IOException e) { 
          // TODO Auto-generated catch block 
          e.printStackTrace(); 
        } 
         
      } 
       
    }); 
     
  } 

Log:

 

其实可能没有说清楚,第一种不算多线程。

1.loadImagesByHandler()是通过Handler.post()方法,构建两个Handler进行通信。

2.loadImagesByThread(),这个是直接new Thread()发起线程,在主线程的handler处理消息

3.loadImageByAsyncTask(),这个用的是异步任务,所有实现在它的内部结构里,可以在里头操作Ui.

4.loadImagesByExecutors()用的是线程池,使得线程可控,保证稳定运行。

其实常用的就是后三种,第二个用法灵活,简单,但不适宜大数量任务;第三个一般适用于单个任务,一次性任务;第四个一般用于大数量,高密度执行的使用情景,比如批量加载图片,批量下载文件等。

看一眼图吧:

全部源码:

package com.bvin.exec; 
 
import java.io.IOException; 
import java.net.MalformedURLException; 
import java.net.URL; 
import java.util.concurrent.ExecutorService; 
import java.util.concurrent.Executors; 
 
import android.app.Activity; 
import android.graphics.drawable.Drawable; 
import android.os.AsyncTask; 
import android.os.Bundle; 
import android.os.Handler; 
import android.os.HandlerThread; 
import android.os.Message; 
import android.util.Log; 
import android.view.View; 
import android.widget.Button; 
import android.widget.ImageView; 
 
public class MainActivity extends Activity { 
  /** Called when the activity is first created. */ 
   
  private Handler handler ; 
  private Button bt; 
  private Handler mainHandler = new Handler(){ 
 
    @Override 
    public void handleMessage(Message msg) { 
      // TODO Auto-generated method stub 
      super.handleMessage(msg); 
      if(msg.what == 2012){ 
        //只要在主线程就可以处理ui  
        ((ImageView)MainActivity.this.findViewById(msg.arg1)).setImageDrawable((Drawable)msg.obj); 
      } 
    } 
     
     
  }; 
   
  private ExecutorService service = Executors.newFixedThreadPool(5); 
   
  @Override 
  public void onCreate(Bundle savedInstanceState) { 
    super.onCreate(savedInstanceState); 
    setContentView(R.layout.main); 
    initViews(); 
    HandlerThread ht = new HandlerThread("down image thread"); 
    ht.start(); 
    handler = new Handler(ht.getLooper()){//如果有了looper那么这个handler就不可以处理ui了 
 
      @Override 
      public void handleMessage(Message msg) { 
        // TODO Auto-generated method stub 
        super.handleMessage(msg); 
         
         
      } 
       
    }; 
     
  } 
   
  private void initViews(){ 
     
    bt = (Button)findViewById(R.id.bt); 
    bt.setOnClickListener(new View.OnClickListener() { 
       
      @Override 
      public void onClick(View v) { 
        // TODO Auto-generated method stub 
        loadImagesByExecutors("http://news.baidu.com/z/resource/r/image/2012-11-23/23c1625aca99f02c50d8e510383a34e7.jpg",R.id.iv1); 
        loadImagesByExecutors("http://news.baidu.com/z/resource/r/image/2012-11-23/c4698d97ef6d10722c8e917733c7beb3.jpg",R.id.iv2); 
        loadImagesByExecutors("http://news.baidu.com/z/resource/r/image/2012-11-23/f332ffe433be2a3112be15f78bff5a40.jpg",R.id.iv3); 
        loadImagesByExecutors("http://news.baidu.com/z/resource/r/image/2012-11-23/6ff8a9c647a1e80bc602eeda48865d4c.jpg",R.id.iv4); 
        loadImagesByExecutors("http://news.baidu.com/z/resource/r/image/2012-11-23/f104d069f7443dca52a878d779392874.jpg",R.id.iv5); 
      } 
    }); 
  } 
   
  private void loadImagesByHandler(final String url,final int id){//通过拥有looper的handler.post(runnable),新建线程 
     
     
    handler.post(new Runnable(){//如果handler没有Looper那么它就不能构建新线程了 
 
      @Override 
      public void run() { 
        // TODO Auto-generated method stub 
        Log.e("当前线程:", ""+Thread.currentThread().getName()); 
        Drawable drawable = null; 
        try { 
          drawable = Drawable.createFromStream(new URL(url).openStream(), "image.gif"); 
        } catch (MalformedURLException e) { 
          // TODO Auto-generated catch block 
          e.printStackTrace(); 
        } catch (IOException e) { 
          // TODO Auto-generated catch block 
          e.printStackTrace(); 
        } 
        //SystemClock.sleep(2000); 
        //((ImageView)MainActivity.this.findViewById(id)).setImageDrawable(drawable); 
        Message msg = mainHandler.obtainMessage(); 
        msg.what = 2012; 
        msg.arg1 = id; 
        msg.obj = drawable; 
        msg.sendToTarget(); 
      } 
       
    }); 
     
     
  } 
   
  private void loadImagesByThread(final String url,final int id){//通过Thread来new 出多个线程 
     
    new Thread(new Runnable(){ 
 
      @Override 
      public void run() { 
        // TODO Auto-generated method stub 
        Log.e("当前线程:", ""+Thread.currentThread().getName()); 
        Drawable drawable = null; 
        try { 
          drawable = Drawable.createFromStream(new URL(url).openStream(), "image.gif"); 
        } catch (MalformedURLException e) { 
          // TODO Auto-generated catch block 
          e.printStackTrace(); 
        } catch (IOException e) { 
          // TODO Auto-generated catch block 
          e.printStackTrace(); 
        } 
        Message msg = mainHandler.obtainMessage(); 
        msg.what = 2012; 
        msg.arg1 = id; 
        msg.obj = drawable; 
        msg.sendToTarget(); 
         
      } 
       
    }).start(); 
  }  
 
  private void loadImageByAsyncTask(final String url,final int id){//构建异步任务,这样就不用handler来处理消息了 
    DownloadTask task = new DownloadTask(); 
    task.execute(""+id,url);//AsyncTask不可重复执行 
  } 
   
  private void loadImagesByExecutors(final String url,final int id){ 
    service.submit(new Runnable(){ 
       
      @Override 
      public void run() { 
        // TODO Auto-generated method stub 
        Log.e("当前线程:", ""+Thread.currentThread().getName()); 
         
        try { 
          final Drawable drawable = Drawable.createFromStream(new URL(url).openStream(), "image.gif"); 
          mainHandler.post(new Runnable(){ 
 
            @Override 
            public void run() {//这将在主线程运行 
              // TODO Auto-generated method stub 
              ((ImageView)MainActivity.this.findViewById(id)).setImageDrawable(drawable); 
            } 
          }); 
           
        } catch (MalformedURLException e) { 
          // TODO Auto-generated catch block 
          e.printStackTrace(); 
        } catch (IOException e) { 
          // TODO Auto-generated catch block 
          e.printStackTrace(); 
        } 
         
      } 
       
    }); 
     
  } 
   
  class DownloadTask extends AsyncTask{ 
 
    int id; 
    @Override 
    protected Drawable doInBackground(String... params) {//params保存url和控件id两个数据 
      // TODO Auto-generated method stub 
      Log.e("当前线程:", ""+Thread.currentThread().getName()); 
      Drawable drawable = null; 
      this.id = Integer.parseInt(params[0]); 
      try { 
        drawable = Drawable.createFromStream(new URL(params[1]).openStream(), "image.gif"); 
      } catch (MalformedURLException e) { 
        // TODO Auto-generated catch block 
        e.printStackTrace(); 
      } catch (IOException e) { 
        // TODO Auto-generated catch block 
        e.printStackTrace(); 
      } 
       
      return drawable; 
    } 
 
    @Override 
    protected void onPostExecute(Drawable result) { 
      // TODO Auto-generated method stub 
      super.onPostExecute(result); 
      ((ImageView)MainActivity.this.findViewById(id)).setImageDrawable(result); 
    } 
 
    @Override 
    protected void onPreExecute() { 
      // TODO Auto-generated method stub 
      super.onPreExecute(); 
    } 
 
    @Override 
    protected void onProgressUpdate(Integer... values) { 
      // TODO Auto-generated method stub 
      super.onProgressUpdate(values); 
    } 
 
     
  } 
} 



以上就是对Android 多线程的资料整理,后续继续补充相关知识,谢谢大家对本站的支持!


推荐阅读
  • SQLite 动态创建多个表的需求在网络上有不少讨论,但很少有详细的解决方案。本文将介绍如何在 Qt 环境中使用 QString 类轻松实现 SQLite 表的动态创建,并提供详细的步骤和示例代码。 ... [详细]
  • 本文深入探讨了 Java 编程语言的基础,特别是其跨平台特性和 JVM 的工作原理。通过介绍 Java 的发展历史和生态系统,帮助初学者理解如何编写并运行第一个 Java 程序。 ... [详细]
  • 本文介绍了两种方法,用于检测 Android 设备是否开启了开发者模式。第一种方法通过检查 USB 调试模式的状态,第二种方法则直接判断开发者选项是否启用。这两种方法均提供了代码示例和详细解释。 ... [详细]
  • 本文深入探讨了 com.example.android.sunshine.data.TestUtilities 中 validateThenCloseCursor() 方法的使用方法及其代码示例,旨在帮助开发者更好地理解和应用该方法。 ... [详细]
  • 当在 Android 应用中使用 NDK 时,可能会遇到 java.lang.UnsatisfiedLinkError: Native method not found 的错误。本文将详细探讨该错误的原因及解决方案。 ... [详细]
  • 本文介绍如何使用Python进行文本处理,包括分词和生成词云图。通过整合多个文本文件、去除停用词并生成词云图,展示文本数据的可视化分析方法。 ... [详细]
  • 本文介绍如何在Linux服务器之间使用SCP命令进行文件传输。SCP(Secure Copy Protocol)是一种基于SSH的安全文件传输协议,支持从远程机器复制文件到本地服务器或反之。示例包括从192.168.45.147复制tomcat目录到本地/home路径。 ... [详细]
  • 并发编程:深入理解设计原理与优化
    本文探讨了并发编程中的关键设计原则,特别是Java内存模型(JMM)的happens-before规则及其对多线程编程的影响。文章详细介绍了DCL双重检查锁定模式的问题及解决方案,并总结了不同处理器和内存模型之间的关系,旨在为程序员提供更深入的理解和最佳实践。 ... [详细]
  • 本文详细介绍了如何在CentOS 7操作系统上安装和配置Grafana,包括必要的依赖项安装、插件管理以及服务启动等步骤。 ... [详细]
  • 解决JAX-WS动态客户端工厂弃用问题并迁移到XFire
    在处理Java项目中的JAR包冲突时,我们遇到了JaxWsDynamicClientFactory被弃用的问题,并成功将其迁移到org.codehaus.xfire.client。本文详细介绍了这一过程及解决方案。 ... [详细]
  • 本文详细介绍了Git分布式版本控制系统中远程仓库的概念和操作方法。通过具体案例,帮助读者更好地理解和掌握如何高效管理代码库。 ... [详细]
  • 使用GDI的一些AIP函数我们可以轻易的绘制出简 ... [详细]
  • 本题探讨如何通过最大流算法解决农场排水系统的设计问题。题目要求计算从水源点到汇合点的最大水流速率,使用经典的EK(Edmonds-Karp)和Dinic算法进行求解。 ... [详细]
  • 本文介绍了如何通过配置 Android Studio 和 Gradle 来显著提高构建性能,涵盖内存分配优化、并行构建和性能分析等实用技巧。 ... [详细]
  • 本文介绍如何通过SSH协议使用Xshell远程连接到Ubuntu系统。为了实现这一目标,需要确保Ubuntu系统已安装并配置好SSH服务器,并保证网络连通性。 ... [详细]
author-avatar
小虎
每一天,不管用什么方式,我都要变得越来越好!
PHP1.CN | 中国最专业的PHP中文社区 | DevBox开发工具箱 | json解析格式化 |PHP资讯 | PHP教程 | 数据库技术 | 服务器技术 | 前端开发技术 | PHP框架 | 开发工具 | 在线工具
Copyright © 1998 - 2020 PHP1.CN. All Rights Reserved | 京公网安备 11010802041100号 | 京ICP备19059560号-4 | PHP1.CN 第一PHP社区 版权所有