参考: https://www.cnblogs.com/snailmanlilin/p/8005787.html
开始写的: public static ThreadPoolExecutor executor = new ThreadPoolExecutor(2, 20, 60L, TimeUnit.SECONDS,new LinkedBlockingQueue<Runnable>(), new ThreadPoolExecutor.CallerRunsPolicy()); 发现线程池里一直是两个线程,不增加。
原来是: 核心线程2个,多余进队列,队列满了才会开新线程。汗,这队列猴年马月能满啊。 ---------------------------------------------------- 后来换成这个了: public static ThreadPoolExecutor executor = new ThreadPoolExecutor(2, 20, 60L, TimeUnit.SECONDS,new SynchronousQueue<Runnable>(), new ThreadPoolExecutor.CallerRunsPolicy());
SynchronousQueue就行了,不对队列里一直没数据。 应该是来一个任务,必须有一个线程来处理,否则一直等? 具体看SynchronousQueue是啥意思吧。
Executors.newCachedThreadPool里面就是SynchronousQueue。 那么,这个队列就没啥用了,没法暂存数据,只能由线程去处理数据。 ---------------------------------------------------- 或者new LinkedBlockingQueue<Runnable>(500)这样设置个长度也可以。 假设20个线程,那么可以处理+等待,一共是520个任务。
SynchronousQueue的话,应该就只能同时处理20个任务了,
|