Java笔试面试-Executors

我不是女神ヾ 2021-09-23 08:02 351阅读 0赞

## Executors 可以创建以下六种线程池： ##

*  FixedThreadPool(n)：创建一个数量固定的线程池，超出的任务会在队列中等待空闲的线程，可用于控制程序的最大并发数。
 *  CachedThreadPool()：短时间内处理大量工作的线程池，会根据任务数量产生对应的线程，并试图缓存线程以便重复使用，如果限制 60 秒没被使用，则会被移除缓存。
 *  SingleThreadExecutor()：创建一个单线程线程池。
 *  ScheduledThreadPool(n)：创建一个数量固定的线程池，支持执行定时性或周期性任务。
 *  SingleThreadScheduledExecutor()：此线程池就是单线程的 newScheduledThreadPool。
 *  WorkStealingPool(n)：Java 8 新增创建线程池的方法，创建时如果不设置任何参数，则以当前机器处理器个数作为线程个数，此线程池会并行处理任务，不能保证执行顺序。

**1.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 - 2019-06-27 20:58:58
    
    CurrentTime - 2019-06-27 20:58:58
    
    CurrentTime - 2019-06-27 20:58:59

根据执行结果可以看出，newFixedThreadPool(2) 确实是创建了两个线程，在执行了一轮（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 - 2019-06-27 21:24:46
    
    CurrentTime - 2019-06-27 21:24:46
    
    CurrentTime - 2019-06-27 21:24:46
    
    CurrentTime - 2019-06-27 21:24:46
    
    CurrentTime - 2019-06-27 21:24:46
    
    CurrentTime - 2019-06-27 21:24:46
    
    CurrentTime - 2019-06-27 21:24:46
    
    CurrentTime - 2019-06-27 21:24:46
    
    CurrentTime - 2019-06-27 21:24:46
    
    CurrentTime - 2019-06-27 21:24:46

根据执行结果可以看出，newCachedThreadPool 在短时间内会创建多个线程来处理对应的任务，并试图把它们进行缓存以便重复使用。

**3.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 - 2019-06-27 21:43:34
    
    CurrentTime - 2019-06-27 21:43:35
    
    CurrentTime - 2019-06-27 21:43:36

**4.ScheduledThreadPool 使用**

创建一个可以执行周期性任务的线程池，具体代码如下：

ScheduledExecutorService scheduledThreadPool = Executors.newScheduledThreadPool(2);
    scheduledThreadPool.schedule(() -> {
        System.out.println("ThreadPool：" + LocalDateTime.now());
    }, 1L, TimeUnit.SECONDS);
    System.out.println("CurrentTime：" + LocalDateTime.now());

以上程序执行结果如下：

CurrentTime：2019-06-27T21:54:21.881
    
    ThreadPool：2019-06-27T21:54:22.845

根据执行结果可以看出，我们设置的 1 秒后执行的任务生效了。

**5.SingleThreadScheduledExecutor 使用**

创建一个可以执行周期性任务的单线程池，具体代码如下：

ScheduledExecutorService singleThreadScheduledExecutor = Executors.newSingleThreadScheduledExecutor();
    singleThreadScheduledExecutor.schedule(() -> {
        System.out.println("ThreadPool：" + LocalDateTime.now());
    }, 1L, TimeUnit.SECONDS);
    System.out.println("CurrentTime：" + LocalDateTime.now());

**6.WorkStealingPool 使用**

Java 8 新增的创建线程池的方式，可根据当前电脑 CPU 处理器数量生成相应个数的线程池，使用代码如下：

ExecutorService workStealingPool = Executors.newWorkStealingPool();
    for (int i = 0; i < 5; i++) {
        int finalNumber = i;
        workStealingPool.execute(() -> {
            System.out.println("I：" + finalNumber);
        });
    }
    Thread.sleep(5000);

以上程序执行结果如下：

I：0
    
    I：3
    
    I：2
    
    I：1
    
    I：4

根据执行结果可以看出，newWorkStealingPool 是并行处理任务的，并不能保证执行顺序。

**ThreadPoolExecutor VS Executors**  
  ThreadPoolExecutor 和 Executors 都是用来创建线程池的，其中 ThreadPoolExecutor 创建线程池的方式相对传统，而 Executors 提供了更多的线程池类型（6 种），但很不幸的消息是在实际开发中并不推荐使用 Executors 的方式来创建线程池。

## 笔试面试题 ##

**1.以下程序会输出什么结果？**

public static void main(String[] args) {
        ExecutorService workStealingPool = Executors.newWorkStealingPool();
        for (int i = 0; i < 5; i++) {
            int finalNumber = i;
            workStealingPool.execute(() -> {
                System.out.print(finalNumber);
            });
        }
    }

A：不输出任何结果  
B：输出 0 到 9 有序数字  
C：输出 0 到 9 无需数字  
D：以上全对

答：A  
题目解析：newWorkStealingPool 内部实现是 ForkJoinPool，它会随着主程序的退出而退出，因为主程序没有任何休眠和等待操作，程序会一闪而过，不会执行任何信息，所以也就不会输出任何结果。

**2.Executors 能创建单线程的线程池吗？怎么创建？**

答：Executors 可以创建单线程线程池，创建分为两种方式：

*  Executors.newSingleThreadExecutor()：创建一个单线程线程池。
 *  Executors.newSingleThreadScheduledExecutor()：创建一个可以执行周期性任务的单线程池。

**3.Executors 中哪个线程适合执行短时间内大量任务？**

答：newCachedThreadPool() 适合处理大量短时间工作任务。它会试图缓存线程并重用，如果没有缓存任务就会新创建任务，如果线程的限制时间超过六十秒，则会被移除线程池，因此它比较适合短时间内处理大量任务。

**4.可以执行周期性任务的线程池都有哪些？**

答：可执行周期性任务的线程池有两个，分别是：newScheduledThreadPool() 和 newSingleThreadScheduledExecutor()，其中 newSingleThreadScheduledExecutor() 是 newScheduledThreadPool() 的单线程版本。

**5.JDK 8 新增了什么线程池？有什么特点？**

答：JDK 8 新增的线程池是 newWorkStealingPool(n)，如果不指定并发数（也就是不指定 n），newWorkStealingPool() 会根据当前 CPU 处理器数量生成相应个数的线程池。它的特点是并行处理任务的，不能保证任务的执行顺序。

**6.newFixedThreadPool 和 ThreadPoolExecutor 有什么关系？**

答：newFixedThreadPool 是 ThreadPoolExecutor 包装，newFixedThreadPool 底层也是通过 ThreadPoolExecutor 实现的。

newFixedThreadPool 的实现源码如下：

public static ExecutorService newFixedThreadPool(int nThreads, ThreadFactory threadFactory) {
        return new ThreadPoolExecutor(nThreads, nThreads,
                                      0L, TimeUnit.MILLISECONDS,
                                      new LinkedBlockingQueue<Runnable>(),
                                      threadFactory);
    }

**7.单线程的线程池存在的意义是什么？**

答：单线程线程池提供了队列功能，如果有多个任务会排队执行，可以保证任务执行的顺序性。单线程线程池也可以重复利用已有线程，减低系统创建和销毁线程的性能开销。

**8.线程池为什么建议使用 ThreadPoolExecutor 创建，而非 Executors？**

答：使用 ThreadPoolExecutor 能让开发者更加明确线程池的运行规则，避免资源耗尽的风险

Executors 返回线程池的缺点如下：

*  FixedThreadPool 和 SingleThreadPool 允许请求队列长度为 Integer.MAX\_VALUE，可能会堆积大量请求，可能会导致内存溢出；
 *  CachedThreadPool 和 ScheduledThreadPool 允许创建线程数量为 Integer.MAX\_VALUE，创建大量线程，可能会导致内存溢出。