完全解析Android多线程中线程池ThreadPool的原理和使用

// 创建线程池对象如下
// 通过 构造方法 配置核心参数
  Executor executor = new ThreadPoolExecutor( 
                       CORE_POOL_SIZE,
                       MAXIMUM_POOL_SIZE,
                       KEEP_ALIVE,
                       TimeUnit.SECONDS, 
                       sPoolWorkQueue,
                       sThreadFactory 
                        );

// 构造函数源码分析
  public ThreadPoolExecutor (int corePoolSize,
                int maximumPoolSize,
                long keepAliveTime,
                TimeUnit unit,
                BlockingQueue<Runnable workQueue>,
                ThreadFactory threadFactory )

// 1. 创建线程池
  // 创建时，通过配置线程池的参数，从而实现自己所需的线程池
  Executor threadPool = new ThreadPoolExecutor(
                       CORE_POOL_SIZE,
                       MAXIMUM_POOL_SIZE,
                       KEEP_ALIVE,
                       TimeUnit.SECONDS,
                       sPoolWorkQueue,
                       sThreadFactory
                       );
  // 注：在Java中，已内置4种常见线程池，下面会详细说明

// 2. 向线程池提交任务：execute（）
  // 说明：传入 Runnable对象
    threadPool.execute(new Runnable() {
      @Override
      public void run() {
        ... // 线程执行任务
      }
    });

// 3. 关闭线程池shutdown() 
 threadPool.shutdown();

 // 关闭线程的原理
 // a. 遍历线程池中的所有工作线程
 // b. 逐个调用线程的interrupt（）中断线程（注：无法响应中断的任务可能永远无法终止）

 // 也可调用shutdownNow（）关闭线程：threadPool.shutdownNow（）
 // 二者区别：
 // shutdown：设置 线程池的状态 为 SHUTDOWN，然后中断所有没有正在执行任务的线程
 // shutdownNow：设置 线程池的状态 为 STOP，然后尝试停止所有的正在执行或暂停任务的线程，并返回等待执行任务的列表
 // 使用建议：一般调用shutdown（）关闭线程池；若任务不一定要执行完，则调用shutdownNow（）

// 1. 创建定长线程池对象 & 设置线程池线程数量固定为3
ExecutorService fixedThreadPool = Executors.newFixedThreadPool(3);

// 2. 创建好Runnable类线程对象 & 需执行的任务
Runnable task =new Runnable(){
 public void run(){
  System.out.println("执行任务啦");
   }
  };

// 3. 向线程池提交任务：execute（）
fixedThreadPool.execute(task);

// 4. 关闭线程池
fixedThreadPool.shutdown();

// 1. 创建 定时线程池对象 & 设置线程池线程数量固定为5
ScheduledExecutorService scheduledThreadPool = Executors.newScheduledThreadPool(5);

// 2. 创建好Runnable类线程对象 & 需执行的任务
Runnable task =new Runnable(){
    public void run(){
       System.out.println("执行任务啦");
     }
  };
// 3. 向线程池提交任务：schedule（）
scheduledThreadPool.schedule(task, 1, TimeUnit.SECONDS); // 延迟1s后执行任务
scheduledThreadPool.scheduleAtFixedRate(task,10,1000,TimeUnit.MILLISECONDS);// 延迟10ms后、每隔1000ms执行任务

// 4. 关闭线程池
scheduledThreadPool.shutdown();

// 1. 创建可缓存线程池对象
ExecutorService cachedThreadPool = Executors.newCachedThreadPool();

// 2. 创建好Runnable类线程对象 & 需执行的任务
Runnable task =new Runnable(){
 public void run(){
    System.out.println("执行任务啦");
      }
  };

// 3. 向线程池提交任务：execute（）
cachedThreadPool.execute(task);

// 4. 关闭线程池
cachedThreadPool.shutdown();

//当执行第二个任务时第一个任务已经完成
//那么会复用执行第一个任务的线程，而不用每次新建线程。

// 1. 创建单线程化线程池
ExecutorService singleThreadExecutor = Executors.newSingleThreadExecutor();

// 2. 创建好Runnable类线程对象 & 需执行的任务
Runnable task =new Runnable(){
 public void run(){
    System.out.println("执行任务啦");
      }
  };

// 3. 向线程池提交任务：execute（）
singleThreadExecutor.execute(task);

// 4. 关闭线程池
singleThreadExecutor.shutdown();