android线程及线程池

众所周知,在UI系统中进行一些耗时操作,都会导致卡顿现象,因为一次刷新在16ms,如果当次操作过了这个时间,那么用户就能感觉到明显的卡顿,甚至引起ANR 。

对于这种情况,一般都是再起一个线程,进行一些耗时的操作,通过继承Thread 或者实现Runnable接口,重写run方法,来实现创建新线程,进行耗时操作的需求.由于java的单继承关系,首推实现Runnable方法,这样不会太过臃肿。

private void runThread() {
        Thread t1 = new Thread(new MyRunnable(this), "郭富城");
        t1.start();
      //强调一点,调用run方法是真的调用方法,而调用start方法则会创建新线程去调用这个run方法。
    }

//实现runnable方法  至于继承Thread方法的代码 ,就不写了
    static class MyRunnable implements Runnable {
        private WeakReference<MainActivity> reference;

        MyRunnable(MainActivity activity) {
            reference = new WeakReference<MainActivity>(activity);
        }

        @Override
        public void run() {
            if (reference != null) {
                MainActivity activity = reference.get();
                if (activity != null) {
                    //子线程不能弹toast的 所以加了点东西
                    Looper.prepare();
                    Toast.makeText(activity, Thread.currentThread().getName() + " is Runing", Toast.LENGTH_SHORT).show();
                    Looper.loop();
                }
            }
        }
    }

另外,jdk1.5版本以后,就新加了个Callable接口,相较于Runnable接口,他可以定义返回值,并且可以抛出异常,需要实现的方法也从run方法变成了call方法。还有一点很有意思,他返回一个Future对象,通过这个对象,我们可以知道任务的进行程序,并且可以关闭这个任务。Thread是不支持这个接口的 ,所以如果要用Callable,就需要用上FutureTask.

@FunctionalInterface
public interface Callable<V> {
    V call() throws Exception;
}

public interface Future<V> {

    boolean cancel(boolean mayInterruptIfRunning);

    boolean isCancelled();

    boolean isDone();

    V get() throws InterruptedException, ExecutionException;

    V get(long timeout, TimeUnit unit)
        throws InterruptedException, ExecutionException, TimeoutException;
}

简单的说,FutureTask是一种可以取消的异步任务,异步执行任务, 可以开始、取消以及查看任务是否完成, 如果任务没有执行完,get方法会导致线程阻塞, 一旦一个执行任务已经完成就不能再次开始和结束(除非执行时通过runAndReset()方法.另外,FutureTask也同样支持Runnable接口。

 private void runFutureTask() {
        //创建线程池 不用线程池 直接用future也可以的
        final ExecutorService exec = Executors.newFixedThreadPool(5);
        //创建futureTask任务
        final FutureTask<String> ft = new FutureTask<String>(new MyCallable());
        // 执行也可以 提交也可以 还有种invokeAll方法
        exec.execute(ft);
//        exec.submit(ft);
        new Thread(new Runnable() {
            @Override
            public void run() {
                try {
                    //get方法会自动阻塞当前线程  直到拿到结果
                    //所以不要放在主线程去get 不然就卡住了 虽然我试过卡个15秒也没事
                    final String text = ft.get();
                    Looper.prepare();
                    Toast.makeText(FutureTaskActivity.this, text, Toast.LENGTH_SHORT).show();
                    Looper.loop();
                } catch (InterruptedException e) {
                    e.printStackTrace();
                } catch (ExecutionException e) {
                    e.printStackTrace();
                }
            }
        }).start();

        //用完线程池 记得关闭掉
        exec.shutdown();
    }

    static class MyCallable implements Callable<String> {

        @Override
        public String call() throws Exception {
            Thread.sleep(3000);
            return "代码让我快乐,代码让我秃顶";
        }
    }

线程是CPU调度的最小单元,对于线程的创建,销毁,调度,其实也是在耗费一定资源的,特别是某些情况下,你需要创建一堆线程进行一些简单的耗时操作时,这个资源的消耗量还是非常大的,所以就有线程池的需求了。

我们来总结一下优点吧。

1.重用线程池中的线程,避免频繁地创建和销毁线程带来的性能消耗;

2.有效控制线程的最大并发数量,防止线程过大导致抢占资源造成系统阻塞;

3.可以对线程进行一定地管理。

使用线程池 相对于每次都new 线程,性能会好很多,并且可以统一管理,功能上也能有所改善,如果需要定时执行,定期执行,线程中断等。

减少内存开销。

ThreadPoolExecutor:
  ExecutorService是最初的线程池接口,ThreadPoolExecutor类是对线程池的具体实现,它通过构造方法来配置线程池的参数,我们来分析一下它常用的构造函数吧。

public ThreadPoolExecutor(int corePoolSize,
                          int maximumPoolSize,
                          long keepAliveTime,
                          TimeUnit unit,
                          BlockingQueue<Runnable> workQueue) {
    this(corePoolSize, maximumPoolSize, keepAliveTime, unit, workQueue,
         Executors.defaultThreadFactory(), defaultHandler);
}

参数解释:

    corePoolSize,线程池中核心线程的数量,默认情况下,即使核心线程没有任务在执行它也存在的,我们固定一定数量的核心线程且它一直存活这样就避免了一般情况下CPU创建和销毁线程带来的开销。我们如果将ThreadPoolExecutor的allowCoreThreadTimeOut属性设置为true,那么闲置的核心线程就会有超时策略,这个时间由keepAliveTime来设定,即keepAliveTime时间内如果核心线程没有回应则该线程就会被终止。allowCoreThreadTimeOut默认为false,核心线程没有超时时间。
    maximumPoolSize,线程池中的最大线程数,当任务数量超过最大线程数时其它任务可能就会被阻塞。最大线程数=核心线程+非核心线程。非核心线程只有当核心线程不够用且线程池有空余时才会被创建,执行完任务后非核心线程会被销毁。
    keepAliveTime,非核心线程的超时时长,当执行时间超过这个时间时,非核心线程就会被回收。当allowCoreThreadTimeOut设置为true时,此属性也作用在核心线程上。
    unit,枚举时间单位,TimeUnit。
    workQueue,线程池中的任务队列,我们提交给线程池的runnable会被存储在这个对象上。

线程池的分配遵循这样的规则:

    当线程池中的核心线程数量未达到最大线程数时,启动一个核心线程去执行任务;
    如果线程池中的核心线程数量达到最大线程数时,那么任务会被插入到任务队列中排队等待执行;
    如果在上一步骤中任务队列已满但是线程池中线程数量未达到限定线程总数,那么启动一个非核心线程来处理任务;
    如果上一步骤中线程数量达到了限定线程总量,那么线程池则拒绝执行该任务,且ThreadPoolExecutor会调用RejectedtionHandler的rejectedExecution方法来通知调用者。

四种线程池 都可以通过Executors提供:

  1. newCachedThreadPool:创建一个可缓存线程池,他是一个不限容量的线程池,其中创建的所有的线程都是非核心线程,如果线程池长度超过处理需要,超时时间设置为60s,如果当前没有任务,会回收空闲线程,若无可回收,则新建线程。用于执行一些生存期很短的异步型任务
public static ExecutorService new CachedThreadPool(){
    return new ThreadPoolExecutor(
        0, Integer.MAX_VALUE, 60L, TimeUnit.SECONDS,
        new SynchronousQueue<Runnable>()
    );
}
ExecutorService cachedThreadPool = Executors.newCachedThreadPool();
  1. newFixedThreadPool :创建一个定长线程池,可控制线程最大并发数,超出的线程会在队列中等待。池线程数固定,创建的线程会一直存在。它没有超时机制并且等待队列无限常,所以fixedThreadPool多数针对一些很稳定很固定的正规并发线程,多用于服务器。
public static ExecutorService newFixedThreadPool(int nThreads){
    return new ThreadPoolExecutor(
        nThreads, nThreads, 0L, TimeUnit.MILLISECONDS,
        new LinkedBlockingQueue<Runnable>()
        );
}
//创建线程池
ExecutorService mExecutor = Executors.newFixedThreadPool(5);//参数即核心线程数
  1. newScheduledThreadPool 创建一个定长线程池,其实他将上面两种线程池的优点全部集结成一块,他有一定数量的核心线程,并且无限容量的非核心线程,区别在于非核心线程的超时时间设定为0秒,即一旦空闲,立马回收,支持定时及周期性任务执行。
public static ScheduledThreadPool newScheduledThreadPool(int corePoolSize){
    return new ScheduledThreadPoolExecutor(corePoolSize);
}
public ScheduledThreadPoolExecutor(int corePoolSize){
    super(corePoolSize, Integer.MAX_VALUE, 0, NANOSECONDS,
          new DelayedWorkQueue());
}
ScheduledExecutorService scheduledThreadPool = Executors.newScheduledThreadPool(10);//核心线程数
  1. newSingleThreadExecutor 创建一个单线程化的线程池,他只有一个核心线程,它也只会用唯一的工作线程来执行任务,可以让调用者忽略线程同步的问题。
public static ExecutorService newSingleThreadExecutor(){
    return new FinalizableDelegatedExecutorService(
        new ThreadPoolExecutor(
        1, 1, 0L, TimeUnit.MILLISECONDS,
        new LinkedBlockingQueue<Runnable>()));
}
ExecutorService singleThreadExecutor = Executors.newSingleThreadExecutor();

线程池一般用法

    shutDown(),关闭线程池,需要执行完已提交的任务;
    shutDownNow(),关闭线程池,并尝试结束已提交的任务;
    allowCoreThreadTimeOut(boolen),允许核心线程闲置超时回收;
    execute(),提交任务无返回值;
    submit(),提交任务有返回值;

newCachedThreadPool缓存线程池,如果线程超出则灵活回收,如果不够则创建

newFixedThreadPool 定长线程池,可以设置最大线程数,超出的任务在队列中等候。

newScheduledThreadPool 也是定长线程池 ,支持定时及周期性任务。

newSingleThreadExecutor 单线程化的线程池,任务根据加入顺序在队列中慢慢等待执行。

除了以上这些,在Android中充当线程的角色还有AsyncTask、HandlerThread、IntentService。它们本质上都是由Handler+Thread来构成的。

AsyncTask,它封装了线程池和Handler,主要为我们在子线程中更新UI提供便利。

HandlerThread,它是个具有消息队列的线程,可以方便我们在子线程中处理不同的事务。

IntentService,我们可以将它看做为HandlerThread的升级版,它是服务,优先级更高。

参考

http://blog.csdn.net/weixin_36244867/article/details/72832632

http://blog.csdn.net/linchunquan/article/details/22382487

http://www.hchstudio.cn/2017/04/01/FutureTask%E6%BA%90%E7%A0%81%E5%88%86%E6%9E%90/

http://www.cnblogs.com/wenjiang/archive/2012/09/02/2668089.html


作者:草丛伦链接:http://www.jianshu.com/p/d79dab197d5a來源:简书著作权归作者所有。商业转载请联系作者获得授权,非商业转载请注明出处。
时间: 2024-10-10 19:22:49

android线程及线程池的相关文章

Android的线程和线程池

原文链接,转载请注明出处 http://sparkyuan.me/2016/03/25/Android的线程和线程池/ 在Java中默认情况下一个进程只有一个线程,也就是主线程,其他线程都是子线程,也叫工作线程.Android中的主线程主要处理和界面相关的事情,而子线程则往往用于执行耗时操作.线程的创建和销毁的开销较大,所以如果一个进程要频繁地创建和销毁线程的话,都会采用线程池的方式. Android中线程的形态 传统的Thread AsyncTask HandlerThread IntentS

Android开发之线程池使用总结

线程池算是Android开发中非常常用的一个东西了,只要涉及到线程的地方,大多数情况下都会涉及到线程池.Android开发中线程池的使用和Java中线程池的使用基本一致.那么今天我想来总结一下Android开发中线程池的使用. OK,假如说我想做一个新闻应用,ListView上有一个item,每个item上都有一张图片需要从网络上加载,如果不使用线程池,你可能通过下面的方式来开启一个新线程: new Thread(new Runnable() { @Override public void ru

Android线程与线程池

一.特殊的线程 1.AsynTask 底层用到了线程池,封装了线程池和Handler,主要是为了方便开发者在子线程中更新UI 2.IntentService(不完整???) 内部采用HandlerThread来执行任务,当任务执行完毕后IntentService会自动退出,底层直接使用了线程(从任务执行的角度来看,IntentService的作用很像一个后台线程,但是IntentService是一种服务,他不容易被系统杀死从而可以尽量保证任务的执行) 3.HandlerThread 是一种具有消

Android(线程二) 线程池详解

我们在ListView中需要下载资源时,赞不考虑缓存机制,那么每一个Item可能都需要开启一个线程去下载资源(如果没有线程池),如果Item很多,那么我们可能就会无限制的一直创建新的线程去执行下载任务,最终结果可能导致,应用卡顿.手机反应迟钝!最坏的结果是,用户直接卸载掉该App.所以,我们在实际开发中需要考虑多线程,多线程就离不开线程池.如果你对线程还不了解,可以看看这篇文章,Android(线程一) 线程. 使用线程池的优点: (1).重用线程,避免线程的创建和销毁带来的性能开销: (2).

android线程与线程池-----线程池(二)《android开发艺术与探索》

android 中的线程池 线程池的优点: 1 重用线程池中的线程,避免了线程的创建和销毁带来的性能开销 2 能有效的控制最大并发数,避免大量线程之间因为喜欢抢资源而导致阻塞 3 能够对线程进行简单的管理,提供定时执行以及指定间隔时间循环执行等 android 中的线程池源自java 中的Executor,Executor是一个接口,正真的实现是ThreadPoolExecutor. ThreadPoolExecutor 提供参数配置线程池. 下面是一个常用的构造方法: public Threa

《Android开发艺术探索》第11章 Android的线程和线程池

第11章 Android的线程和线程池 11.1 主线程和子线程 (1)在Java中默认情况下一个进程只有一个线程,也就是主线程,其他线程都是子线程,也叫工作线程.Android中的主线程主要处理和界面相关的事情,而子线程则往往用于执行耗时操作.线程的创建和销毁的开销较大,所以如果一个进程要频繁地创建和销毁线程的话,都会采用线程池的方式.(2)在Android中除了Thread,还有HandlerThread.AsyncTask以及IntentService等也都扮演着线程的角色,只是它们具有不

Android中的线程池

总会有线程,总会有队列,等着被执行吧.so,让我们再深深看看线程池: 简介: 线程的使用在java中占有极其重要的地位,在jdk1.4极其之前的jdk版本中,关于线程池的使用是极其简陋的.在jdk1.5之后这一情况有了很大的改观.Jdk1.5之后加入了java.util.concurrent包,这个包中主要介绍java中线程以及线程池的使用.为我们在开发中处理线程的问题提供了非常大的帮助. 作用: 线程池作用就是限制系统中执行线程的数量.     根据系统的环境情况,可以自动或手动设置线程数量,

【转载】Android中UI线程与后台线程交互设计的5种方法

原帖地址:http://www.cr173.com/html/19165_1.html 在android的设计思想中,为了确保用户顺滑的操作体验.一些耗时的任务不能够在UI线程中运行,像访问网络就属于这类任务.因此我们必须要重新开启一个后台线程运行这些任务.然而,往往这些任务最终又会直接或者间接的需要访问和控制UI控件.例如访问网络获取数据,然后需要将这些数据处理显示出来.就出现了上面所说的情况.原本这是在正常不过的现象了,但是android规定除了UI线程外,其他线程都不可以对那些UI控件访问

java中的进程,线程,线程池总结

1.线程与进程 进程 狭义上讲:正在执行的程序,由线程组成,可包含多个线程在运行. 广义上讲:进程是一个具有一定独立功能的程序有关于某个数据集合的一次运行的活动.它可以申请或者拥有系统资源,是一个动态的概念. 进程的概念主要两点:1.进程是一个实体,每一个进程都有自己的地址空间,一般情况下包括文本区域,数据区和堆栈. 线程 为进程中执行的程序片段. 一个线程由线程ID,当前指令针,寄存器和堆栈组成,另外线程是进程的实体,是被系统独立调试的分派的基本单元. 线程是程序中一个单一的顺序控制流程.进程