业务交互的过程中涉及到了很多关于SFTP下载的问题，因此在代码中定义了一些线程池，使用中发现了一些问题，
代码类似如下所示：
如上面的代码所示，定义了一个初始容量为2，最大容量为100，队列长度为10的线程池，期待的运行结果为：
Thread name=pool-1-thread-1Thread name=pool-1-thread-2Thread name=pool-1-thread-3Thread name=pool-1-thread-4Thread name=pool-1-thread-5Thread name=pool-1-thread-6Thread name=pool-1-thread-7Thread name=pool-1-thread-8Thread name=pool-1-thread-9Thread name=pool-1-thread-10Thread name=pool-1-thread-3Thread name=pool-1-thread-5Thread name=pool-1-thread-2Thread name=pool-1-thread-1Thread name=pool-1-thread-4Thread name=pool-1-thread-10Thread name=pool-1-thread-7Thread name=pool-1-thread-6Thread name=pool-1-thread-9Thread name=pool-1-thread-8Thread name=pool-1-thread-3Thread name=pool-1-thread-4Thread name=pool-1-thread-1Thread name=pool-1-thread-5Thread name=pool-1-thread-2Thread name=pool-1-thread-8Thread name=pool-1-thread-6Thread name=pool-1-thread-7Thread name=pool-1-thread-9Thread name=pool-1-thread-10
期待十个线程都可以运行，但实际的执行效果如下：
Thread name=pool-1-thread-1Thread name=pool-1-thread-2Thread name=pool-1-thread-2Thread name=pool-1-thread-1Thread name=pool-1-thread-1Thread name=pool-1-thread-2Thread name=pool-1-thread-1Thread name=pool-1-thread-2Thread name=pool-1-thread-2Thread name=pool-1-thread-1Thread name=pool-1-thread-2Thread name=pool-1-thread-1Thread name=pool-1-thread-2Thread name=pool-1-thread-1
对比可以看出，用上面的方式定义线程池，最终只有两个线程可以运行，即线程池的初始容量大小。其余线程都被阻塞到了队列ArrayBlockingQueue<>(10)
问题分析我们知道，Executors框架提供了几种常见的线程池分别为：
newCachedThreadPool创建一个可缓存线程池，如果线程池长度超过处理需要，可灵活回收空闲线程，若无可回收，则新建线程。newFixedThreadPool 创建一个定长线程池，可控制线程最大并发数，超出的线程会在队列中等待。newScheduledThreadPool 创建一个定长线程池，支持定时及周期性任务执行。newSingleThreadExecutor 创建一个单线程化的线程池，它只会用唯一的工作线程来执行任务，保证所有任务按照指定顺序(FIFO, LIFO, 优先级)执行。如果将代码中自定义的线程池改为 ：
运行发现，提交的十个线程都可以运行
Executors.newCachedThreadPool()的源码如下：
通过对比发现，newCachedThreadPool使用的是 SynchronousQueue<>()而我们使用的是ArrayBlockingQueue<>(10) 因此可以很容易的发现问题出在队列上。
问题解决将ArrayBlockingQueue改为SynchronousQueue 问题解决，代码如下：
总结 两个队列的UML关系图从图上我们可以看到，两个队列都继承了AbstractQueue实现了BlockingQueue接口，因此功能应该相似
SynchronousQueue的定义SynchronousQueue类似于一个传递通道,只是通过他传递某个元素，并没有任何容量，只有当第一个元素被取走，才能在给队列添加元素。
ArrayBlockingQueue的定义ArrayBlockingQueue从定义来看就是一个普通的队列，先入先出，当队列为空时，获取数据的线程会被阻塞，当队列满时，添加队列的线程会被阻塞，直到队列可用。
分析从上面队列的定义中可以看出，导致线程池没有按照预期运行的原因不是因为队列的问题，应该是关于线程池在提交任务时，从队列取数据的方式不同导致的。
jdk源码中关于线程池队列的说明从说明中可以看到，如果正在运行的线程数必初始容量corePoolSize小，那么Executor会从创建一个新线程去执行任务，如果正在执行的线程数必corePoolSize大，那么Executor会将新提交的任务放到阻塞队列，除非当队列的个数超过了队列的最大长度maxmiumPooSize。
从源码中找到关于提交任务的方法：
从源码中看到 subimit实际上是调用了execute方法
execute方法的源码：
源码中可以看出，提交任务时，首先会判断正在执行的线程数是否小于corePoolSize，如果条件成立那么会直接创建线程并执行任务。如果条件不成立，且队列没有满，那么将任务放到队列，如果条件不成立但是队列满了，那么同样也新创建线程并执行任务。
到此这篇关于Java如何自定义线程池中队列的文章就介绍到这了,更多相关Java 队列内容请搜索七叶笔记以前的文章或继续浏览下面的相关文章希望大家以后多多支持七叶笔记！
