ConcurrentHashMap с параллельными потоками для удаления ключей

Question

У меня есть следующий последовательный код, который удаляет записи из хэш-карты, используя другой список ключей. Размер карты может составлять 50-100 тыс. Записей и удалить список ключей может быть 2k - 10k. Я ищу решения, используя новые Java-8 потоков ...

List<Long> removed = new ArrayList<Long>(); 
    for (Long k : removelist) { 
     if (null != map.remove(k)) { 
      removed.add(k); 
     } 
    } 

Answer 1

Разновидность прямого перевода

List<Long> removed = removeList.parallelStream() 
     .map(key -> map.remove(key) != null ? key : null) 
     .filter(Objects::nonNull) 
     .collect(Collectors.toList()); 

на map шаг карты от ключа к ключу, если он может быть удален, чтобы null если не. null s затем фильтруют.

немного короче, непосредственно фильтрации для тех ключей, которые могут быть удалены:

List<Long> removed = removeList.parallelStream() 
     .filter(key -> map.remove(key) != null) 
     .collect(Collectors.toList()); 

или через remove метод набора ключей, который возвращает boolean и, следовательно, может быть использован непосредственно в качестве Predicate

List<Long> removed = removeList.parallelStream() 
      .filter(map.keySet()::remove) 
      .collect(Collectors.toList());