我需要并行执行两个任务,然后等待它们完成。我还需要第二个任务的结果,因为我正在使用Future

我的问题是我是否需要executor.awaitTermination来加入任务,否则Future.get()会照顾好它。还有使用Java 8实现此目标的更好方法吗?

public class Test {

    public static void main(String[] args) {
        test();
        System.out.println("Exiting Main");
    }

    public static void test() {
        System.out.println("In Test");
        ExecutorService executor = Executors.newFixedThreadPool(2);

        executor.submit(() -> {
            for(int i = 0 ; i< 5 ; i++) {
                System.out.print("["+i+"]");
                try {
                    Thread.sleep(1000);
                } catch (Exception e) {e.printStackTrace();}
            }
        });

        Future<String> result = executor.submit(() -> {
            StringBuilder builder = new StringBuilder();
            for(int i = 0 ; i< 10 ; i++) {
                System.out.print("("+i+")");
                try {
                    Thread.sleep(1000);
                } catch (Exception e) {e.printStackTrace();}
                builder.append(i);
            }
            return builder.toString();
        });

        System.out.println("shutdown");
        executor.shutdown();
        // DO I need this code : START
        System.out.println("awaitTermination");
        try {
            executor.awaitTermination(Long.MAX_VALUE, TimeUnit.NANOSECONDS);
        } catch (InterruptedException e) {
            System.out.println("Error");
        }
        // DO I need this code : END
        System.out.println("Getting result");
        try {
            System.out.println(result.get());
        }
        catch (InterruptedException e) {e.printStackTrace();}
        catch (ExecutionException e) {e.printStackTrace();}
        System.out.println("Exiting Test");
    }

}


使用awaitTermination的输出:

In Test
[0]shutdown
(0)awaitTermination
[1](1)[2](2)[3](3)[4](4)(5)(6)(7)(8)(9)Getting result
0123456789
Exiting Test
Exiting Main


没有awaitTermination的输出:

In Test
[0]shutdown
Getting result
(0)[1](1)[2](2)[3](3)[4](4)(5)(6)(7)(8)(9)0123456789
Exiting Test
Exiting Main

最佳答案

get javadoc:


  必要时等待计算完成,然后检索其结果。


get将仅等待第二个任务。

awaitTermination javadoc:


  阻塞直到关闭请求后所有任务完成执行,或者发生超时,或者当前线程被中断(以先发生者为准)。


awaitTermination将等待所有任务。

08-19 23:14