答案是会!以下为详细的解释。
SynchronousQueue是没有容量的队列,往队列里插入一个元素,下一次插入会陷入阻塞,直到之前的元素被其他消费者给取走。
在线程池的上下文中,为了简化讨论情况,这里假设核心线程不允许死亡(除非崩溃)。站在线程池的视角,当一个新任务来的时候,它是怎么处理的呢
- 如果当前的线程数量数量小于核心线程数,线程池倾向于创建新的线程处理新的任务,
- 否则尝试将任务加入到队列中,java提供的阻塞队列抽象中有offer和put两个方法,其中offer是条件满足则进行插入,否则直接返回,put则是条件不满足的情况下会进行阻塞等待,上文中我这里用了“尝试将任务加入到队列”这种说法,意思是指这里使用是offer的方式入队,
- 失败的情况下,如果当前线程数没有超过线程池配置的最大线程数的话,会尝试创建新的线程去处理,否则执行拒绝策略。成功的情况下就加入队列,等待其他线程取到该任务去执行。
回到我们的上下文,若尝试将任务插入到SynchronousQueue的过程中发现无法插入,也就是说此队列的上一个任务尚未被调度完成,这个时候就会走到“尝试创建新的线程去调度该任务的过程”。那如果这个时候最大线程数已经达到了,那么就无法创建线程了,自然就会执行拒绝策略了。
因此,实践中,如果我们决定使用SynchronousQueue作为我们的线程池配置,由于这个阻塞队列的特性,我们期望的是立刻有线程接受这个任务,换言之,要么将最大线程数设置得很大,比如Int.Max,Executors中的newCachedThreadPool使用的就是这种方式,要么我们必须有一个认知,我们提交给线程池的任务执行时间不长,下一个任务来的时候一般有空闲的线程或者能够创建新的线程进行处理(这个认知可能随着app的迭代被打破),如果以上两个条件都不满足,就享受拒绝策略吧,而在安卓中,默认的线程拒绝策略会杀死整个app(喜提线上崩溃),所以使用SynchronousQueue需要万分小心。