Java 面试系列：线程池之 Executors + 面试题
2021-02-01 本文已影响0人
you的日常
线程池的创建分为两种方式：ThreadPoolExecutor 和 Executors，本节重点来看 Executors 是如何创建线程池的。
Executors 可以创建以下六种线程池。
- FixedThreadPool(n)：创建一个数量固定的线程池，超出的任务会在队列中等待空闲的线程，可用于控制程序的最大并发数。
- CachedThreadPool()：短时间内处理大量工作的线程池，会根据任务数量产生对应的线程，并试图缓存线程以便重复使用，如果限制 60 秒没被使用，则会被移除缓存。
- SingleThreadExecutor()：创建一个单线程线程池。
- ScheduledThreadPool(n)：创建一个数量固定的线程池，支持执行定时性或周期性任务。
- SingleThreadScheduledExecutor()：此线程池就是单线程的 newScheduledThreadPool。
- WorkStealingPool(n)：Java 8 新增创建线程池的方法，创建时如果不设置任何参数，则以当前机器处理器个数作为线程个数，
此线程池会并行处理任务，不能保证执行顺序。
下面分别来看以上六种线程池的具体代码使用。
线程池的具体使用
FixedThreadPool 使用
创建固定个数的线程池，具体示例如下：
ExecutorService fixedThreadPool = Executors.newFixedThreadPool(2);
for (int i = 0; i < 3; i++) {
fixedThreadPool.execute(() -> {
System.out.println("CurrentTime - " + LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")));
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
e.printStackTrace();
}
});
}
以上程序执行结果如下：
CurrentTime - 2020-12-27 20:58:58
CurrentTime - 2020-12-27 20:58:58
CurrentTime - 2020-12-27 20:58:59
根据执行结果可以看出，newFixedThreadPool(2) 确实是创建了两个线程，在执行了一轮（2 次）之后，停了一秒，有了空闲线程，才执行第三次。
CachedThreadPool 使用
根据实际需要自动创建带缓存功能的线程池，具体代码如下：
ExecutorService cachedThreadPool = Executors.newCachedThreadPool();
for (int i = 0; i < 10; i++) {
cachedThreadPool.execute(() -> {
System.out.println("CurrentTime - " +
LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")));
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
e.printStackTrace();
}
});
}
以上程序执行结果如下：
CurrentTime - 2020-12-27 21:24:46
CurrentTime - 2020-12-27 21:24:46
CurrentTime - 2020-12-27 21:24:46
CurrentTime - 2020-12-27 21:24:46
CurrentTime - 2020-12-27 21:24:46
CurrentTime - 2020-12-27 21:24:46
CurrentTime - 2020-12-27 21:24:46
CurrentTime - 2020-12-27 21:24:46
CurrentTime - 2020-12-27 21:24:46
CurrentTime - 2020-12-27 21:24:46
根据执行结果可以看出，newCachedThreadPool 在短时间内会创建多个线程来处理对应的任务，并试图把它们进行缓存以便重复使用。
SingleThreadExecutor 使用
创建单个线程的线程池，具体代码如下：
ExecutorService singleThreadExecutor = Executors.newSingleThreadExecutor();
for (int i = 0; i < 3; i++) {
singleThreadExecutor.execute(() -> {
System.out.println("CurrentTime - " +
LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")));
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
e.printStackTrace();
}
});
}
以上程序执行结果如下：
CurrentTime - 2020-12-27 21:43:34
CurrentTime - 2020-12-27 21:43:35
CurrentTime - 2020-12-27 21:43:36
ScheduledThreadPool 使用
创建一个可以执行周期性任务的线程池，具体代码如下：
