Java——多线程高并发系列之线程池（Executor）的理解与使用

package com.szh.threadpool;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.TimeUnit;
/**
 * 线程池的基本使用
 */
public class Test01 {
    public static void main(String[] args) {
        //创建有 5 个线程大小的线程池
        ExecutorService executorService= Executors.newFixedThreadPool(5);
        //向线程池中提交13个任务, 这13个任务存储到线程池的阻塞队列中,
        //线程池中这 5 个线程就从阻塞队列中取任务执行
        for (int i = 0; i < 13; i++) {
            executorService.execute(new Runnable() {
                @Override
                public void run() {
                    System.out.println(Thread.currentThread().getId() + " 编号的线程正在执行任务，开始时间："
                                    + System.currentTimeMillis());
                    try {
                        TimeUnit.MILLISECONDS.sleep(1000 * 3); //模拟任务执行时长
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                }
            });
        }
        //关闭线程池
        executorService.shutdown();
    }
}

package com.szh.threadpool;
import java.util.concurrent.*;
/**
 *
 */
public class Test03 {
    public static void main(String[] args) {
        //用一个银行的例子来讲解这七大参数
        ExecutorService threadPool=new ThreadPoolExecutor(
                3, //指定线程池中核心线程的数量（两个常开业务窗口）
                5, //指定线程池中最大线程数量（总共五个窗口）
                2, //当线程池线程的数量超过 corePoolSize 时, 多余的空闲线程的存活时长, 即空闲线程在多长时长内销毁
                TimeUnit.SECONDS, //keepAliveTime 的时长单位
                new LinkedBlockingQueue<>(3), //任务队列, 把任务提交到该任务队列中等待执行（银行候客区的大小）
                Executors.defaultThreadFactory(), //默认线程池工厂
                new ThreadPoolExecutor.AbortPolicy()); //拒绝策略, 当任务太多来不及处理时, 如何拒绝
                /*
                    默认是 AbortPolicy() 会抛出异常
                    CallerRunsPolicy() 只要线程池没关闭, 会在调用者线程中运行当前被丢弃的任务
                    DiscardPolicy() 直接丢弃这个无法处理的任务
                    DiscardOldestPolicy() 将任务队列中最老的任务丢弃, 尝试再次提交新任务
                 */
        //向线程池中提交9个任务
        for (int i = 0; i < 9; i++) {
            threadPool.execute(new Runnable() {
                @Override
                public void run() {
                    System.out.println(Thread.currentThread().getName());
                }
            });
        }
        //关闭连接
        threadPool.shutdown();
    }
}

int corePoolSize //核心线程池数量
int maximumPoolSize //最大线程池数量
long keepAliveTime //超时存活时间
TimeUnit unit //超时单位
BlockingQueue<Runnable> workQueue //阻塞队列
ThreadFactory threadFactory //线程工厂，用于创建线程
RejectedExecutionHandler handler //拒绝策略