Java 线程池的基本用法

线程池

池化思想：线程池、数据连接池等，比如我们 Spark 的 Executor 就是典型的线程池，用户在启动 Spark 作业的同时启动线程池，这样 Spark 的 Task 就可以直接获取资源，而不用像 MR 程序那样等待容器上的进程开启了。

如果不使用线程池的话，我们需要：

手动创建线程对象
执行任务
执行完毕，回收资源

优点：

提高线程的利用率
提高程序的响应速度（线程对象提前创建好的，节省了创建和销毁的开销）
便于统一管理线程对象
可以控制最大的并发数

1、Java 创建线程池示例

1.1、构造参数解释

线程池就好比我们的银行，它有很多个接待客人的柜台（一个柜台就是一个线程，用来执行任务）和用来供客人等待的座位（等待的执行的任务）。上面的图中，我们有 5 个柜台（对应第2个参数：maximumPoolSize）；而其中绿色的三个柜台代表常驻柜台（也就是一直都有人，对应第1个参数：corePoolSize）；红色的柜台代表预备柜台，也就是当业务繁忙的时候，最多还可以打电话摇两个人来（maximumPoolSize - corePoolSize）；但是摇人来帮忙是有时效性的，如果帮完忙一段时间（取决于第3个和第4个参数）没有活干，这些线程就会被释放；摇人的方式取决于第6个参数（下面我们是通过默认的线程工厂来再创建线程的）；蓝色的等候区区域代表座位（可允许等待的任务数量），当柜台前和座位都满了的时候，如果再有任务进来就会被拒绝，具体的拒绝方式取决于第7个参数，下面我们给出的拒绝策略是直接报错：

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

public class TestThreadPool {
	public static void main(String[] args) {
		// 1.核心线程数 2.最大线程数 3.存活时间 4.时间单位 5.等待队列 6.线程工厂 7.拒绝策略(直接抛异常)
		ExecutorService executorService = new ThreadPoolExecutor(3, 5, 10, TimeUnit.SECONDS, new ArrayBlockingQueue<>(3),Executors.defaultThreadFactory(),new ThreadPoolExecutor.AbortPolicy());
		for (int i = 0; i < 9; i++) {
			executorService.execute(()->{
				System.out.println(Thread.currentThread().getName()+"正在工作");
			});
		}
        // 关闭线程池
		executorService.shutdown();
	}
}