java Executors工具类的相关方法使用创建
通过Executors类创建线程池
线程池的创建方式有很多种，可以通过Executors工具类创建多种模式的线程池，Executors工具类位于java.util.concurrent.locks包中，接下来解释其中的方法。
首先将线程池的七个参数标在这里： corePoolSize：表示线程池中核心线程的数量；
maximumPoolSize：表示线程池中最大线程数量；
keepAliveTime：针对救急线程的存活时间的变量，就是当线程数量超过线程池中的核心数量时，如果没有新的任务被提交，那么核心线程外的救急线程就会保持在keepAliveTime变量值之后被销毁，而不是立即销毁；
unit：也是针对救急线程，表示keepAliveTime的核心单位；
workQueue：表示线程池中的阻塞队列，阻塞队列中存储着等待执行的任务；
threadFactory：表示用来创建线程的线程工厂。创建线程池的时候，默认的线程工厂创建的线程具有相同的优先级，可以为线程起一个好名字；
handler：表示线程池的拒绝策略。当线程池中的阻塞队列满了的时候，线程数maximumPoolSize也达到了最大值，如果此时再有任务提交到线程池，线程池就会采取策略来拒绝任务的执行。
🎆newCachedThreadPool方法
调用Executors工具类的newCachedThreadPool方法可以创建一个可缓存的线程池，核心线程数为0，当线程池中的线程数量超过了运行任务所需要的线程数，那么可以回收空闲的线程，默认每60s回收；同时当任务增加的时候，线程池又可以创建新的线程来处理任务。
public static ExecutorService newCachedThreadPool() {
return new ThreadPoolExecutor(0, Integer.MAX_VALUE,
60L, TimeUnit.SECONDS,
new SynchronousQueue<Runnable>());
}
public static ExecutorService newCachedThreadPool(ThreadFactory threadFactory) {
return new ThreadPoolExecutor(0, Integer.MAX_VALUE,
60L, TimeUnit.SECONDS,
new SynchronousQueue<Runnable>(),
threadFactory);
}
🎊newFixThreadPool方法
调用Executors工具类的newFixThreadPool方法可以创建一个固定长度大小的线程池，线程池中的线程都是核心线程，也就是创建的线程池中的线程数量是固定的，能够控制线程池的最大并发数。
当向线程池提交任务时，如果线程池中有空闲的线程则会直接执行任务，如果没有空闲线程则会将任务放入阻塞队列中等待，有空闲线程的时候再去执行阻塞队列中的线程。
当线程池达到最大线程数时，线程数量会保持不变，一旦某个线程出现异常，线程池会补充一个线程。提交到线程池的任务过多可能会导致内存溢出。
public static ExecutorService newFixedThreadPool(int nThreads, ThreadFactory threadFactory) {
return new ThreadPoolExecutor(nThreads, nThreads,
0L, TimeUnit.MILLISECONDS,
new LinkedBlockingQueue<Runnable>(),
threadFactory);
}
🎍newScheduledThreadPool方法
调用Executors工具类的newScheduledThreadPool方法可以创建一个可以周期性执行任务的线程池，也能够定时执行任务。
public static ScheduledExecutorService newScheduledThreadPool(int corePoolSize) {
return new ScheduledThreadPoolExecutor(corePoolSize);
}
public static ScheduledExecutorService newScheduledThreadPool(
int corePoolSize, ThreadFactory threadFactory) {
return new ScheduledThreadPoolExecutor(corePoolSize, threadFactory);
}
🎠newSingleThreadExecutor方法
调用Executors工具类的newSingleThreadExecutor方法可以创建只有一个工作线程的线程池，相当于只有一个线程在工作。能够保证任务按照先进先出的顺序，或者优先级顺序执行任务。就像单线程在串行执行任务一样，但是也有些区别，如果这个唯一的线程出现了异常，线程池会创建一个新的线程来代替它。
public static ExecutorService newSingleThreadExecutor(ThreadFactory threadFactory) {
return new FinalizableDelegatedExecutorService
(new ThreadPoolExecutor(1, 1,
0L, TimeUnit.MILLISECONDS,
new LinkedBlockingQueue<Runnable>(),
threadFactory));
}
🎡newSingleThreadScheduledExecutor方法
调用Executors工具类的newSingleThreadScheduledExecutor方法可以创建只有一个工作线程，并且支持定时，周期性执行任务的线程池。
public static ScheduledExecutorService newSingleThreadScheduledExecutor(ThreadFactory threadFactory) {
return new DelegatedScheduledExecutorService
(new ScheduledThreadPoolExecutor(1, threadFactory));
}
🎁newWorkStealingPool方法
调用Executors工具类的newSingleThreadExecutor方法可以创建一个具有并行级别的线程池，这是jdk 1.8新增的方法，可以为线程池设置并行级别，通过使用多个队列来减少竞争，需要传递一个并行级别的参数。
public static ExecutorService newWorkStealingPool(int parallelism) {
return new ForkJoinPool
(parallelism,
ForkJoinPool.defaultForkJoinWorkerThreadFactory,
null, true);
}以上就是java Executors工具类的相关方法使用创建的详细内容，更多关于java Executors工具类的资料请关注脚本之家其它相关文章！
相关文章
这篇文章主要介绍了spring中使用mybatis实现批量插入的示例代码，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧2020-06-06
Java开发的同学应该都使用或者听说过Google提供的Guava工具包。日常使用最多的肯定是集合相关的工具类，还有Guava cache，除了这些之外Guava还提供了很多有用的功能，鉴于日常想用的时候找不到，这里就梳理一下Guava中那些好用的工具类，想优化代码的时候不妨过来看看2021-04-04
这篇文章主要介绍了教你如何用Eclipse创建一个Maven项目,文中有非常详细的代码示例,对正在入门Java的小伙伴们是非常有帮助的哟,需要的朋友可以参考下2021-05-05
这篇文章主要介绍了spring结合hibernate结合,需要的朋友可以参考下2017-09-09
spring boot下 500 404 错误页面处理的方法
本篇文章主要介绍了spring boot下 500 404 错误页面处理的方法，具有一定的参考价值，感兴趣的小伙伴们可以参考一下2017-04-04
这篇文章主要给大家介绍了关于Spring Data分页与排序的实现方法，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧2018-12-12
本篇将对定义在 XMl 文件中的 bean，从静态的的定义到变成可以使用的对象的过程，即 bean 的加载和获取的过程进行一个整体的了解2017-05-05
小编做题遇到了大数的精确计算，再次认识了bigdecimal关于Bigdecimal意外的有许多小知识点和坑，这里特此整理一下为方便以后学习，希望能帮助到其他的萌新2021-08-08
这篇文章主要介绍了Java动态编译执行代码示例，具有一定借鉴价值，需要的朋友可以参考下。2017-12-12
Java中的List接口从Java 8开始新增了stream()方法,用于创建一个Stream流对象,这篇文章主要给大家介绍了关于java中List常用的4种stream()方法的相关资料,需要的朋友可以参考下2024-02-02
最新评论