今天我们来聊一下这个 Java 中的线程池，线程池，这块的内容，已经是非常的容易被面试官问到的内容，为什么呢？这是因为线程池，是一种多线程的处理方式，如果使用方式得当的话，那么对我们的代码的质量也是非常高的。
我们既然要了解线程池，那么肯定是需要从几个角度来考虑，第一，什么是线程池？第二：为什么需要线程池？第三，线程池的创建方式都有哪些。
线程池是一种多线程处理形式，处理过程中将任务添加到队列，然后在创建线程后自动启动这些任务。
线程池线程都是后台线程。每个线程都使用默认的堆栈大小，以默认的优先级运行，并处于多线程单元 中。如果某个线程在托管代码中空闲（如正在等待某个事件），则线程池将插入另一个辅助线程来使所 有处理器保持繁忙。
如果所有线程池线程都始终保持繁忙，但队列中包含挂起的工作，则线程池将在一段时间后创建另一个辅助线程但线程的数目永远不会超过最大值。超过最大值的线程可以排队，但他们要等到其他线程完成后才启动。
我们有两种常见的创建线程的方法，
但是我们创建这两种线程在运行结束后都会被虚拟机销毁，如果线程数量多的话，频繁的创建和销毁线程会大大浪费时间和效率，更重要的是浪费内存。那么有没有一种方法能让线程运行完后不立即销毁，而是让线程重复使用，继续执行其他的任务哪？
这就是线程池的由来，很好的解决线程的重复利用，避免重复开销。
(1)重用存在的线程，减少对象创建销毁的开销。
(2)可有效的控制最大并发线程数，提高系统资源的使用率，同时避免过多资源竞争，避免堵塞。
(3)提供定时执行、定期执行、单线程、并发数控制等功能。
而且优点这么多，那么肯定就得知道 Java 提供了哪些线程池的实现方式了。
FixedThreadPool
public static ExecutorService newFixedThreadPool(int nThreads) { return new ThreadPoolExecutor(nThreads, nThreads, 0L, TimeUnit.MILLISECONDS, new LinkedBlockingQueue<Runnable>()); }newFixedThreadPool 实际上返回的是 ThreadPoolExecutor，ThreadPoolExecutor 实际就是线程池实现类，使用了典型的模板方法设计模式，通过ThreadPoolExecutor构造器的说明我们稍微解释一下各参数的意思：
构造器如下：
public ThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, BlockingQueue<Runnable> workQueue) { this(corePoolSize, maximumPoolSize, keepAliveTime, unit, workQueue, Executors.defaultThreadFactory(), defaultHandler); }而newFixedThreadPool使用了corePoolSize和maximumPoolSize相等，所以当线程池线程数到达corePoolSize之后就不会再创建线程。
并且newFixedThreadPool使用了LinkedBlockingQueue，而且使用的是默认构造器，容量是Integer.MAX_VALUE，keepAliveTime是0，实际上设不设置都没关系，因为不会超过核心线程数。
实际上我们也可以理解为FixedThreadPool该线程池中的线程数量始不变。当有一个新的任务提交时，线程池中若有空闲线程，则立即执行。若没有，则新的任务会被暂存在一个任务队列中，待有线程空闲时，便处理在任务队列中的任务。
SingleThreadExecutor
实际上SingleThreadExecutor是使用单个 worker 线程的Executor。
也就是说方法返回一个只有一个线程的线程池。若多余一个任务被提交到该线程 池，任务会被保存在一个任务队列中，待线程空闲，按先入先出的顺序执行队列中的任务
public static ExecutorService newSingleThreadExecutor() { return new FinalizableDelegatedExecutorService (new ThreadPoolExecutor(1, 1, 0L, TimeUnit.MILLISECONDS, new LinkedBlockingQueue<Runnable>())); }SingleThreadExecutor 的 corePoolSize 和 maximumPoolSize 被设置为 1 。其他参数与 FixedThreadPool 相同。 SingleThreadExecutor 使用无 队列 LinkedBlockingQueue 作 为线程池的工作队列（ 队列的容量为Integer.MAX_VALUE ）。
CachedThreadPool
该方法返回一个可根据实际情况调整线程数量的线程池。线程池的线程数 量不确定，但若有空闲线程可以复用，则会优先使用可复用的线程。若所有线程均在工作，又有新 的任务提交，则会创建新的线程处理任务。所有线程在当前任务执行完毕后，将返回线程池进行复 用。
public static ExecutorService newCachedThreadPool() { return new ThreadPoolExecutor(0, Integer.MAX_VALUE, 60L, TimeUnit.SECONDS, new SynchronousQueue<Runnable>()); }ScheduledThreadPoolExecutor
这个线程池的构造器就比较多了
// 第一个构造函数 public ScheduledThreadPoolExecutor(int corePoolSize) { super(corePoolSize, Integer.MAX_VALUE, DEFAULT_KEEPALIVE_MILLIS, MILLISECONDS, new DelayedWorkQueue()); } // 第二个构造函数 public ScheduledThreadPoolExecutor(int corePoolSize, ThreadFactory threadFactory) { super(corePoolSize, Integer.MAX_VALUE, DEFAULT_KEEPALIVE_MILLIS, MILLISECONDS, new DelayedWorkQueue(), threadFactory); } // 第三个构造函数 public ScheduledThreadPoolExecutor(int corePoolSize, RejectedExecutionHandler handler) { super(corePoolSize, Integer.MAX_VALUE, DEFAULT_KEEPALIVE_MILLIS, MILLISECONDS, new DelayedWorkQueue(), handler); } // 第四个构造函数 public ScheduledThreadPoolExecutor(int corePoolSize, ThreadFactory threadFactory, RejectedExecutionHandler handler) { super(corePoolSize, Integer.MAX_VALUE, DEFAULT_KEEPALIVE_MILLIS, MILLISECONDS, new DelayedWorkQueue(), threadFactory, handler); }主要用来在给定的延迟后运行任务，或者定期执行任务。ScheduledThreadPoolExecutor又分为：ScheduledThreadPoolExecutor（包含多个线程）和SingleThreadScheduledExecutor （只包含一个线程）两种。
其实创建方式，就是Executors，使用 Executors 可以非常轻易的创建我们上面所说的这几种线程池。但是呢，有一个地方不知道大家有没有注意到，在 阿里的开发手册上面，是不允许使用 Executors 去创建的，更推荐我们使用的是 ThreadPoolExecutor 构造去创建，这样的好处就是为了规避资源耗尽的风险那时候抛出的就不是异常，而是错误了。
private static ExecutorService executor = new ThreadPoolExecutor(13, 13,60L, TimeUnit.SECONDS,new ArrayBlockingQueue(13));我们可以自己直接调用 ThreadPoolExecutor 的构造函数来自己创建线程池。在创建的同时，给 BlockQueue 指定容量就可以了。
这时候如果提交的线程数超过了可用线程数的时候，就会抛出异常，比如 java.util.concurrent.RejectedExecutionException,这是因为当前线程池使用的队列是有边界队列，队列已经满了便无法继续处理新的请求。
如果你觉得对 Error 和 Exception 没有任何感觉得话，你也是可以使用 Executors 去创建的。
你还知道有其他方式去创建线程池的么？
本文链接：http://www.28at.com/showinfo-26-12172-0.html阿里规范竟然不让我用这种方式创建线程池
声明：本网页内容旨在传播知识，若有侵权等问题请及时与本网联系，我们将在第一时间删除处理。邮件：2376512515@qq.com
上一篇： 我们一起聊一聊Not only Java
下一篇： Python 中的真与假
Copyright © 2016-2023 天津谷骐科技有限公司 版权所有 sitemap.xml
违法及侵权请联系：2376512515@qq.com 津ICP备18001702号
津公网安备 12010102000574号