java并发测试用例模板

这里申请了1000个线程，并且执行1000次任务。当所有任务完成后，main退出。

public class Test {
     public static void main(String[] args) {
          int count = 1000;
          ExecutorService executorService = Executors.newFixedThreadPool(count);
          for (int i = 0; i < count; i++)
               executorService.execute(new Test().new Task());

          executorService.shutdown();
          while (!executorService.isTerminated()) {
               try {
                    Thread.sleep(10);
               } catch (InterruptedException e) {
                    e.printStackTrace();
               }
          }
     }

     public class Task implements Runnable {

          @Override
          public void run() {
               try {
                    // 测试内容
               } catch (Exception e) {
                    e.printStackTrace();
               }
          }
     }
}

如果要实现真正的并发同时执行，可通过CyclicBarrier来控制。

public class Test {
     public static void main(String[] args) {
          int count = 1000;
          CyclicBarrier cyclicBarrier = new CyclicBarrier(count);
          ExecutorService executorService = Executors.newFixedThreadPool(count);
          for (int i = 0; i < count; i++)
               executorService.execute(new Test().new Task(cyclicBarrier));

          executorService.shutdown();
          while (!executorService.isTerminated()) {
               try {
                    Thread.sleep(10);
               } catch (InterruptedException e) {
                    e.printStackTrace();
               }
          }
     }

     public class Task implements Runnable {
          private CyclicBarrier cyclicBarrier;

          public Task(CyclicBarrier cyclicBarrier) {
               this.cyclicBarrier = cyclicBarrier;
          }

          @Override
          public void run() {
               try {
                    // 等待所有任务准备就绪
                    cyclicBarrier.await();
                    // 测试内容
               } catch (Exception e) {
                    e.printStackTrace();
               }
          }
     }
}

评论

3 楼 flysnowxf 2014-05-26  

shibin_1109 写道

10-16行为什么要让没有执行完的线程睡眠呢?找了好久不理解为什么?还有那个Thread是正在执行的线程么?

很久没来这里了，不好意思。在main函数这个Thread中，Thread.sleep(10)指的就是这个main进程。executorService是异步执行任务的，如果不通过executorService.isTerminated()来休眠main进程，那么1000个Task任务都没有执行完，main就先执行完了然后关掉了整个程序。你去掉while那段代码试试，你会发现刚运行然后程序就结束了。

2 楼 shibin_1109 2014-03-31  

10-16行为什么要让没有执行完的线程睡眠呢?找了好久不理解为什么?还有那个Thread是正在执行的线程么?

1 楼 xuhang1128 2013-07-23  

good！