四 Java多线程-ThreadPool线程池-2 _生活百科

线程池是个神器，用得好会非常地方便。本来觉得线程池的构造器有些复杂，即使讲清楚了对今后的用处可能也不太大，因为有一些Java定义好的线程池可以直接使用。但是（凡事总有个但是），还是觉得讲一讲可能跟有助于理解后面的常用线程池，所以该打脸还是打吧
因为直接结合代码看会更清楚一些，所以我把带注释的代码贴出来：
public class ThreadPoolExecutor {public ThreadPoolExecutor(/*** corePoolSize：初始化时指定的核心线程数，包括空闲线程，必须大于等于0 ，当有新任务提交时，会执行以下判断（workCount为当前活跃的线程数量）:* 当workCount＜ corePoolSize：即使线程池中有空闲线程，也会创建新线程* 当corePoolSize ≤ workCount ＜ maximumPoolSize：只有workQueue满时才创建新线程* 当corePoolSize < workCount ＜ maximumPoolSize：且超过corePoolSize部分的线程空闲时间达到keepAliveTime时，就回收这些线程，当设置allowCoreThreadTimeOut(true)时，*线程池中corePoolSize范围内的线程空闲时间达到keepAliveTime也将被回收* 当设置corePoolSize == maximumPoolSize：线程池的大小固定，此时如有新任务提交，且workQueue未满时，会将请求放入workQueue，等待有空闲的线程从workQueue中取任务并处理* 当workCount ≥ maximumPoolSize：若workQueue满，则采取handler对应的策略*/int corePoolSize,// maximumPoolSize：初始化时指定的最大线程数量int maximumPoolSize,// keepAliveTime：线程池维护线程所允许的空闲时间。当线程池中的线程数量大于corePoolSize时，如果这时没有新的任务提交，核心线程外的线程不会立即销毁，而是等待，直到等待的时间超过了keepAliveTimelong keepAliveTime,// 空闲时间单位TimeUnit unit,/*** workQueue：阻塞队列的类型是保存等待执行的任务的阻塞队列，主要有四种提交方式：* SynchronousQueue：同步队列，这个“队列”内部只包含了一个元素，队列的size始终为0，每执行一个put，就需要一个take来解除阻塞，反之也一样。饱和状态下，线程池能处理的最大线程数量为maximumPoolSize*使用SynchronousQueue队列，提交的任务不会保存，而是会马上提交执行*需要对程序的并发量有个准确的评估，才能设置合适的maximumPoolSize数量，否则很容易就会执行拒绝策略* ArrayBlockingQueue：有界任务队列，饱和状态下，线程池能处理的最大线程数量为maximumPoolSize + ArrayBlockingQueue.SIZE* LinkedBlockingQueue：无界任务队列，线程池的任务队列可以无限制的添加新的任务，此时线程池能够创建的最大线程数是corePoolSize ， *而maximumPoolSize就无效了，线程池饱和状态下能处理的最大线程数量只取决于系统的性能* PriorityBlockingQueue：优先任务队列，同LinkedBlockingQueue一样，它也是一个无界的任务队列，只不过需要自己实现元素的Comparable排序接口*/BlockingQueue<Runnable> workQueue,// threadFactory：创建新线程，使新创建的线程有相同的优先级且为非守护线程，同时设置线程的名称，默认使用Executors.DefaultThreadFactory类创建ThreadFactory threadFactory,/*** handler：表示线程池的饱和策略，意思就是如果阻塞队列满了并且没有空闲的线程，此时如果继续提交任务，就需要采取一种策略处理该任务，线程池提供了4种策略* AbortPolicy：直接抛出异常，这是默认策略* CallerRunsPolicy：如果线程池的线程数量达到上限，则把任务队列中的任务放在调用者的线程当运行* DiscardOldestPolicy：丢弃阻塞队列中靠最前的任务，并执行当前任务* DiscardPolicy：直接丢弃任务*/RejectedExecutionHandler handler) {// balabala… …}}这样就清晰多了。
其中，最主要是要清楚几种workQueue，也就是BlockingQueue<Runnable>的作用。
SynchronousQueue同步队列，这个队列没有所谓的缓冲，这样做是为了排除阻塞时队列丢消息的可能。如果没有其他微服务并行执行的话，可以放心地用这个队列，不然还是小心一点为妙。它的示例代码：
/** * 同步队列 */public class SynchronousQueueTest {public static void main(String[] args) {ExecutorService service = new ThreadPoolExecutor(1,// 当要处理的线程数超过maximumPoolSize时，抛出异常2,1000,TimeUnit.MILLISECONDS,new SynchronousQueue<Runnable>(),Executors.defaultThreadFactory(),new ThreadPoolExecutor.AbortPolicy());for (int i = 0; i < 10; i++) {service.execute(() ->System.out.println("当前线程 " + Thread.currentThread().getName()));}service.shutdown();}}ArrayBlockingQueue，它的使用范围非常广，一般可以用于轻量级的同步锁，也就是在同一个服务中（也就是非微服务架构），如果要具有分布式锁的功能又不想部署zookeeper这么麻烦的话，ArrayBlockingQueue就是一个非常不错的选择。

四 Java多线程-ThreadPool线程池-2

推荐阅读

母亲节要买什么礼物,分享几款走心的

2022年护士年终工作总结 2022美工个人年终工作总结

双子座的床上功夫

金鱼眼面相解析，有金鱼眼的人运势怎么样

怎么去胶？

抗皱六胜肽精华液的使用方法六胜肽抗皱精华液使用方法

手机无响应的解决方法应该怎么解决呢

白煮牛肉的家常做法大全白煮牛肉的家常做法

宝马有什么技术

形容经历了事情的成语是什么

糖不甩怎么做才Q

猫咪渴了的表现

瘦麒麟臂方法瘦胳膊最有效的方法

开元通宝680万图片 &#8211; 开元通宝2020价格

汽车贴膜前需要洗车吗汽车贴膜前要洗车吗?

关于本玉12号简述本玉12号

蓝牙耳机使用小技巧蓝牙耳机的正确使用方法

诗歌鉴赏蜀相咏史怀古诗蜀相的作者

梦见下牙掉了,但没流血是什么意思

越狱第3季中第几集越狱成功？