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

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