Java岗大厂面试百日冲刺【Day47】— 并发编程4

转载自: Java岗大厂面试百日冲刺【Day47】— 并发编程4

本文已获得原作者 _陈哈哈 授权并经过重新整理规划后发布。

本栏目Java开发岗高频面试题主要出自以下各技术栈：Java基础知识、集合容器、并发编程、JVM、Spring全家桶、MyBatis等ORMapping框架、MySQL数据库、Redis缓存、RabbitMQ消息队列、Linux操作技巧等。

  • 在《阿里Java开发代码规范》中表示，线程资源必须通过线程池提供，不允许在应用中自行显式创建线程。即在使用多线程时，均要通过线程池创建。

InterviewForJavaByThreeQuestionsADay47-01.webp

面试题1：说一下线程池都是怎么创建的？

线程池可以自动创建也可以手动创建。

自动创建线程池

自动创建体现在Executors工具类中，常见的可以创建newFixedThreadPool、newCachedThreadPool、newSingleThreadExecutor、newScheduledThreadPool；

public static ExecutorService newFixedThreadPool(int var0) {
	return new ThreadPoolExecutor(var0, var0, 0L, TimeUnit.MILLISECONDS, new LinkedBlockingQueue());
}
	
public static ExecutorService newSingleThreadExecutor() {
	return new Executors.FinalizableDelegatedExecutorService(new ThreadPoolExecutor(1, 1, 0L, TimeUnit.MILLISECONDS, new LinkedBlockingQueue()));
}

public static ExecutorService newCachedThreadPool() {
	return new ThreadPoolExecutor(0, 2147483647, 60L, TimeUnit.SECONDS, new SynchronousQueue());
}

public static ScheduledExecutorService newScheduledThreadPool(int var0) {
	return new ScheduledThreadPoolExecutor(var0);
}

手动创建线程池(推荐)

手动创建体现在可以灵活设置线程池的各个参数，体现在代码中即ThreadPoolExecutor类构造器上各个实参的不同：

/**
 * @Description 配置线程池实例，用于调用
 */
@Configuration
public class ThreadPoolConfig {
    @Bean(value = "threadPoolInstance")
    public ExecutorService createThreadPoolInstance() {
	
        //通过guava类库的ThreadFactoryBuilder来实现线程工厂类并设置线程名称
        ThreadFactory threadFactory = new ThreadFactoryBuilder().setNameFormat("thread-pool-%d").build();
        ExecutorService threadPool = new ThreadPoolExecutor(10, 16, 60L, TimeUnit.SECONDS, new ArrayBlockingQueue<Runnable>(100), threadFactory, new ThreadPoolExecutor.AbortPolicy());
        return threadPool;
    }
}

//通过name=threadPoolInstance引用线程池实例
@Resource(name = "threadPoolInstance")
private ExecutorService executorService;
 
@Override
public void spikeConsumer() {
	// 线程池启动线程
	executorService.execute(new Runnable() {
	@Override
	public void run() {
		// 可执行代码块儿
	}});
}

InterviewForJavaByThreeQuestionsADay47-02.webp

追问1：线程池都有哪些参数？

// 默认拒绝策略为 AbortPolicy
public ThreadPoolExecutor(int corePoolSize,
                           int maximumPoolSize,
                           long keepAliveTime,
                           TimeUnit unit,
                           BlockingQueue<Runnable> workQueue,
                           ThreadFactory threadFactory,
                           RejectedExecutionHandler handler) {}
  • corePoolSize：核心线程数，也是线程池中常驻的线程数，线程池初始化时默认是没有线程的，当任务来临时才开始创建线程去执行任务
  • maximumPoolSize：最大线程数，在核心线程数的基础上可能会额外增加一些非核心线程，需要注意的是只有当workQueue队列填满时才会创建多于corePoolSize的线程(线程池总线程数不超过maxPoolSize)
  • keepAliveTime：非核心线程的空闲时间超过keepAliveTime就会被自动终止回收掉，注意当corePoolSize=maxPoolSize时，keepAliveTime参数也就不起作用了(因为不存在非核心线程)；
  • unit：keepAliveTime的时间单位
  • workQueue：用于保存任务的队列，可以为无界、有界、同步移交三种队列类型之一，当池子里的工作线程数大于corePoolSize时，这时新进来的任务会被放到队列中
  • threadFactory：创建线程的工厂类，默认使用Executors.defaultThreadFactory()，也可以使用guava库的ThreadFactoryBuilder来创建
  • handler：线程池无法继续接收任务(队列已满且线程数达到maximunPoolSize)时的饱和策略，取值有AbortPolicy、CallerRunsPolicy、DiscardOldestPolicy、DiscardPolicy
// 默认拒绝策略为 AbortPolicy
ExecutorService threadPool = new ThreadPoolExecutor(10, 20, 60L, TimeUnit.SECONDS, new ArrayBlockingQueue<Runnable>(100), threadFactory, new ThreadPoolExecutor.AbortPolicy());

追问2：线程池都有哪几种工作队列（WorkQueue）？分别有什么特点？

常用

  • ArrayBlockintQueue(有界队列)：基于数组的有限阻塞队列，先进先出(FIFO)，插入数据和取出数据公用一个锁对象；
  • LinkedBlockingQueue(无界队列)：基于链表的无限阻塞队列，先进先出(FIFO)，当请求越来越多时(任务处理速度跟不上任务提交速度造成请求堆积)可能导致内存占用过多或OOM，newFixedThreadPool 和 newSingleThreadExecutor 使用这个队列；
  • SynchronousQueue(同步移交队列)：不存储元素的阻塞队列，插入操作必须等待一个线程调用移除操作，否则一直会阻塞。newCachedTHreadPool 使用这个队列

不常用

  • PriorityBlockingQueue：有优先级的无限阻塞队列，基于最小二叉堆实现
  • DelayedWorkQueue：每个元素指定延时时间，只有当时间到了才能从队列中获取该元素，是一个无限队列。

面试题2：线程池提交一个任务经过哪些步骤？

InterviewForJavaByThreeQuestionsADay47-03.webp

线程池提交任务流程为:

  1. 当线程池新加入一个线程时，首先判断当前线程数，是否小于corePoolSize（核心线程数），如果小于，则执行步骤2，否则执行3；
  2. 创建新线程添加到线程池中，流程结束；
  3. 判断当前线程池等待队列是否已满，若已满，则跳转至步骤5；
  4. 加入等待队列，等待线程池空闲，流程结束；
  5. 判断当前线程数是否已达到maximumPoolSize（最大线程数），若未达到，则跳转至步骤7；
  6. 执行线程池拒绝策略，流程结束；
  7. 创建一个新线程，执行任务；
  8. 流程结束；

比如现有一个线程池，corePoolSize=10，maxPoolSize=20，队列长度为100，那么当任务过来会先创建10个核心线程数，接下来进来的任务会进入到队列中直到队列满了，会创建额外的线程来执行任务(最多20个线程)，这个时候如果再来任务就会执行拒绝策略。

追问1：线程池的拒绝策略了解么？

  • AbortPolicy（默认）：中断直接抛异常
  • DiscardPolicy：默默丢弃任务，不进行任何通知
  • DiscardOldestPolicy：丢弃掉在队列中存在时间最久的任务
  • CallerRunsPolicy：让提交任务的线程去执行任务

面试题3：关闭线程池的方式都有哪些？

  • shutdownNow()：立即关闭线程池(强制)，正在执行中的及队列中的任务会被中断，同时该方法会返回被中断的队列中的任务列表；
  • shutdown()：平滑关闭线程池，正在执行中的及队列中的任务能执行完成，后续进来的任务会被执行拒绝策略；
  • isTerminated()：当正在执行的任务及对列中的任务全部都执行完就会返回，return true；