今天线上发现一个bug,虽然程序用了两个线程池来处理不一样的任务,可是每次执行批量任务后在数据库中查询发现,建立的任务数和线程数对不上,老是只对应A池中的线程数。B池没有同时执行。数据库
可是在测试环境,任务比较少的状况下,是不存在这种状况的,看了下代码,发现问题所在。测试
由于在线程池中使用了ArrayBlockingQueue阻塞队列,拒绝策略中也使用了executor.getQueue().put(r);阻塞的方法。若是此时,A池中任务很是多,超过了队列长度,这时添加任务的步骤将阻塞,从而致使后面的B池的代码没法执行。线程
针对猜测,进行验证,将队列长度设置为大于任务数后,再运行。发现两池开始同时工做了。问题解决。队列