parallelo flusso dà elementi nulli, come fare in Java 8

Question

sto ottenendo alcuni risultati strani quando si cerca di utilizzare un flusso parallelo e so che una soluzione, ma non sembra l'ideale

// Create the set "selected" 
somethingDao.getSomethingList().parallelStream() 
       .filter(something -> !selected.contains(something.getSomethingId())) 
       .forEach(something -> 
           somethingSubGroupDTO.addFilterDTO(
             new FilterDTO(something.getSomethingName(), something.getSomethingDescription(), false)) 
       ); 
selected.clear(); 

somethingDao.getSomethingList restituisce un List

selected è un che non viene modificato durante questa operazione.

somethingSubGroupDTO.addFilterDTO è una funzione di supporto che si aggiunge a un elenco non sincronizzato. Questo è il problema. Come elenco non sincronizzato ottengo meno elementi nella lista del previsto E alcuni elementi sono nulli. Se lo trasformo in una lista sincronizzata funziona. Ovviamente aggiungere contesa di blocco a un flusso parallelo non è l'ideale.

Al livello alto, so che è possibile farlo in modo tale che ogni stream eseguirà la propria elaborazione e quando si uniranno si aggregheranno. (Almeno posso immaginare un tale processo senza contesa di blocco) Tuttavia, dato che sono nuovo nell'elaborazione del flusso Java 8, non sono a conoscenza di come. Come faccio a fare la stessa operazione senza contesa in un singolo punto?

Answer 1

Non utilizzare forEach e ritirare il flusso in un List invece:

somethingDao.getSomethingList().parallelStream() 
       .filter(something -> !selected.contains(something.getSomethingId())) 
       .map(something -> new FilterDTO(something.getSomethingName(), something.getSomethingDescription(), false)) 
       .collect(toList()); 

Quindi, è possibile impostare la lista restituita direttamente nel vostro somethingSubGroupDTO oggetto, invece di aggiungere un elemento alla volta.