有些场景下，你可能要检查代码有没有并发问题，验证幂等或者做一下简单的压力测试， 这时候需要写一个并发请求的程序，那么怎么做呢？
先上代码
final long time_start = System.currentTimeMillis();
ExecutorService service = Executors.newFixedThreadPool(10);
int client_num = 10;
final CountDownLatch countDownLatch = new CountDownLatch(1);
for (int i = 0; i < client_num; i++) {
Runnable job = new Runnable() {
@Override
public void run() {
Worker worker = new Worker();
try {
countDownLatch.await();
worker.doWork();
}catch(Exception e){
e.printStackTrace();
}
}
};
service.submit(job);
}
countDownLatch.countDown();
service.shutdown();
while (!service.isTerminated()) {
}
System.out.println("time consuming is " + (System.currentTimeMillis() - time_start));
我们来拆解下这个Case，看看都做了些什么：
1. 容器准备
首先，你需要一个线程池来调用任务处理，虽然你可以每次new一个线程来做，但是无论是在生产环境还是测试，都不太建议这样做。本示例用的是
ExecutorService service = Executors.newFixedThreadPool(10) 其效果是构造一个固定线程数的线程池，这个线程池的coreSize和maxSize都是10， 也就是说，最多可以同时处理10个任务，多了的就要排队。
线程池装载完任务后，执行submit , 但是此时任务并未执行，具体原因看下面。
2. 并发执行
这里是比较tricky的一个点，因为要模拟完全并发的情况，就要保证所有任务同一时间触发，这里我们用了一个java.util.concurrent的工具类 CountDownLatch， 从名字大概可以猜测到，这个是一个像栅栏一样的工具，先把羊圈在里面，等count数到0的时候，打开栅栏，放出群羊。。
使用步骤： 首先，初始化countDownLatch计数为1。 然后， 在业务代码里在执行业务逻辑之前我们嵌入了一行 countDownLatch.await() 。最后， 当所有任务都装载完毕提交后，执行countDownLatch.countDown()，如同发令枪一般，所有的任务同时触发，并发量达到client_num的数量10。
3. 任务结束
任务结束的时候调用的是线程池的shutdown方法, 看一下这个方法的注释
Attempts to stop all actively executing tasks, halts the processing of waiting tasks, and returns a list of the tasks that were awaiting execution.
意思是这个方法只是尝试去停止所有任务，但是并不保证都能结束，并且没有结束的任务是以list返回的。
所以后面又跟了一个
while (!service.isTerminated()) {
}
循环一直等待所有的任务结束完毕，最后再统计所有任务的执行时间。
结语
这是一段比较简单的并发测试代码，单元测试足够用，但是如果用做规模化的压力测试，还需要考虑压力机与测试机的连接以及数据热点等一系列问题，这又是个很大的话题了。
