Какова наилучшая практика для подсчета на каждый ключ в java

Question

В java Мне нужно подсчитать элементы на ключ, поэтому я подумал об использовании ConcurrentMap с ключом, и, поскольку значение имеет AtomicInteger, однако мне интересно, есть ли лучший способ. Это не критический сервис, он просто используется для сбора статистики, поэтому я не против, если я опоздаю на 10 секунд с правильной статистикой или что-то вроде этого. Поэтому я задаюсь вопросом, есть ли более эффективная практика для него в стандартном java-параллелизме, или я снова остаюсь с тем, чтобы иметь дело с ConcurrentMap и с AtomicInteger (пример, который мог бы также решить проблему, был бы передачей сообщений, может быть, если да, то как может это мне помочь?) (лучше всего было бы с примером ...), что бы не было проблем с производительностью, и было бы безопасно, и было бы легко использовать, я не возражаю против латентности.

Answer 1

Guava предоставляет ConcurrentHashMultiset. Это параллельная реализация Multiset, которая фактически представляет собой набор, позволяющий дублировать. Вы можете add(E) и remove(Object), как обычно, но также получить count(Object) элемента в Multiset.

Фактически, this is implemented с использованием подложки ConcurrentHashMap<E, AtomicInteger>, поэтому ваша практика прекрасна. Однако:

• Интерфейс Multiset обеспечивает более хорошую абстракцию, он распространяется даже Collection.
• Правильное управление этими AtomicIntegers самостоятельно - это сложное дело. Быстро взглянув на код Гуавы, вы должны дать представление о проблемах, которые возникают при одновременном программировании: вам нужно много compareAndSet s и бесконечных циклов while, чтобы убедиться, что получены правильные результаты.

Answer 2

Да, я думаю, что это правильное направление, поэтому я действительно не понимаю, почему, по вашему мнению, это непросто. Просто используйте специфические функции с параллельной картой. То есть для обновления статистики будет:

AtomicInteger newCounter = new AtomicInteger(1); 
AtomicInteger existingCounter = map.putIfAbsent(key, newCounter); 
if(existingCounter != null) 
    existingCounter.incrementAndGet();