Концепция параллельных потоков

Question

Я изучаю потоки Java и хочу знать, есть ли что-то не так с этим кодом. Поскольку я использую параллельный поток, я использовал ConcurrentHashMap.

class Person { 
    private String name; 

    public String getName() { 
     return this.name; 
    } 
} 

и

ConcurrentHashMap<Integer, Person> map = <Mapping of id to Person> 
List<Integer> list = <list of Id> 

list = list.parallelStream() 
     .filter(id -> map.containsKey(id) 
         && !Strings.isNullOrEmpty(map.get(id).getName())) 
     .collect(Collectors.toList()); 

Answer 1

Если карта активно обновляется, у вас может быть гонка между containsKey и get. Вместо этого вы могли бы написать что-то вроде

list.parallelStream() 
    .filter(id -> { 
     Person person = map.get(id); 
     return person != null && !Strings.isNullOrEmpty(person.getName()); 
    }) 
    .collect(Collectors.toList()); 

Использование parallelStream не имеет ничего общего с этим - это прекрасно. Он выполняет два отдельных вызова на ConcurrentMap по одному и тому же ключу и ожидает, что они будут иметь согласованные результаты.

Answer 2

Карта является одновременно, поэтому он может работать с многопоточный доступ. Синхронизация или блокировка не требуется.

В вашем случае будет работать обычный HashMap, потому что вы только запрашиваете карту. Как-то никто обновляет список во время потоковой передачи, у вас нет многопоточной конкуренции.