java android ExecutorService 线程池解析


ExecutorService:

它也是一个接口,它扩展自Executor接口,Executor接口更像一个抽象的命令模式,仅有一个方法:execute(runnable);Executor接口简单,可是非常重要,重要在这样的设计的模式上。。Java5以后,通过Executor来启动线程比用Thread的start()更好。在新特征中,能够非常easy控制线程的启动、运行和关闭过程,还能够非常easy使用线程池的特性。


几种不同的ExecutorService线程池对象 

1.newCachedThreadPool() 
-缓存型池子,先查看池中有没有曾经建立的线程,假设有,就reuse.假设没有,就建一个新的线程增加池中 
-能reuse的线程,必须是timeout IDLE内的池中线程,缺省timeout是60s,超过这个IDLE时长,线程实例将被终止及移出池。 
  注意,放入CachedThreadPool的线程不必操心其结束,超过TIMEOUT不活动,其会自己主动被终止。 
2. newFixedThreadPool 
-newFixedThreadPool与cacheThreadPool差点儿相同,也是能reuse就用,但不能随时建新的线程 
-其独特之处:随意时间点,最多仅仅能有固定数目的活动线程存在,此时假设有新的线程要建立,仅仅能放在另外的队列中等待,直到当前的线程中某个线程终止直接被移出池子 
-和cacheThreadPool不同,FixedThreadPool没有IDLE机制(可能也有,但既然文档没提,肯定非常长,类似依赖上层的TCP或UDP IDLE机制之类的),所以FixedThreadPool多数针对一些非常稳定非常固定的正规并发线程,多用于server 
-从方法的源码看,cache池和fixed 池调用的是同一个底层池,仅仅只是參数不同: 
fixed池线程数固定,而且是0秒IDLE(无IDLE) 
cache池线程数支持0-Integer.MAX_VALUE(显然全然没考虑主机的资源承受能力),60秒IDLE  

3.ScheduledThreadPool 
-调度型线程池 
-这个池子里的线程能够按schedule依次delay运行,或周期运行 

4.SingleThreadExecutor 
-单例线程,随意时间池中仅仅能有一个线程 
-用的是和cache池和fixed池同样的底层池,但线程数目是1-1,0秒IDLE(无IDLE) 


   

1、ExecutorService:

是一个接口,继承了Executor:

public interface ExecutorService extends Executor {
}

2、Executor:

而Executor亦是一个接口,该接口仅仅包括了一个方法:

void execute(Runnable command);

3、Executors:

该类是一个辅助类,此包中所定义的 Executor、ExecutorService、ScheduledExecutorService、ThreadFactory 和 Callable 类的工厂和有用方法。

此类支持下面各种方法:

• 创建并返回设置有经常使用配置字符串的 ExecutorService 的方法。
• 创建并返回设置有经常使用配置字符串的 ScheduledExecutorService 的方法。
• 创建并返回“包装的”ExecutorService 方法,它通过使特定于实现的方法不可訪问来禁用又一次配置。
• 创建并返回 ThreadFactory 的方法,它可将新创建的线程设置为已知的状态。
• 创建并返回非闭包形式的 Callable 的方法,这样可将其用于须要 Callable 的运行方法中。

4、创建ExecutorService的方法:

newFixedThreadPool()

创建一个可重用固定线程数的线程池,以共享的无界队列方式来执行这些线程。

5、ExecutorService的方法:

shutdown

void shutdown()
启动一次顺序关闭,运行曾经提交的任务,但不接受新任务。假设已经关闭,则调用没有其它作用。 

抛出:
SecurityException – 假设安全管理器存在而且关闭,此 ExecutorService 可能操作某些不同意调用者改动的线程(由于它没有保持 RuntimePermission(“modifyThread”)),或者安全管理器的 checkAccess 方法拒绝訪问。

启动一次顺序关闭,运行曾经提交的任务,但不接受新任务。假设已经关闭,则调用没有其它作用。

awaitTermination

boolean awaitTermination(long timeout,
                         TimeUnit unit)
                         throws InterruptedException
请求关闭、发生超时或者当前线程中断,不管哪一个首先发生之后,都将导致堵塞,直到全部任务完毕运行。 

參数:
timeout – 最长等待时间
unit – timeout 參数的时间单位
返回:
假设此运行程序终止,则返回 true;假设终止前超时期满,则返回 false
抛出:
InterruptedException – 假设等待时发生中断

请求关闭、发生超时或者当前线程中断,不管哪一个首先发生之后,都将导致堵塞,直到全部任务完毕运行。既是等待全部子线程运行结束。

execute

void execute(Runnable command)
在未来某个时间运行给定的命令。该命令可能在新的线程、已入池的线程或者正调用的线程中运行,这由 Executor实现决定。 

參数:
command – 可执行的任务
抛出:
RejectedExecutionException – 假设不能接受执行此任务。
NullPointerException – 假设命令为 null

在未来某个时间运行给定的命令。该命令可能在新的线程、已入池的线程或者正调用的线程中运行,这由 Executor 实现决定。

submit

Future<?> submit(Runnable task)
提交一个 Runnable 任务用于运行,并返回一个表示该任务的 Future。该 Future 的 get 方法在成功 完毕时将会返回null。 

參数:
task – 要提交的任务
返回:
表示任务等待完毕的 Future
抛出:
RejectedExecutionException – 假设任务无法安排运行
NullPointerException – 假设该任务为 null

提交一个 Runnable 任务用于运行,并返回一个表示该任务的 Future。该 Future 的 get 方法在成功 完毕时将会返回 null。

6、以下是相关的使用样例:

public class ExecutorServiceTest {

    public static void main(String[] args) throws IOException, InterruptedException {
        // 创建一个固定大小的线程池
        ExecutorService service = Executors.newFixedThreadPool(3);
        for (int i = 0; i < 10; i++) {
            System.out.println("创建线程" + i);
            Runnable run = new Runnable() {
                @Override
                public void run() {
                    System.out.println("启动线程");
                }
            };
            // 在未来某个时间运行给定的命令
            service.execute(run);
        }
        // 关闭启动线程
        service.shutdown();
        // 等待子线程结束,再继续运行以下的代码
        service.awaitTermination(Long.MAX_VALUE, TimeUnit.DAYS);
        System.out.println("all thread complete");
    }
}

能够发现线程被循环创建,可是启动线程却不是连续的,而是由ExecutorService决定的。

參考:http://www.itzhai.com/the-executorservice-common-method-newfixedthreadpool-of-create-fixed-size-thread-pool.html

如有问题请留言,转载注明出处。


    原文作者:mengfanrong
    原文地址: http://www.cnblogs.com/mengfanrong/p/3762292.html
    本文转自网络文章,转载此文章仅为分享知识,如有侵权,请联系博主进行删除。
点赞