Collections.synchronizedlist() remove element while iterating dalla fine

Question

Sto usando Collections.Synchronizedlist() per rendere sicuro il thread arraylist. Quello che voglio porre è il seguente codice thread-safe vale a dire rimuovere, mentre l'iterazione di lista dalla fine: -

pendingExecutionList = Collections.synchronizedList(new ArrayList<>(initialCapacity)); 

sto creando la lista nel thread principale. e aggiungendo a questa lista da diversi thread. Ma, iterazione e la rimozione è stato fatto solo da un unico filo programmato come segue: -

for (int i = pendingExecutionList.size() - 1; i >= 0; i--) 
{ 
    if (someCondition(pendingExecutionList.get(i))) 
    { 
     process(pendingExecutionList.remove(i)); 
    } 
} 

Il codice precedente viene eseguito da un solo filo mentre più thread stanno aggiungendo a questa lista.

Voglio evitare di utilizzare iteratore su synchronized(list) in quanto non è sicuro.

Answer 1

Se sto capendo correttamente la vostra pipeline del flusso di lavoro, suggerirei di provare qualche variante di uno BlockingQueue invece di uno synchronizedList().

ArrayBlockingQueue consentirebbe di avere una programmazione equa delle esecuzioni e dovrebbe mantenere le cache dei produttori multipli abbastanza calde (a meno che i produttori non inizino a superare il prefetcher della cache, nel qual caso si verificherà una condivisione errata).

Se si è in vena di sperimentare, è possibile dare un'occhiata alle code MPSC (più produttori, singolo consumatore) disponibili al di fuori del JDK, come lo MpscArrayQueue di Nitsan Wakart o lo Disruptor.

Answer 2

Invece di tenere il blocco, in realtà si ottiene il blocco una volta per elemento. Ciò comporta il rischio di essere più lento del semplice blocco mentre controlli.

Ti suggerisco di considerare l'utilizzo di un PriorityQueue con un ordine appropriato. Questo ordinerà la coda in modo che quelli che stai per elaborare successivamente saranno all'inizio e il costo della rimozione è relativamente economico indipendentemente dal numero di attività in attesa.