Java Multi-Thread Палач InvokeAll Проблемы

Question

код У меня возникли проблемы с является:

Executor executor = (Executor) callList; 

    List<ProgState> newProgList = executor.invokeAll(callList).stream() 
      .map(future -> {try {return future.get();} catch(Exception e){e.printStackTrace();}}) 
      .filter(p -> p!=null).collect(Collectors.toList()); 

Метод invokeAll (List>) не определено для типа Исполнителю

Я сказал, что я должен использовать исполнителя, как тот, что в фрагменте кода.

В вызываемых объектов определяются в следующем коде:

List<Callable<ProgState>> callList = (List<Callable<ProgState>>) lst.stream() 
      .map(p -> ((Callable<ProgState>)(() -> {return p.oneStep();}))) 
      .collect(Collectors.toList()); 

Вот код учителя:

//prepare the list of callables 

List<Callable<PrgState>> callList = prgList.stream().map(p -> (() -> {return p.oneStep();})).collect(Collectors.toList()); 

//start the execution of the callables 
//it returns the list of new created threads 

List<PrgState> newPrgList = executor.invokeAll(callList).stream() 
.map(future -> { try { 
return future.get(); 
} 
catch(Exception e) { 

//here you can treat the possible 
// exceptions thrown by statements 
// execution 

} 
}) 
.filter(p -> p!=null).collect(Collectors.toList()); 


//add the new created threads to the list of existing threads 

prgList.addAll(newPrgList); 

Answer 1

Вы не можете бросить список вызываемых объектов с ExecutorService. Вам необходимо определить ExecutorService, который будет забирать вызовы и выполнять их в одном или нескольких потоках параллельно.

Это то, что я думаю, что вы после:

ExecutorService executor = Executors.newCachedThreadPool();//change executor type as per your need. 
List<ProgState> newProgList = executor.invokeAll(callList).stream().map(future -> {... 

Answer 2

Если вы можете использовать поток(), почему бы не parallelStream(), как это было бы гораздо проще.

List<PrgState> prgStates = prgList.parallelStream() 
            .map(p -> p.oneStep()) 
            .collect(Collectors.toList()); 

Таким образом, у вас нет пула потоков для настройки, запуска или остановки по завершении.

Возможно, что parallelStream() был основной причиной добавления Stream и lambdas в Java 8. ;)