如何让executor服务等待所有线程完成

Question

有时我看到一些线程还没有完成他们的工作，服务杀死那个线程，我怎么能强迫服务等待，直到线程完成他们的工作？

这是我的代码：

        ExecutorService pool = Executors.newFixedThreadPool(10);
        List<Future<List<Book>>> futures = Lists.newArrayList();
        final ObjectMapper mapper1 = new ObjectMapper();
        for (final Author a : authors) {
            futures.add(pool.submit(new Callable<List<Book>>() {
                @Override
                public List<Book> call() throws Exception {
                    String urlStr = "http://localhost/api/book?limit=5000&authorId=" + a.getId();

                    List<JsonBook> Jsbooks = mapper1.readValue(
                            new URL(urlStr), BOOK_LIST_TYPE_REFERENCE);

                    List<Book> books = Lists.newArrayList();
                    for (JsonBook jsonBook : Jsbooks) {
                        books.add(jsonBook.toAvro());
                    }

                    return books;
                }
            }));
        }
        pool.shutdown();
        pool.awaitTermination(3, TimeUnit.MINUTES);

      List<Book> bookList = Lists.newArrayList();
    for (Future<List<Book>> future : futures) {
        if (!future.isDone()) {
           LogUtil.info("future " + future.toString());  <-- future not finished yet 
           throw new RuntimeException("Future to retrieve books: " + future + " did not complete");

}
        bookList.addAll(future.get());
    }

我看到了一些例外。future.is完成（））块。我怎么能确保每一个未来是当执行者服务关闭？

Answer 1

我喜欢用倒计时锁。

将闩锁设置为您正在迭代的大小，并将该闩锁传递到可调用项中，然后在run/call方法中使用try/finally块来递减倒计时闩锁。

在所有事情都进入executor服务队列后，只需调用闩锁的wait方法，该方法将一直阻塞，直到完成所有操作。届时，您的所有可调用项都将完成，您可以正确地关闭executor服务。

这个链接有一个如何设置的示例。http://docs.oracle.com/javase/7/docs/api/java/util/concurrent/CountDownLatch.html