一、创建线程池的方式一般有两种:
通过Executors工厂方法创建
通过newThreadPoolExecutor(intcorePoolSize,intmaximumPoolSize,longkeepAliveTime,TimeUnitunit,BlockingQueue<Runnable>workQueue,newThreadFactoryBuilder().setNameFormat(“thread-name-%”).build(),newThreadPoolExecutor.AbortPolicy())
二、通过Executors工厂创建1. Executors.newSingleThreadExecutor()
这个线程池只有一个核心线程在工作,也就是相当于单线程串行执行所有任务。如果这个唯一的线程因为异常结束,那么会有一个新的线程来替代它。此线程池保证所有任务的执行顺序按照任务的提交顺序执行。
public static ExecutorService newSingleThreadExecutor() {
return new FinalizableDelegatedExecutorService
(new ThreadPoolExecutor(1, 1,
0L, TimeUnit.MILLISECONDS,
new LinkedBlockingQueue<Runnable>()));
}
corePoolSize:1,只有一个核心线程在工作
maximumPoolSize:1
keepAliveTime:0L
TimeUnit:TimeUnit.MILLISECONDS时间单位是毫秒
workQueue:new LinkedBlockingQueue(),其缓冲队列是无界的
2. Executors.newFixedThreadPool(n)
FixedThreadPool 是固定大小的线程池,只有核心线程。每次提交一个任务就创建一个线程,直到线程达到线程池的最大大小。线程池的大小一旦达到最大值就会保持不变,如果某个线程因为执行异常而结束,那么线程池会补充一个新线程。FixedThreadPool 多数针对一些很稳定很固定的正规并发线程,多用于服务器。
public static ExecutorService newFixedThreadPool(int nThreads) {
return new ThreadPoolExecutor(nThreads, nThreads,
0L, TimeUnit.MILLISECONDS,
new LinkedBlockingQueue<Runnable>());
}
corePoolSize:nThreads
maximumPoolSize:nThreads
keepAliveTime:0L
TimeUnit:TimeUnit.MILLISECONDS时间单位是毫秒
workQueue:new LinkedBlockingQueue(),其缓冲队列是无界的
3. Executors.newCachedThreadPool()
CachedThreadPool 是无界线程池,如果线程池的大小超过了处理任务所需要的线程,那么就会回收部分空闲(60 秒不执行任务)线程,当任务数增加时,此线程池又可以智能的添加新线程来处理任务。线程池大小完全依赖于操作系统(或者说 JVM)能够创建的最大线程大小。SynchronousQueue 是一个是缓冲区为 1 的阻塞队列。缓存型池子通常用于执行一些生存期很短的异步型任务,因此在一些面向连接的 daemon 型 SERVER 中用得不多。但对于生存期短的异步任务,它是 Executor 的首选。
public static ExecutorService newCachedThreadPool() {
return new ThreadPoolExecutor(0, Integer.MAX_VALUE,
60L, TimeUnit.SECONDS,
new SynchronousQueue<Runnable>());
}
corePoolSize:0
maximumPoolSize:Integer.MAX_VALUE
keepAliveTime:60L
TimeUnit:TimeUnit.SECONDS时间单位是秒
workQueue:new SynchronousQueue(),一个是缓冲区为 1 的阻塞队列。
4. Executors.newScheduledThreadPool(n)
ScheduledThreadPool核心线程池固定,大小无限的线程池。此线程池支持定时以及周期性执行任务的需求。创建一个周期性执行任务的线程池。如果闲置,非核心线程池会在 DEFAULT_KEEPALIVEMILLIS 时间内回收。
public ScheduledThreadPoolExecutor(int corePoolSize) {
super(corePoolSize, Integer.MAX_VALUE, 0, NANOSECONDS,
new DelayedWorkQueue());
}
corePoolSize:corePoolSize
maximumPoolSize:Integer.MAX_VALUE
keepAliveTime:DEFAULTKEEPALIVEMILLIS
workQueue:new DelayedWorkQueue()
三、通过new ThreadPoolExecutor(coreThreadSize, max… …)
具体的详情请看之前的文章线程池的理解以及使用
Java技术债务
JVM内存泄漏和内存溢出的原因JVM常用监控工具解释以及使用
Redis 常见面试题(一)
ClickHouse之MaterializeMySQL引擎(十)
三种实现分布式锁的实现与区别
线程池的理解以及使用