在多线程的世界里,如果源源不断的生产线程的话,内存迟早会被吃光,所以就有了能够重复利用线程的线程池。一个请求到来,从池子中捞起一个空闲的线程,带着该请求去处理事情,事情做完后线程回归池里,等待下一位客人。在池子中的线程可以一遍又一遍的使用,避免了线程创建、销毁的开销,但如果请求的到达率高于线程的处理速度呢?池子会随着请求的积累慢慢膨胀,最终爆掉。
看例子:
import java.util.ArrayList; import java.util.List; import java.util.concurrent.Callable; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; import java.util.concurrent.FutureTask; import java.util.concurrent.TimeUnit; public class ThreadPoolTest { // 定义大小弹性伸缩的线程池 private final ExecutorService es = Executors.newCachedThreadPool(); public static void main(String[] args) { ThreadPoolTest t = new ThreadPoolTest(); t.poolTest(1000000, 4, 5); } /** * 测试不同线程数量对线程池的冲击 * * @author wulinfeng * @param nThread 每次投入多少线程到线程池中 * @param nSecondDelay 每个任务的请求数 * @param nSecondDelay 在每个任务中休眠多少秒 */ public void poolTest(int nThread, int nRequestData, int nSecondDelay) { // 创建任务列表 List<SubFutureTask<String>> tasks = new ArrayList<SubFutureTask<String>>(); // 创建任务,放入任务列表 for (int i = 0; i < nThread; i++) { Callable<String> callable1 = new ResultCallable<String>(nRequestData, nSecondDelay); SubFutureTask<String> task1 = new SubFutureTask<String>(callable1); tasks.add(task1); } // 从任务列表中获取执行结果 String result = getSubmitResult(tasks); System.out.println(result); } /** * 获取结果集 * * @author wulinfeng * @param tasks * @return */ private String getSubmitResult(List<SubFutureTask<String>> tasks) { // 循环遍历出任务对象并提交到Executor if (null == es || es.isShutdown()) { return null; } if ((null != tasks && tasks.size() > 0)) { for (int i = 0; i < tasks.size(); i++) { es.submit(tasks.get(i)); } } // 获取结果集 return (String)getResult(tasks); } /** * 包装结果 * * @author wulinfeng * @param tasks * @return */ private String getResult(List<SubFutureTask<String>> tasks) { StringBuilder sb = new StringBuilder(); if ((null != tasks && tasks.size() > 0)) { for (int i = 0; i < tasks.size(); i++) { SubFutureTask<String> task = tasks.get(i); String result = null; if (null != task) { try { // 使用超时时间限制,超时则抛异常 Object res = task.get(3000, TimeUnit.MILLISECONDS); if (res instanceof String) { result = (String)res; } } catch (Exception e) { sb.append(String.format("第%d个线程请求超时了 ", i)); e.printStackTrace(); continue; } } if (result != null) { sb.append(String.format("第%d个线程: ", i)); sb.append(result).append(' '); } } } return sb.toString(); } /** * 定义任务内容 * * @author wulinfeng * @version C10 2018年9月3日 * @since SDP V300R003C10 */ class ResultCallable<T> implements Callable<T> { private int nRequestData; private int nSecondDelay; public ResultCallable(int nRequet, int nSecondDelay) { this.nRequestData = nRequet; this.nSecondDelay = nSecondDelay; } @Override public T call() throws Exception { StringBuilder sb = new StringBuilder(); for (int i = 0; i < nRequestData; i++) { // 该请求耗时nSecondDelay秒 Thread.sleep(1000 * nSecondDelay); sb.append(String.format("第(%d)次请求数据,线程名:%s,响应时间点:%d ", i, Thread.currentThread().getName(), System.currentTimeMillis())); } return (T)sb.toString(); } } /** * 获取callable对象 * * @author wulinfeng * @version C10 2018年9月3日 * @since SDP V300R003C10 */ class SubFutureTask<V> extends FutureTask<V> { private Callable<V> callable; public SubFutureTask(Callable<V> arg0) { super(arg0); this.callable = arg0; } public Callable<V> getCallable() { return this.callable; } } }
上面用了可缓存线程池,用一百万个线程丢到池子里去,没有任何问题,因为这个池子默认能容纳整形的最大值2147483647。但真跑起来会发现控制台并未打印,看个人电脑性能好坏,有的人可能电脑会变卡,我反正是等了半天都没反应。如果这个池子拿到生产环境用,而且请求量、线程的到达率很大,那么很有可能会吃光内存。所以一般项目都不敢用它。那么固定大小的线程池呢?
把前面几行改为:
// 定义固定大小的线程池 private final ExecutorService es = Executors.newFixedThreadPool(64); public static void main(String[] args) { ThreadPoolTest t = new ThreadPoolTest(); t.poolTest(100, 4, 5); }
跑一把看输出:
java.util.concurrent.TimeoutException
at java.util.concurrent.FutureTask.get(FutureTask.java:205)
at cn.migu.newportal.cache.async.pool.conner.ThreadPoolTest.getResult(ThreadPoolTest.java:96)
at cn.migu.newportal.cache.async.pool.conner.ThreadPoolTest.getSubmitResult(ThreadPoolTest.java:72)
at cn.migu.newportal.cache.async.pool.conner.ThreadPoolTest.poolTest(ThreadPoolTest.java:44)
at cn.migu.newportal.cache.async.pool.conner.ThreadPoolTest.main(ThreadPoolTest.java:19)
java.util.concurrent.TimeoutException
at java.util.concurrent.FutureTask.get(FutureTask.java:205)
at cn.migu.newportal.cache.async.pool.conner.ThreadPoolTest.getResult(ThreadPoolTest.java:96)
at cn.migu.newportal.cache.async.pool.conner.ThreadPoolTest.getSubmitResult(ThreadPoolTest.java:72)
at cn.migu.newportal.cache.async.pool.conner.ThreadPoolTest.poolTest(ThreadPoolTest.java:44)
at cn.migu.newportal.cache.async.pool.conner.ThreadPoolTest.main(ThreadPoolTest.java:19)
java.util.concurrent.TimeoutException
at java.util.concurrent.FutureTask.get(FutureTask.java:205)
at cn.migu.newportal.cache.async.pool.conner.ThreadPoolTest.getResult(ThreadPoolTest.java:96)
at cn.migu.newportal.cache.async.pool.conner.ThreadPoolTest.getSubmitResult(ThreadPoolTest.java:72)
at cn.migu.newportal.cache.async.pool.conner.ThreadPoolTest.poolTest(ThreadPoolTest.java:44)
at cn.migu.newportal.cache.async.pool.conner.ThreadPoolTest.main(ThreadPoolTest.java:19)
java.util.concurrent.TimeoutException
at java.util.concurrent.FutureTask.get(FutureTask.java:205)
at cn.migu.newportal.cache.async.pool.conner.ThreadPoolTest.getResult(ThreadPoolTest.java:96)
at cn.migu.newportal.cache.async.pool.conner.ThreadPoolTest.getSubmitResult(ThreadPoolTest.java:72)
at cn.migu.newportal.cache.async.pool.conner.ThreadPoolTest.poolTest(ThreadPoolTest.java:44)
at cn.migu.newportal.cache.async.pool.conner.ThreadPoolTest.main(ThreadPoolTest.java:19)
java.util.concurrent.TimeoutException
at java.util.concurrent.FutureTask.get(FutureTask.java:205)
at cn.migu.newportal.cache.async.pool.conner.ThreadPoolTest.getResult(ThreadPoolTest.java:96)
at cn.migu.newportal.cache.async.pool.conner.ThreadPoolTest.getSubmitResult(ThreadPoolTest.java:72)
at cn.migu.newportal.cache.async.pool.conner.ThreadPoolTest.poolTest(ThreadPoolTest.java:44)
at cn.migu.newportal.cache.async.pool.conner.ThreadPoolTest.main(ThreadPoolTest.java:19)
java.util.concurrent.TimeoutException
at java.util.concurrent.FutureTask.get(FutureTask.java:205)
at cn.migu.newportal.cache.async.pool.conner.ThreadPoolTest.getResult(ThreadPoolTest.java:96)
at cn.migu.newportal.cache.async.pool.conner.ThreadPoolTest.getSubmitResult(ThreadPoolTest.java:72)
at cn.migu.newportal.cache.async.pool.conner.ThreadPoolTest.poolTest(ThreadPoolTest.java:44)
at cn.migu.newportal.cache.async.pool.conner.ThreadPoolTest.main(ThreadPoolTest.java:19)
java.util.concurrent.TimeoutException
at java.util.concurrent.FutureTask.get(FutureTask.java:205)
at cn.migu.newportal.cache.async.pool.conner.ThreadPoolTest.getResult(ThreadPoolTest.java:96)
at cn.migu.newportal.cache.async.pool.conner.ThreadPoolTest.getSubmitResult(ThreadPoolTest.java:72)
at cn.migu.newportal.cache.async.pool.conner.ThreadPoolTest.poolTest(ThreadPoolTest.java:44)
at cn.migu.newportal.cache.async.pool.conner.ThreadPoolTest.main(ThreadPoolTest.java:19)
java.util.concurrent.TimeoutException
at java.util.concurrent.FutureTask.get(FutureTask.java:205)
at cn.migu.newportal.cache.async.pool.conner.ThreadPoolTest.getResult(ThreadPoolTest.java:96)
at cn.migu.newportal.cache.async.pool.conner.ThreadPoolTest.getSubmitResult(ThreadPoolTest.java:72)
at cn.migu.newportal.cache.async.pool.conner.ThreadPoolTest.poolTest(ThreadPoolTest.java:44)
at cn.migu.newportal.cache.async.pool.conner.ThreadPoolTest.main(ThreadPoolTest.java:19)
java.util.concurrent.TimeoutException
at java.util.concurrent.FutureTask.get(FutureTask.java:205)
at cn.migu.newportal.cache.async.pool.conner.ThreadPoolTest.getResult(ThreadPoolTest.java:96)
at cn.migu.newportal.cache.async.pool.conner.ThreadPoolTest.getSubmitResult(ThreadPoolTest.java:72)
at cn.migu.newportal.cache.async.pool.conner.ThreadPoolTest.poolTest(ThreadPoolTest.java:44)
at cn.migu.newportal.cache.async.pool.conner.ThreadPoolTest.main(ThreadPoolTest.java:19)
java.util.concurrent.TimeoutException
at java.util.concurrent.FutureTask.get(FutureTask.java:205)
at cn.migu.newportal.cache.async.pool.conner.ThreadPoolTest.getResult(ThreadPoolTest.java:96)
at cn.migu.newportal.cache.async.pool.conner.ThreadPoolTest.getSubmitResult(ThreadPoolTest.java:72)
at cn.migu.newportal.cache.async.pool.conner.ThreadPoolTest.poolTest(ThreadPoolTest.java:44)
at cn.migu.newportal.cache.async.pool.conner.ThreadPoolTest.main(ThreadPoolTest.java:19)
java.util.concurrent.TimeoutException
at java.util.concurrent.FutureTask.get(FutureTask.java:205)
at cn.migu.newportal.cache.async.pool.conner.ThreadPoolTest.getResult(ThreadPoolTest.java:96)
at cn.migu.newportal.cache.async.pool.conner.ThreadPoolTest.getSubmitResult(ThreadPoolTest.java:72)
at cn.migu.newportal.cache.async.pool.conner.ThreadPoolTest.poolTest(ThreadPoolTest.java:44)
at cn.migu.newportal.cache.async.pool.conner.ThreadPoolTest.main(ThreadPoolTest.java:19)
java.util.concurrent.TimeoutException
at java.util.concurrent.FutureTask.get(FutureTask.java:205)
at cn.migu.newportal.cache.async.pool.conner.ThreadPoolTest.getResult(ThreadPoolTest.java:96)
at cn.migu.newportal.cache.async.pool.conner.ThreadPoolTest.getSubmitResult(ThreadPoolTest.java:72)
at cn.migu.newportal.cache.async.pool.conner.ThreadPoolTest.poolTest(ThreadPoolTest.java:44)
at cn.migu.newportal.cache.async.pool.conner.ThreadPoolTest.main(ThreadPoolTest.java:19)
第0个线程请求超时了
第1个线程请求超时了
第2个线程请求超时了
第3个线程请求超时了
第4个线程请求超时了
第5个线程请求超时了
第6个线程:
第(0)次请求数据,线程名:pool-1-thread-7,响应时间点:1536029991602
第(1)次请求数据,线程名:pool-1-thread-7,响应时间点:1536029996604
第(2)次请求数据,线程名:pool-1-thread-7,响应时间点:1536030001605
第(3)次请求数据,线程名:pool-1-thread-7,响应时间点:1536030006606
第7个线程:
第(0)次请求数据,线程名:pool-1-thread-8,响应时间点:1536029991602
第(1)次请求数据,线程名:pool-1-thread-8,响应时间点:1536029996604
第(2)次请求数据,线程名:pool-1-thread-8,响应时间点:1536030001605
第(3)次请求数据,线程名:pool-1-thread-8,响应时间点:1536030006606
第8个线程:
第(0)次请求数据,线程名:pool-1-thread-9,响应时间点:1536029991603
第(1)次请求数据,线程名:pool-1-thread-9,响应时间点:1536029996604
第(2)次请求数据,线程名:pool-1-thread-9,响应时间点:1536030001604
第(3)次请求数据,线程名:pool-1-thread-9,响应时间点:1536030006605
第9个线程:
第(0)次请求数据,线程名:pool-1-thread-10,响应时间点:1536029991603
第(1)次请求数据,线程名:pool-1-thread-10,响应时间点:1536029996604
第(2)次请求数据,线程名:pool-1-thread-10,响应时间点:1536030001604
第(3)次请求数据,线程名:pool-1-thread-10,响应时间点:1536030006605
第10个线程:
第(0)次请求数据,线程名:pool-1-thread-11,响应时间点:1536029991603
第(1)次请求数据,线程名:pool-1-thread-11,响应时间点:1536029996604
第(2)次请求数据,线程名:pool-1-thread-11,响应时间点:1536030001604
第(3)次请求数据,线程名:pool-1-thread-11,响应时间点:1536030006605
第11个线程:
第(0)次请求数据,线程名:pool-1-thread-12,响应时间点:1536029991603
第(1)次请求数据,线程名:pool-1-thread-12,响应时间点:1536029996605
第(2)次请求数据,线程名:pool-1-thread-12,响应时间点:1536030001605
第(3)次请求数据,线程名:pool-1-thread-12,响应时间点:1536030006606
第12个线程:
第(0)次请求数据,线程名:pool-1-thread-13,响应时间点:1536029991603
第(1)次请求数据,线程名:pool-1-thread-13,响应时间点:1536029996605
第(2)次请求数据,线程名:pool-1-thread-13,响应时间点:1536030001605
第(3)次请求数据,线程名:pool-1-thread-13,响应时间点:1536030006606
第13个线程:
第(0)次请求数据,线程名:pool-1-thread-14,响应时间点:1536029991604
第(1)次请求数据,线程名:pool-1-thread-14,响应时间点:1536029996605
第(2)次请求数据,线程名:pool-1-thread-14,响应时间点:1536030001605
第(3)次请求数据,线程名:pool-1-thread-14,响应时间点:1536030006606
第14个线程:
第(0)次请求数据,线程名:pool-1-thread-15,响应时间点:1536029991604
第(1)次请求数据,线程名:pool-1-thread-15,响应时间点:1536029996605
第(2)次请求数据,线程名:pool-1-thread-15,响应时间点:1536030001605
第(3)次请求数据,线程名:pool-1-thread-15,响应时间点:1536030006606
第15个线程:
第(0)次请求数据,线程名:pool-1-thread-16,响应时间点:1536029991604
第(1)次请求数据,线程名:pool-1-thread-16,响应时间点:1536029996606
第(2)次请求数据,线程名:pool-1-thread-16,响应时间点:1536030001607
第(3)次请求数据,线程名:pool-1-thread-16,响应时间点:1536030006609
第16个线程:
第(0)次请求数据,线程名:pool-1-thread-17,响应时间点:1536029991604
第(1)次请求数据,线程名:pool-1-thread-17,响应时间点:1536029996606
第(2)次请求数据,线程名:pool-1-thread-17,响应时间点:1536030001607
第(3)次请求数据,线程名:pool-1-thread-17,响应时间点:1536030006609
第17个线程:
第(0)次请求数据,线程名:pool-1-thread-18,响应时间点:1536029991605
第(1)次请求数据,线程名:pool-1-thread-18,响应时间点:1536029996607
第(2)次请求数据,线程名:pool-1-thread-18,响应时间点:1536030001607
第(3)次请求数据,线程名:pool-1-thread-18,响应时间点:1536030006608
第18个线程:
第(0)次请求数据,线程名:pool-1-thread-19,响应时间点:1536029991609
第(1)次请求数据,线程名:pool-1-thread-19,响应时间点:1536029996610
第(2)次请求数据,线程名:pool-1-thread-19,响应时间点:1536030001610
第(3)次请求数据,线程名:pool-1-thread-19,响应时间点:1536030006612
第19个线程:
第(0)次请求数据,线程名:pool-1-thread-20,响应时间点:1536029991609
第(1)次请求数据,线程名:pool-1-thread-20,响应时间点:1536029996610
第(2)次请求数据,线程名:pool-1-thread-20,响应时间点:1536030001611
第(3)次请求数据,线程名:pool-1-thread-20,响应时间点:1536030006612
第20个线程:
第(0)次请求数据,线程名:pool-1-thread-21,响应时间点:1536029991608
第(1)次请求数据,线程名:pool-1-thread-21,响应时间点:1536029996610
第(2)次请求数据,线程名:pool-1-thread-21,响应时间点:1536030001612
第(3)次请求数据,线程名:pool-1-thread-21,响应时间点:1536030006614
第21个线程:
第(0)次请求数据,线程名:pool-1-thread-22,响应时间点:1536029991608
第(1)次请求数据,线程名:pool-1-thread-22,响应时间点:1536029996610
第(2)次请求数据,线程名:pool-1-thread-22,响应时间点:1536030001610
第(3)次请求数据,线程名:pool-1-thread-22,响应时间点:1536030006611
第22个线程:
第(0)次请求数据,线程名:pool-1-thread-23,响应时间点:1536029991608
第(1)次请求数据,线程名:pool-1-thread-23,响应时间点:1536029996610
第(2)次请求数据,线程名:pool-1-thread-23,响应时间点:1536030001611
第(3)次请求数据,线程名:pool-1-thread-23,响应时间点:1536030006612
第23个线程:
第(0)次请求数据,线程名:pool-1-thread-24,响应时间点:1536029991608
第(1)次请求数据,线程名:pool-1-thread-24,响应时间点:1536029996609
第(2)次请求数据,线程名:pool-1-thread-24,响应时间点:1536030001609
第(3)次请求数据,线程名:pool-1-thread-24,响应时间点:1536030006610
第24个线程:
第(0)次请求数据,线程名:pool-1-thread-25,响应时间点:1536029991608
第(1)次请求数据,线程名:pool-1-thread-25,响应时间点:1536029996609
第(2)次请求数据,线程名:pool-1-thread-25,响应时间点:1536030001609
第(3)次请求数据,线程名:pool-1-thread-25,响应时间点:1536030006610
第25个线程:
第(0)次请求数据,线程名:pool-1-thread-26,响应时间点:1536029991608
第(1)次请求数据,线程名:pool-1-thread-26,响应时间点:1536029996609
第(2)次请求数据,线程名:pool-1-thread-26,响应时间点:1536030001609
第(3)次请求数据,线程名:pool-1-thread-26,响应时间点:1536030006610
第26个线程:
第(0)次请求数据,线程名:pool-1-thread-27,响应时间点:1536029991607
第(1)次请求数据,线程名:pool-1-thread-27,响应时间点:1536029996609
第(2)次请求数据,线程名:pool-1-thread-27,响应时间点:1536030001611
第(3)次请求数据,线程名:pool-1-thread-27,响应时间点:1536030006613
第27个线程:
第(0)次请求数据,线程名:pool-1-thread-28,响应时间点:1536029991608
第(1)次请求数据,线程名:pool-1-thread-28,响应时间点:1536029996609
第(2)次请求数据,线程名:pool-1-thread-28,响应时间点:1536030001609
第(3)次请求数据,线程名:pool-1-thread-28,响应时间点:1536030006610
第28个线程:
第(0)次请求数据,线程名:pool-1-thread-29,响应时间点:1536029991608
第(1)次请求数据,线程名:pool-1-thread-29,响应时间点:1536029996609
第(2)次请求数据,线程名:pool-1-thread-29,响应时间点:1536030001609
第(3)次请求数据,线程名:pool-1-thread-29,响应时间点:1536030006610
第29个线程:
第(0)次请求数据,线程名:pool-1-thread-30,响应时间点:1536029991607
第(1)次请求数据,线程名:pool-1-thread-30,响应时间点:1536029996609
第(2)次请求数据,线程名:pool-1-thread-30,响应时间点:1536030001611
第(3)次请求数据,线程名:pool-1-thread-30,响应时间点:1536030006612
第30个线程:
第(0)次请求数据,线程名:pool-1-thread-31,响应时间点:1536029991607
第(1)次请求数据,线程名:pool-1-thread-31,响应时间点:1536029996608
第(2)次请求数据,线程名:pool-1-thread-31,响应时间点:1536030001610
第(3)次请求数据,线程名:pool-1-thread-31,响应时间点:1536030006611
第31个线程:
第(0)次请求数据,线程名:pool-1-thread-32,响应时间点:1536029991607
第(1)次请求数据,线程名:pool-1-thread-32,响应时间点:1536029996608
第(2)次请求数据,线程名:pool-1-thread-32,响应时间点:1536030001609
第(3)次请求数据,线程名:pool-1-thread-32,响应时间点:1536030006611
第32个线程:
第(0)次请求数据,线程名:pool-1-thread-33,响应时间点:1536029991607
第(1)次请求数据,线程名:pool-1-thread-33,响应时间点:1536029996608
第(2)次请求数据,线程名:pool-1-thread-33,响应时间点:1536030001610
第(3)次请求数据,线程名:pool-1-thread-33,响应时间点:1536030006611
第33个线程:
第(0)次请求数据,线程名:pool-1-thread-34,响应时间点:1536029991606
第(1)次请求数据,线程名:pool-1-thread-34,响应时间点:1536029996608
第(2)次请求数据,线程名:pool-1-thread-34,响应时间点:1536030001609
第(3)次请求数据,线程名:pool-1-thread-34,响应时间点:1536030006611
第34个线程:
第(0)次请求数据,线程名:pool-1-thread-35,响应时间点:1536029991606
第(1)次请求数据,线程名:pool-1-thread-35,响应时间点:1536029996608
第(2)次请求数据,线程名:pool-1-thread-35,响应时间点:1536030001610
第(3)次请求数据,线程名:pool-1-thread-35,响应时间点:1536030006611
第35个线程:
第(0)次请求数据,线程名:pool-1-thread-36,响应时间点:1536029991605
第(1)次请求数据,线程名:pool-1-thread-36,响应时间点:1536029996607
第(2)次请求数据,线程名:pool-1-thread-36,响应时间点:1536030001607
第(3)次请求数据,线程名:pool-1-thread-36,响应时间点:1536030006608
第36个线程:
第(0)次请求数据,线程名:pool-1-thread-37,响应时间点:1536029991606
第(1)次请求数据,线程名:pool-1-thread-37,响应时间点:1536029996607
第(2)次请求数据,线程名:pool-1-thread-37,响应时间点:1536030001607
第(3)次请求数据,线程名:pool-1-thread-37,响应时间点:1536030006608
第37个线程:
第(0)次请求数据,线程名:pool-1-thread-38,响应时间点:1536029991606
第(1)次请求数据,线程名:pool-1-thread-38,响应时间点:1536029996607
第(2)次请求数据,线程名:pool-1-thread-38,响应时间点:1536030001607
第(3)次请求数据,线程名:pool-1-thread-38,响应时间点:1536030006608
第38个线程:
第(0)次请求数据,线程名:pool-1-thread-39,响应时间点:1536029991605
第(1)次请求数据,线程名:pool-1-thread-39,响应时间点:1536029996606
第(2)次请求数据,线程名:pool-1-thread-39,响应时间点:1536030001608
第(3)次请求数据,线程名:pool-1-thread-39,响应时间点:1536030006609
第39个线程:
第(0)次请求数据,线程名:pool-1-thread-40,响应时间点:1536029991605
第(1)次请求数据,线程名:pool-1-thread-40,响应时间点:1536029996606
第(2)次请求数据,线程名:pool-1-thread-40,响应时间点:1536030001607
第(3)次请求数据,线程名:pool-1-thread-40,响应时间点:1536030006608
第40个线程:
第(0)次请求数据,线程名:pool-1-thread-41,响应时间点:1536029991610
第(1)次请求数据,线程名:pool-1-thread-41,响应时间点:1536029996611
第(2)次请求数据,线程名:pool-1-thread-41,响应时间点:1536030001612
第(3)次请求数据,线程名:pool-1-thread-41,响应时间点:1536030006613
第41个线程:
第(0)次请求数据,线程名:pool-1-thread-42,响应时间点:1536029991610
第(1)次请求数据,线程名:pool-1-thread-42,响应时间点:1536029996611
第(2)次请求数据,线程名:pool-1-thread-42,响应时间点:1536030001611
第(3)次请求数据,线程名:pool-1-thread-42,响应时间点:1536030006613
第42个线程:
第(0)次请求数据,线程名:pool-1-thread-43,响应时间点:1536029991609
第(1)次请求数据,线程名:pool-1-thread-43,响应时间点:1536029996610
第(2)次请求数据,线程名:pool-1-thread-43,响应时间点:1536030001611
第(3)次请求数据,线程名:pool-1-thread-43,响应时间点:1536030006612
第43个线程:
第(0)次请求数据,线程名:pool-1-thread-44,响应时间点:1536029991610
第(1)次请求数据,线程名:pool-1-thread-44,响应时间点:1536029996611
第(2)次请求数据,线程名:pool-1-thread-44,响应时间点:1536030001612
第(3)次请求数据,线程名:pool-1-thread-44,响应时间点:1536030006613
第44个线程:
第(0)次请求数据,线程名:pool-1-thread-45,响应时间点:1536029991609
第(1)次请求数据,线程名:pool-1-thread-45,响应时间点:1536029996611
第(2)次请求数据,线程名:pool-1-thread-45,响应时间点:1536030001612
第(3)次请求数据,线程名:pool-1-thread-45,响应时间点:1536030006613
第45个线程:
第(0)次请求数据,线程名:pool-1-thread-46,响应时间点:1536029991609
第(1)次请求数据,线程名:pool-1-thread-46,响应时间点:1536029996610
第(2)次请求数据,线程名:pool-1-thread-46,响应时间点:1536030001611
第(3)次请求数据,线程名:pool-1-thread-46,响应时间点:1536030006612
第46个线程:
第(0)次请求数据,线程名:pool-1-thread-47,响应时间点:1536029991609
第(1)次请求数据,线程名:pool-1-thread-47,响应时间点:1536029996610
第(2)次请求数据,线程名:pool-1-thread-47,响应时间点:1536030001611
第(3)次请求数据,线程名:pool-1-thread-47,响应时间点:1536030006612
第47个线程:
第(0)次请求数据,线程名:pool-1-thread-48,响应时间点:1536029991610
第(1)次请求数据,线程名:pool-1-thread-48,响应时间点:1536029996611
第(2)次请求数据,线程名:pool-1-thread-48,响应时间点:1536030001612
第(3)次请求数据,线程名:pool-1-thread-48,响应时间点:1536030006613
第48个线程:
第(0)次请求数据,线程名:pool-1-thread-49,响应时间点:1536029991611
第(1)次请求数据,线程名:pool-1-thread-49,响应时间点:1536029996613
第(2)次请求数据,线程名:pool-1-thread-49,响应时间点:1536030001616
第(3)次请求数据,线程名:pool-1-thread-49,响应时间点:1536030006617
第49个线程:
第(0)次请求数据,线程名:pool-1-thread-50,响应时间点:1536029991611
第(1)次请求数据,线程名:pool-1-thread-50,响应时间点:1536029996613
第(2)次请求数据,线程名:pool-1-thread-50,响应时间点:1536030001617
第(3)次请求数据,线程名:pool-1-thread-50,响应时间点:1536030006617
第50个线程:
第(0)次请求数据,线程名:pool-1-thread-51,响应时间点:1536029991611
第(1)次请求数据,线程名:pool-1-thread-51,响应时间点:1536029996613
第(2)次请求数据,线程名:pool-1-thread-51,响应时间点:1536030001617
第(3)次请求数据,线程名:pool-1-thread-51,响应时间点:1536030006617
第51个线程:
第(0)次请求数据,线程名:pool-1-thread-52,响应时间点:1536029991611
第(1)次请求数据,线程名:pool-1-thread-52,响应时间点:1536029996612
第(2)次请求数据,线程名:pool-1-thread-52,响应时间点:1536030001613
第(3)次请求数据,线程名:pool-1-thread-52,响应时间点:1536030006614
第52个线程:
第(0)次请求数据,线程名:pool-1-thread-53,响应时间点:1536029991611
第(1)次请求数据,线程名:pool-1-thread-53,响应时间点:1536029996612
第(2)次请求数据,线程名:pool-1-thread-53,响应时间点:1536030001614
第(3)次请求数据,线程名:pool-1-thread-53,响应时间点:1536030006616
第53个线程:
第(0)次请求数据,线程名:pool-1-thread-54,响应时间点:1536029991611
第(1)次请求数据,线程名:pool-1-thread-54,响应时间点:1536029996612
第(2)次请求数据,线程名:pool-1-thread-54,响应时间点:1536030001614
第(3)次请求数据,线程名:pool-1-thread-54,响应时间点:1536030006615
第54个线程:
第(0)次请求数据,线程名:pool-1-thread-55,响应时间点:1536029991610
第(1)次请求数据,线程名:pool-1-thread-55,响应时间点:1536029996612
第(2)次请求数据,线程名:pool-1-thread-55,响应时间点:1536030001613
第(3)次请求数据,线程名:pool-1-thread-55,响应时间点:1536030006614
第55个线程:
第(0)次请求数据,线程名:pool-1-thread-56,响应时间点:1536029991610
第(1)次请求数据,线程名:pool-1-thread-56,响应时间点:1536029996611
第(2)次请求数据,线程名:pool-1-thread-56,响应时间点:1536030001612
第(3)次请求数据,线程名:pool-1-thread-56,响应时间点:1536030006613
第56个线程:
第(0)次请求数据,线程名:pool-1-thread-57,响应时间点:1536029991610
第(1)次请求数据,线程名:pool-1-thread-57,响应时间点:1536029996612
第(2)次请求数据,线程名:pool-1-thread-57,响应时间点:1536030001613
第(3)次请求数据,线程名:pool-1-thread-57,响应时间点:1536030006615
第57个线程:
第(0)次请求数据,线程名:pool-1-thread-58,响应时间点:1536029991610
第(1)次请求数据,线程名:pool-1-thread-58,响应时间点:1536029996612
第(2)次请求数据,线程名:pool-1-thread-58,响应时间点:1536030001613
第(3)次请求数据,线程名:pool-1-thread-58,响应时间点:1536030006614
第58个线程:
第(0)次请求数据,线程名:pool-1-thread-59,响应时间点:1536029991612
第(1)次请求数据,线程名:pool-1-thread-59,响应时间点:1536029996613
第(2)次请求数据,线程名:pool-1-thread-59,响应时间点:1536030001616
第(3)次请求数据,线程名:pool-1-thread-59,响应时间点:1536030006617
第59个线程:
第(0)次请求数据,线程名:pool-1-thread-60,响应时间点:1536029991612
第(1)次请求数据,线程名:pool-1-thread-60,响应时间点:1536029996613
第(2)次请求数据,线程名:pool-1-thread-60,响应时间点:1536030001616
第(3)次请求数据,线程名:pool-1-thread-60,响应时间点:1536030006617
第60个线程:
第(0)次请求数据,线程名:pool-1-thread-61,响应时间点:1536029991612
第(1)次请求数据,线程名:pool-1-thread-61,响应时间点:1536029996613
第(2)次请求数据,线程名:pool-1-thread-61,响应时间点:1536030001616
第(3)次请求数据,线程名:pool-1-thread-61,响应时间点:1536030006617
第61个线程:
第(0)次请求数据,线程名:pool-1-thread-62,响应时间点:1536029991612
第(1)次请求数据,线程名:pool-1-thread-62,响应时间点:1536029996613
第(2)次请求数据,线程名:pool-1-thread-62,响应时间点:1536030001615
第(3)次请求数据,线程名:pool-1-thread-62,响应时间点:1536030006616
第62个线程:
第(0)次请求数据,线程名:pool-1-thread-63,响应时间点:1536029991612
第(1)次请求数据,线程名:pool-1-thread-63,响应时间点:1536029996613
第(2)次请求数据,线程名:pool-1-thread-63,响应时间点:1536030001615
第(3)次请求数据,线程名:pool-1-thread-63,响应时间点:1536030006616
第63个线程:
第(0)次请求数据,线程名:pool-1-thread-64,响应时间点:1536029991612
第(1)次请求数据,线程名:pool-1-thread-64,响应时间点:1536029996613
第(2)次请求数据,线程名:pool-1-thread-64,响应时间点:1536030001614
第(3)次请求数据,线程名:pool-1-thread-64,响应时间点:1536030006616
第64个线程请求超时了
第65个线程请求超时了
第66个线程请求超时了
第67个线程请求超时了
第68个线程请求超时了
第69个线程请求超时了
第70个线程:
第(0)次请求数据,线程名:pool-1-thread-2,响应时间点:1536030011606
第(1)次请求数据,线程名:pool-1-thread-2,响应时间点:1536030016606
第(2)次请求数据,线程名:pool-1-thread-2,响应时间点:1536030021607
第(3)次请求数据,线程名:pool-1-thread-2,响应时间点:1536030026607
第71个线程:
第(0)次请求数据,线程名:pool-1-thread-11,响应时间点:1536030011606
第(1)次请求数据,线程名:pool-1-thread-11,响应时间点:1536030016606
第(2)次请求数据,线程名:pool-1-thread-11,响应时间点:1536030021607
第(3)次请求数据,线程名:pool-1-thread-11,响应时间点:1536030026607
第72个线程:
第(0)次请求数据,线程名:pool-1-thread-14,响应时间点:1536030011607
第(1)次请求数据,线程名:pool-1-thread-14,响应时间点:1536030016607
第(2)次请求数据,线程名:pool-1-thread-14,响应时间点:1536030021609
第(3)次请求数据,线程名:pool-1-thread-14,响应时间点:1536030026609
第73个线程:
第(0)次请求数据,线程名:pool-1-thread-12,响应时间点:1536030011607
第(1)次请求数据,线程名:pool-1-thread-12,响应时间点:1536030016607
第(2)次请求数据,线程名:pool-1-thread-12,响应时间点:1536030021608
第(3)次请求数据,线程名:pool-1-thread-12,响应时间点:1536030026608
第74个线程:
第(0)次请求数据,线程名:pool-1-thread-7,响应时间点:1536030011607
第(1)次请求数据,线程名:pool-1-thread-7,响应时间点:1536030016607
第(2)次请求数据,线程名:pool-1-thread-7,响应时间点:1536030021608
第(3)次请求数据,线程名:pool-1-thread-7,响应时间点:1536030026609
第75个线程:
第(0)次请求数据,线程名:pool-1-thread-8,响应时间点:1536030011607
第(1)次请求数据,线程名:pool-1-thread-8,响应时间点:1536030016607
第(2)次请求数据,线程名:pool-1-thread-8,响应时间点:1536030021609
第(3)次请求数据,线程名:pool-1-thread-8,响应时间点:1536030026609
第76个线程:
第(0)次请求数据,线程名:pool-1-thread-15,响应时间点:1536030011607
第(1)次请求数据,线程名:pool-1-thread-15,响应时间点:1536030016607
第(2)次请求数据,线程名:pool-1-thread-15,响应时间点:1536030021608
第(3)次请求数据,线程名:pool-1-thread-15,响应时间点:1536030026609
第77个线程:
第(0)次请求数据,线程名:pool-1-thread-13,响应时间点:1536030011607
第(1)次请求数据,线程名:pool-1-thread-13,响应时间点:1536030016607
第(2)次请求数据,线程名:pool-1-thread-13,响应时间点:1536030021609
第(3)次请求数据,线程名:pool-1-thread-13,响应时间点:1536030026609
第78个线程:
第(0)次请求数据,线程名:pool-1-thread-36,响应时间点:1536030011609
第(1)次请求数据,线程名:pool-1-thread-36,响应时间点:1536030016609
第(2)次请求数据,线程名:pool-1-thread-36,响应时间点:1536030021610
第(3)次请求数据,线程名:pool-1-thread-36,响应时间点:1536030026610
第79个线程:
第(0)次请求数据,线程名:pool-1-thread-40,响应时间点:1536030011609
第(1)次请求数据,线程名:pool-1-thread-40,响应时间点:1536030016609
第(2)次请求数据,线程名:pool-1-thread-40,响应时间点:1536030021610
第(3)次请求数据,线程名:pool-1-thread-40,响应时间点:1536030026610
第80个线程:
第(0)次请求数据,线程名:pool-1-thread-38,响应时间点:1536030011609
第(1)次请求数据,线程名:pool-1-thread-38,响应时间点:1536030016609
第(2)次请求数据,线程名:pool-1-thread-38,响应时间点:1536030021610
第(3)次请求数据,线程名:pool-1-thread-38,响应时间点:1536030026610
第81个线程:
第(0)次请求数据,线程名:pool-1-thread-37,响应时间点:1536030011609
第(1)次请求数据,线程名:pool-1-thread-37,响应时间点:1536030016609
第(2)次请求数据,线程名:pool-1-thread-37,响应时间点:1536030021610
第(3)次请求数据,线程名:pool-1-thread-37,响应时间点:1536030026610
第82个线程:
第(0)次请求数据,线程名:pool-1-thread-18,响应时间点:1536030011609
第(1)次请求数据,线程名:pool-1-thread-18,响应时间点:1536030016609
第(2)次请求数据,线程名:pool-1-thread-18,响应时间点:1536030021610
第(3)次请求数据,线程名:pool-1-thread-18,响应时间点:1536030026610
第83个线程:
第(0)次请求数据,线程名:pool-1-thread-17,响应时间点:1536030011610
第(1)次请求数据,线程名:pool-1-thread-17,响应时间点:1536030016610
第(2)次请求数据,线程名:pool-1-thread-17,响应时间点:1536030021611
第(3)次请求数据,线程名:pool-1-thread-17,响应时间点:1536030026611
第84个线程:
第(0)次请求数据,线程名:pool-1-thread-16,响应时间点:1536030011610
第(1)次请求数据,线程名:pool-1-thread-16,响应时间点:1536030016610
第(2)次请求数据,线程名:pool-1-thread-16,响应时间点:1536030021611
第(3)次请求数据,线程名:pool-1-thread-16,响应时间点:1536030026611
第85个线程:
第(0)次请求数据,线程名:pool-1-thread-39,响应时间点:1536030011610
第(1)次请求数据,线程名:pool-1-thread-39,响应时间点:1536030016610
第(2)次请求数据,线程名:pool-1-thread-39,响应时间点:1536030021611
第(3)次请求数据,线程名:pool-1-thread-39,响应时间点:1536030026611
第86个线程:
第(0)次请求数据,线程名:pool-1-thread-28,响应时间点:1536030011611
第(1)次请求数据,线程名:pool-1-thread-28,响应时间点:1536030016611
第(2)次请求数据,线程名:pool-1-thread-28,响应时间点:1536030021612
第(3)次请求数据,线程名:pool-1-thread-28,响应时间点:1536030026612
第87个线程:
第(0)次请求数据,线程名:pool-1-thread-24,响应时间点:1536030011611
第(1)次请求数据,线程名:pool-1-thread-24,响应时间点:1536030016611
第(2)次请求数据,线程名:pool-1-thread-24,响应时间点:1536030021612
第(3)次请求数据,线程名:pool-1-thread-24,响应时间点:1536030026612
第88个线程:
第(0)次请求数据,线程名:pool-1-thread-26,响应时间点:1536030011611
第(1)次请求数据,线程名:pool-1-thread-26,响应时间点:1536030016611
第(2)次请求数据,线程名:pool-1-thread-26,响应时间点:1536030021612
第(3)次请求数据,线程名:pool-1-thread-26,响应时间点:1536030026612
第89个线程:
第(0)次请求数据,线程名:pool-1-thread-25,响应时间点:1536030011611
第(1)次请求数据,线程名:pool-1-thread-25,响应时间点:1536030016611
第(2)次请求数据,线程名:pool-1-thread-25,响应时间点:1536030021612
第(3)次请求数据,线程名:pool-1-thread-25,响应时间点:1536030026612
第90个线程:
第(0)次请求数据,线程名:pool-1-thread-29,响应时间点:1536030011611
第(1)次请求数据,线程名:pool-1-thread-29,响应时间点:1536030016611
第(2)次请求数据,线程名:pool-1-thread-29,响应时间点:1536030021612
第(3)次请求数据,线程名:pool-1-thread-29,响应时间点:1536030026612
第91个线程:
第(0)次请求数据,线程名:pool-1-thread-3,响应时间点:1536030011611
第(1)次请求数据,线程名:pool-1-thread-3,响应时间点:1536030016611
第(2)次请求数据,线程名:pool-1-thread-3,响应时间点:1536030021612
第(3)次请求数据,线程名:pool-1-thread-3,响应时间点:1536030026612
第92个线程:
第(0)次请求数据,线程名:pool-1-thread-33,响应时间点:1536030011612
第(1)次请求数据,线程名:pool-1-thread-33,响应时间点:1536030016612
第(2)次请求数据,线程名:pool-1-thread-33,响应时间点:1536030021613
第(3)次请求数据,线程名:pool-1-thread-33,响应时间点:1536030026613
第93个线程:
第(0)次请求数据,线程名:pool-1-thread-22,响应时间点:1536030011612
第(1)次请求数据,线程名:pool-1-thread-22,响应时间点:1536030016612
第(2)次请求数据,线程名:pool-1-thread-22,响应时间点:1536030021613
第(3)次请求数据,线程名:pool-1-thread-22,响应时间点:1536030026613
第94个线程:
第(0)次请求数据,线程名:pool-1-thread-31,响应时间点:1536030011612
第(1)次请求数据,线程名:pool-1-thread-31,响应时间点:1536030016612
第(2)次请求数据,线程名:pool-1-thread-31,响应时间点:1536030021613
第(3)次请求数据,线程名:pool-1-thread-31,响应时间点:1536030026613
第95个线程:
第(0)次请求数据,线程名:pool-1-thread-32,响应时间点:1536030011612
第(1)次请求数据,线程名:pool-1-thread-32,响应时间点:1536030016612
第(2)次请求数据,线程名:pool-1-thread-32,响应时间点:1536030021613
第(3)次请求数据,线程名:pool-1-thread-32,响应时间点:1536030026613
第96个线程:
第(0)次请求数据,线程名:pool-1-thread-35,响应时间点:1536030011612
第(1)次请求数据,线程名:pool-1-thread-35,响应时间点:1536030016612
第(2)次请求数据,线程名:pool-1-thread-35,响应时间点:1536030021613
第(3)次请求数据,线程名:pool-1-thread-35,响应时间点:1536030026613
第97个线程:
第(0)次请求数据,线程名:pool-1-thread-34,响应时间点:1536030011612
第(1)次请求数据,线程名:pool-1-thread-34,响应时间点:1536030016612
第(2)次请求数据,线程名:pool-1-thread-34,响应时间点:1536030021613
第(3)次请求数据,线程名:pool-1-thread-34,响应时间点:1536030026613
第98个线程:
第(0)次请求数据,线程名:pool-1-thread-30,响应时间点:1536030011613
第(1)次请求数据,线程名:pool-1-thread-30,响应时间点:1536030016613
第(2)次请求数据,线程名:pool-1-thread-30,响应时间点:1536030021614
第(3)次请求数据,线程名:pool-1-thread-30,响应时间点:1536030026614
第99个线程:
第(0)次请求数据,线程名:pool-1-thread-47,响应时间点:1536030011613
第(1)次请求数据,线程名:pool-1-thread-47,响应时间点:1536030016613
第(2)次请求数据,线程名:pool-1-thread-47,响应时间点:1536030021614
第(3)次请求数据,线程名:pool-1-thread-47,响应时间点:1536030026614
我们把池子大小固定为64(基本大小、最大大小均为64),然后丢进去100个请求线程,超出的36个会先放到一个无界队列中,等池中看有哪个线程已经服务完老请求了再出来接新客户。另外我们故意把服务时间加长了(每次数据请求休眠5秒),这会导致有部分线程在获取结果超时。关于超时需要注意的是,所设置的3秒超时针对的是获取结果等待的时间,跟每个线程执行的时延是两码事。仔细看一下上面的输出,池子中线程名打印出来的其实还没到64个,也就是重复利用的线程并未全部出场,超时的有12个。当我丢一万个请求线程时,会发生什么?
这一行改为:
t.poolTest(10000, 4, 1);
每个任务的服务时间从5秒缩减到1秒,增加了池中线程的处理速度,但请求达到率暴增到10000,虽然无界队列可以容得下那9936个人客户,但64个服务生已经忙不过来了,现在控制台只有无尽的TimeOut异常了。为了能看到过程,我们把控制台的日志记录到文件里,在poolTest最后加入:
// 打印到文件里 try { PrintStream ps = new PrintStream("D:\ThreadPoolTest.txt"); System.setOut(ps); } catch (FileNotFoundException e) { e.printStackTrace(); } System.out.println(result);
现在控制台依然是无尽的TimeOut异常,但我们去看ThreadPoolTest.txt,会发现服务线程还是有服务的。我的文件里超时是157个,占比也不算多。但如果我再把响应时间提高到2秒呢?超时314个。如果放到生产环境,很明显,池子还是得爆,因为请求不是一万个就完事了,而是源源不断的累加而来。还是那句话,只要请求到达率超过池的处理速度,迟早要出事。