昨晚用Junit测试多线程,代码如下:
private int i = 3;
@Test
public void test() {
for (int i = 0; i < this.i; i ++) {
new Thread(new Runner()).start();
}
}
class Runner implements Runnable {
@Override
public void run() {
System.out.printlun(123);
}
}
发现运行后居然没有任何输出…我又运行了好几次,有时又有1~2句输出,但是始终不全…
当时还以为程序有错,clean了class继续,还是一样的,早上起来查了下百度,才明白,原来Junit只管自己的运行,是说当Junit执行完毕后,会关闭程序,不会关心是否还有自己启动的后台线程在运行。当Junit运行完毕后,如果后台线程还没有执行完毕,那么也是不会再执行了,所以出现了昨天的情况…
我始终对多线程的执行过程没有意识呢…主线程和后台线程的关系和执行一定要搞清楚呢…
现在既然搞清楚了,那好办了,下面代码展示如何优雅的将Junit主线程设置为同步线程:
private int i = 3;
/*
* 线程计数器
* 将线程数量初始化
* 每执行完成一条线程,调用countDown()使计数器减1
* 主线程调用方法await()使其等待,当计数器为0时才被执行
*/
private CountDownLatch latch = new CountDownLatch(i);
@Test
public void test() {
for (int i = 0; i < this.i; i ++) {
new Thread(new Runner()).start();
}
try {
latch.await(); // 主线程等待
} catch (InterruptedException e) {
e.printStackTrace();
}
}
class Runner implements Runnable {
@Override
public void run() {
System.out.printlun(123);
latch.countDown(); // 执行完毕,计数器减1
}
这样改变代码之后,一切正常了!