Блог

Главная - Вопросы по программированию - Является ли метод invokeAny от Java ExecutorService однопоточным исполнителем, гарантированно возвращающим результаты первой задачи, которая успешно завершается

Является ли метод invokeAny от Java ExecutorService однопоточным исполнителем, гарантированно возвращающим результаты первой задачи, которая успешно завершается

#java #multithreading #executorservice #invoke #callable

Вопрос:

В настоящее время я готовлю свой профессиональный сертификационный экзамен Oracle Java, и у меня возникли некоторые проблемы с пониманием этого метода из интерфейса ExecutorService под названием invokeAny(). Что меня беспокоит, так это не основная функция этого метода. Я знаю, что этот метод предназначен для возврата результата одной из вызываемых задач из списка вызываемых объектов, которые передаются этому методу в качестве параметра, и отмены других задач. Что меня смущает, так это то, что в официальной документации Java говорится следующее:

«Результаты этого метода не определены, если данная коллекция была изменена во время выполнения этой операции».

И в моем руководстве по OCP говорится:

«Хотя часто возвращается первая завершенная задача, такое поведение не гарантируется, так как этим методом может быть возвращена любая завершенная задача».

Но что делать, если набор задач не изменяется во время выполнения. Я протестировал этот метод, используя как исполнителя с одним потоком, так и исполнителя пула фиксированных потоков с произвольным количеством потоков(16) для исполнителя пула фиксированных потоков, и в случае исполнителя с одним потоком, который гарантирует, что задачи всегда будут выполняться последовательно, invokeAny всегда возвращает результат первой задачи, которая успешно завершается.

Моя главная проблема в том, что:

Если я получу вопрос на экзамене, например, чтобы угадать результаты следующего кода:

 ExecutorService executorService = Executors.newSingleThreadExecutor();
List<Callable<String>> callables = new ArrayList<>();
callables.add(() -> "Task1");
callables.add(() -> "Task2");
callables.add(() -> "Task3");

String result = null;
try {
   result = executorService.invokeAny(callables);
} catch (InterruptedException e) {
     e.printStackTrace();
} catch (ExecutionException e) {
     e.printStackTrace();
}
System.out.println(result);
executorService.shutdown();

И вопрос в том,:

Каков результат следующего кода:

A. Задача 1 B. Задача 2 C. Задача 3 D. Результат не определен.

Когда я выполняю этот код, я всегда получаю строку Task1 в результате, потому что исполнитель с одним потоком последовательно выполняет задачи в одном отдельном потоке, начиная с первой задачи, в то время как другие задачи ждут, и если используется фиксированный пул потоков, то задачи завершаются недетерминированным образом.

Итак, каким должен быть мой ответ на экзамене, когда я использую исполнителя с одним потоком: A или D?

Метки: , ,