6.4 ThreadPoolExecutor-Java语言基础8-Java多线程

当前位置:　首页>> 技术小册>> Java语言基础8-Java多线程

构造方法：
```bash
public ThreadPoolExecutor(int corePoolSize,
                          int maximumPoolSize,
                          long keepAliveTime,
                          TimeUnit unit,
                          BlockingQueue<Runnable> workQueue,
                          ThreadFactory threadFactory,
                          RejectedExecutionHandler handler) {
    ...
}
```

●  解释： 
  - corePoolSize ：核心线程数量。
  - maximumPoolSize ：线程池中的最大线程数量（核心线程数量 + 临时线程数量）。
  - keepAliveTime ：空闲时间值（也可以称为存活时间），即临时线程空闲多少时间被销毁，比如：1。
  - unit ：空闲时间单位（存活时间单位），即临时线程空闲多少时间被销毁，如：TimeUnit.SECONDS 表示秒。
  - workQueue ：任务队列（阻塞队列），如：20 个任务只有 10 个线程同时工作，那么多余的 10 个任务将放到任务队列中，等有线程空闲了，再从任务队列中取出任务继续执行。
  - threadFactory ：创建线程工厂，一般都是采用 Executors.defaultThreadFactory() 方式。
  - handler ：任务的拒绝策略，当任务太多（提交任务超过了线程池中的最大线程数量+任务队列的容量）的时候的解决方案。 
    ■ new ThreadPoolExecutor.AbortPolicy() ：默认的策略，丢弃任务并抛出 RejectedExecutionException 异常。
    ■ new ThreadPoolExecutor.DiscardPolicy() ：丢失任务，但是不抛出异常，不推荐。
    ■ new ThreadPoolExecutor.DiscardOldestPolicy() ：抛弃队列中等待最久的任务，然后将当前任务加入到队列中。
    ■ new ThreadPoolExecutor.CallerRunsPolicy() ：调用任务的run()方法绕过线程池直接执行。

●  示例：

```bash
package com.github.demo10;

import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.Executors;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;

/**
 * @author maxiaoke.com
 * @version 1.0
 */
public class Test {
    public static void main(String[] args) {
        // 参数1：核心线程数量
        // 参数2：最大线程数量
        // 参数3：空闲线程的最大存活时间
        // 参数4：时间单位
        // 参数5：任务队列
        // 参数6：创建线程工程
        // 参数7：任务的拒绝策略
        ThreadPoolExecutor pool = new ThreadPoolExecutor(2, 5, 2, TimeUnit.SECONDS, new ArrayBlockingQueue<>(10),
            Executors.defaultThreadFactory(), new ThreadPoolExecutor.AbortPolicy());

pool.submit(() -> System.out.println(Thread.currentThread().getName() + "：你好啊"));

pool.submit(() -> System.out.println(Thread.currentThread().getName() + "：我很好"));

pool.submit(() -> System.out.println(Thread.currentThread().getName() + "：哦"));

pool.submit(() -> System.out.println(Thread.currentThread().getName() + "：再见"));

pool.shutdown();
    }
}
```