newFixedThreadPool例子无法运行求解

Question

@Test
public void test1() {
    ExecutorService fixedThreadPool = Executors.newFixedThreadPool(3);
    for (int i = 0; i < 10; i++) {
        final int index = i;
        fixedThreadPool.execute(new Runnable() {

            @Override
            public void run() {
                try {
                    System.out.println(index);
                    Thread.sleep(2000);
                } catch (Exception e) {
                    e.printStackTrace();
                } 
            }
        });
    }
}

以上是我在别的博客找到的例子，但是这个例子无法实现“每2秒打印3个数字”这个效果。前三个线程被执行，但是后面加入的都不行。for并没有被阻塞。

Answer 1

非main函数下，你的测试函数的主线程，不会等待线程池中的其他线程结束，就结束线程了！你改成主函数就正常了，改成被主函数调用也正常了。也可以在测试函数的for循环外增加等待时间，或者增加判断所以线程是否完全结束。