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

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

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

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

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

面试题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() {
		// 可执行代码块儿
	}});
}

追问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 使用这个队列

不常用