Preciso retornar de forma mais rápida uma lista de objetos. Para isto estou usando parallelStream().forEach(), chamando no corpo do foreach um método que retorna o objeto desejado e adicionando-o em um ArrayList. No entanto tenho retornos estranhos para o ArrayList, muitas vezes com elementos duplicados. Eu não poderia fazer desta forma? Teria outra forma de executar em paralelo?
public List<ProdutividadeSumarioIndividualDto> getProdutividadesFuncis(List<String> matriculas,
LocalDate dataInicial, LocalDate dataFinal) {
List<ProdutividadeSumarioIndividualDto> procs = new ArrayList<ProdutividadeSumarioIndividualDto>();
matriculas.parallelStream().forEach((x) -> {
try {
procs.add(this.prodControler.getProdutividadeFuncionario(x, dataInicial, dataFinal));
} catch (Exception e) {
e.printStackTrace();
}
});
return procs;
}
getProdutividadeFuncionario
faz? Uma chamada ao banco? Ou talvez a uma API? Não seria possível criar uma nova versão do método que receba uma lista de matrículas e retorne uma lista deProdutividadeSumarioIndividualDto
s? Essa seria a melhor solução. – Anthony Accioly 4/01 às 17:59List<ProdutividadeSumarioIndividualDto> procs = matriculas.parallelStream().map(m -> this.prodControler.getProdutividadeFuncionario(x, dataInicial, dataFinal)).collect(Collectors.toList());
para fazer as consultas em paralelo, porém essa é uma solução com muito mais overhead do que modificar ocontroller
. – Anthony Accioly 4/01 às 18:04ArrayList
não é thread-safe e a stream chamaadd
em paralelo. A melhor maneira realmente seria mudar o seu web-service para receber uma lista de matrículas (essa será a única solução que te poupará o overhead de n chamadas individuais de rede, etc). – Anthony Accioly 5/01 às 18:29m
e invoquei o método comx
. Acho que assim deve funcionar (só dá para afirmar com 100% de certeza se você editar a sua questão e postar um MVCE que eu possa fazer rodar):matriculas.parallelStream().map(m -> prodControler.getProdutividadeFuncionario(m, dataInicial, dataFinal)).collect(Collectors.toList());
. Novamente, o uso de requisições paralelas, ainda que potencialmente faça o código ficar bem mais rápido, não é a melhor solução para o problema. – Anthony Accioly 5/01 às 18:34