Блог

У меня есть WebMVC rest api. Один из моих методов rest — это «длительная задача». Моя первоначальная реализация заняла 100 секунд для завершения моих тестовых данных.

Мой второй подход состоял в том, чтобы разбить тестовые данные на страницы и использовать пул потоков. На моем уровне обслуживания у меня есть private final ExecutorService executor = Executors.newFixedThreadPool(8); , и я подчиняюсь ему List<Future<Page>> results = this.executor.invokeAll(pages); , сократив его до 45 секунд.

Вопрос заключается в ожидании всех страниц. Мне действительно нужны страницы для окончательного ответа json, поэтому я делаю:

         List<Future<Page>> results = this.executor.invokeAll(pages);

        for (Future<Page> result : results)
            result.get();
  

Если я это сделаю, я думаю, меня действительно не волнует порядок, в котором они заканчиваются, потому что они будут в правильном порядке в исходном списке страниц.

Но get() — это блокирующий вызов. Это вообще имеет значение в webmvc rest api?

Я могу заверить вас, что invokeAll возвращает список фьючерсов в том же порядке, что и переданные вызываемые объекты, т. Е. 3-й Callable<Page> в переданном pages списке является источником 3-го Future<Page> в results списке фьючерсов.

Возвращает: список фьючерсов, представляющих задачи, в том же последовательном порядке, который создается итератором для данного списка задач, каждая из которых завершена

Пока все хорошо, пока с вами все в порядке, они будут доступны после того, как все они вернутся true Future::isDone , нет способа получить доступ к промежуточным результатам с помощью такого метода.

Вы можете использовать несколько вызовов CompletableFuture::supplyAsync(Supplier<T>, Executor) для получения List<CompletableFuture<T>> , а затем CompletableFuture::thenAccept(Consumer<T>) выполнить действие по завершению, ожидая других результатов.

Минимальный образец, использующий a String вместо Page для краткости:

 Random random = new Random();
// simulate irregular delay
List<Callable<String>> pages = List.of(
    () -> { Thread.sleep(random .nextInt(3000) 2000); return "one";},
    () -> { Thread.sleep(random .nextInt(3000) 2000); return "two";},
    () -> { Thread.sleep(random .nextInt(3000) 2000); return "three";},
    () -> { Thread.sleep(random .nextInt(3000) 2000); return "four";},
    () -> { Thread.sleep(random .nextInt(3000) 2000); return "five";}
);

ExecutorService executor = Executors.newFixedThreadPool(8);
List<CompletableFuture<String>> results = pages.stream()
    .map(callable -> CompletableFuture.supplyAsync(
        // this should be wrapped into a method instead
        () -> { try {return callable.call();} catch (Exception ignore) {} return null; },
        executor))
    .collect(Collectors.toList());

// clumsy index print to demonstrate the immediate results
for (int i=0; i<results.size(); i  ) {
    int index = i;
    results.get(i).thenAccept(page -> System.out.println("Finished ("   index   ") : "   page));
}
  

К сожалению, создатели, похоже, хотели избежать любого использования проверяемых исключений при разработке CompatibleFuture , поэтому он несовместим с. Callable<T>