Raccolta aggiornata durante l'esecuzione dello streaming java 8

Question

Ho uno List di oggetti che vengono aggiornati regolarmente da un paio di thread. Durante l'aggiornamento voglio usare uno stream per filtrare alcuni elementi.

Ad esempio; dire che ho lista che viene aggiornata regolarmente:

List<MyObject> myList 

Ora, a un certo punto nel tempo che uso corrente in tale elenco

List<MyObject> result = 
myList.stream().filter(myobj->myobjt.isValid()).collect(toList()); 

È questo thread-safe dato che la mia lista è in corso di aggiornamento da una un paio di discussioni?

Answer 1

I Javadoc of CopyOnWriteArrayList indica:

Il metodo "istantanea" stile iteratore utilizza un riferimento allo stato della matrice al punto che l'iteratore è stato creato. Questo array non cambia mai durante il ciclo di vita dell'iteratore, quindi l'interferenza è impossibile e l'iteratore è garantito non lanciare ConcurrentModificationException. L'iteratore non rifletterà aggiunte, rimozioni o modifiche alla lista da quando è stato creato l'iteratore.

Quindi, sì, il codice deve essere protetto da thread. Lo stream ignorerà tutte le aggiunte all'elenco dopo che è stato avviato.