Em Java ConcurrentHashMap
possui uma propriedade interessante. Operações como putIfAbsent
, remove
, replace
, computeIfAbsent
, computeIfPresent
, compute
e merge
são atômicas.
Exemplo:
final Map<String, Integer> map = new ConcurrentHashMap<>();
IntStream.rangeClosed(1, 10000)
.parallel()
.forEach(i -> map.merge("key" + (i % 5 + 1), i, Integer::sum));
final long total = map.values().stream().mapToInt(Integer::intValue).sum(); // 50005000
Eu não encontrei nenhuma operação similar na API do TrieMap
:
val map = TrieMap[String, Int]().withDefaultValue(0)
(1 to 10000).par.foreach(i => map(s"key${i % 5 + 1}") += i)
val total = map.values.sum // valor aleatório, += não é uma operação atomica
Claramente é possível sincronizar operações manualmente bem como usar construções como CAS, STM, etc:
(1 to 10000).par.foreach(i => {
val key = s"key${i % 5 + 1}".intern
key.synchronized {
map(key) += i
}
})
Alternativamente, é possível utilizar ConcurrentHashMap
do Java diretamente (sem usar asScala
):
val map = new java.util.concurrent.ConcurrentHashMap[String, Int]()
(1 to 10000).par.foreach(i => map.merge(s"key${i % 5 + 1}", i, Integer.sum _))
val total = map.values().asScala.sum
Há alguma maneira mais simples / idiomática de garantir updates atomicos em um concurrent.Map
?