Как вызвать метод параллельно, который возвращает будущее?

Question

У меня есть метод async, как показано ниже, который вызывает мой класс Task и мой класс Task выполняет всю работу.

@Override 
    public Future<DataResponse> executeAsync(DataKey key) { 
     Future<DataResponse> future = null; 

     try { 
      Task task = new Task(key, restTemplate); 
      future = executor.submit(task); 
     } catch (Exception ex) { 
      // logging exception here 
     } 

     return future; 
    } 

Ниже мой Task класс, который делает всю работу:

public class Task implements Callable<DataResponse> { 

    private DataKey key; 
    private RestTemplate restTemplate; 

    public Task(DataKey key, RestTemplate restTemplate) { 
     this.key = key; 
     this.restTemplate = restTemplate; 
    } 

    @Override 
    public DataResponse call() throws Exception { 
     // some code here 
    } 
} 

Теперь мне нужно вызвать метод executeAsync параллельно, а затем сделать List<DataResponse> объект и вернуть его.

@Override 
public List<DataResponse> executeSync(DataKey key) { 
    List<DataResponse> responseList = new ArrayList<DataResponse>(); 

    // make a List of DataKey using single key passed to this method.  
    List<DataKey> keys = new ArrayList<DataKey>(); 

    for(DataKey key : keys) { 


    } 
} 

Как я могу назвать executeAsync метод параллельно и вернуться обратно responseList? В моем keys списке максимум у меня будет шесть объектов DataKey.

Answer 1

Если вы ожидаете вернуть List<DataResponse>, содержащий объекты DataResponse, которые были возвращены Task#call, вы не можете сделать это асинхронно. Вам нужно будет заблокировать внутри executeSync, чтобы дождаться результата всех фьючерсов.

List<Future> futures = new ArrayList<>(keys.size()); 
for(DataKey key : keys) { 
    Future<DataResponse> future = executeAsync(key); 
    futures.add(future); 
} 

for (Future<DataResponse> future : futures) { 
    try { 
     responseList.add(future.get()); 
    } catch (Exception e) { 
     // do something else. 
    } 
    return responseList 
} 

Более приемлемым решением с Future является использование CompletionService, как подробно описано here.

В Java 8 вы должны использовать CompletableFuture (или Guava's ListenableFuture) для асинхронных задач. Вы все еще можете сделать то, что я сделал выше, или вы можете изменить свой код, чтобы в полной мере использовать задачи продолжения.

Answer 2

Вы можете вызвать метод invokeAll службы-исполнителя и отправить ему список задач. Служба-исполнитель будет выполнять задачи параллельно.

https://docs.oracle.com/javase/7/docs/api/java/util/concurrent/ExecutorService.html#invokeAll(java.util.Collection)

Это было бы так же, как: 1. ссылающегося executeAsync параллельно от для цикла в методе executeSync. 2. вызов метода executeAsync последовательно из цикла for в методе executeSync.

Answer 3

Нет причин для его параллельного выполнения, поскольку он уже работает параллельно. Единственное, что вам нужно - это вызвать метод async для каждого из элементов и сохранить результат Future s в списке. По завершении этого цикла вам нужно пройти список тех Future s, и вызов get() на каждом из них даст результат. В этом списке результатов вы вернетесь как возвращаемое значение.