문자열 맵과 다른 맵을 스레드로 안전하게 채우는 방법은 무엇입니까?

Question

아래의 클래스에서 increment 및 decrement 메트릭을 사용하여 응용 프로그램 메트릭을 측정하려고합니다.

public class AppMetrics { 
    private final AtomicLongMap<String> metricCounter = AtomicLongMap.create(); 

    private static class Holder { 
    private static final AppMetrics INSTANCE = new AppMetrics(); 
    } 

    public static AppMetrics getInstance() { 
    return Holder.INSTANCE; 
    } 

    private AppMetrics() {}  

    public void increment(String name) { 
    metricCounter.getAndIncrement(name); 
    } 

    public AtomicLongMap<String> getMetricCounter() { 
    return metricCounter; 
    } 
} 

내가 메트릭 이름을 전달하여 통계를 증가 increment 방법 멀티 스레드 코드에서 클래스 AppMetrics의를 호출하고 있습니다.

문제 설명 :

는 지금은 문자열을 각 clientId에 대한 metricCounter을 갖고 싶어. 즉, 동일한 clientId을 여러 번 가져올 수도 있고 때로는 새로운 clientId이 될 수도 있습니다. 따라서 어쨌든 그 clientId에 대한 metricCounter지도를 추출해야하고 해당 특정지도의 메트릭을 증가시켜야합니다 (어떻게해야할지 모르겠습니다). 그).

염두에 두어야 할 올바른 방법은 스레드로부터 안전해야하며 원자 적 조작을 수행해야한다는 것입니다. 그 대신지도를 만들려고했습니다.

private final Map<String, AtomicLongMap<String>> clientIdMetricCounterHolder = Maps.newConcurrentMap(); 

올바른 방법인가요? 그렇다면 어떻게하면 clientId을 키로 전달하여이지도를 채울 수 있으며 값은 각 측정 항목의 카운터지도가됩니다.

나는 자바 7

Answer 1

에 Map<String, Map<String, T>> 그냥 변장에 Map<Pair<String, String>, T>입니다입니다. MultiKey 클래스를 만듭니다

class MultiKey { 
    public String clientId; 
    public String name; 

    // be sure to add hashCode and equals 
} 

그럼 그냥 AtomicLongMap<MultiKey>를 사용합니다.

편집 :

측정의 세트가 잘 정의되어 제공, 하나의 클라이언트에 대한 통계를 보려면이 데이터 구조를 사용하기에 너무 어렵지 않을 것이다 :

Set<String> possibleMetrics = // all the possible values for "name" 

Map<String, Long> getMetricsForClient(String client) { 
    return Maps.asMap(possibleMetrics, m -> metrics.get(new MultiKey(client, m)); 
} 

가 반환지도 할 것이다 생방송보기. 이전 Java 버전을 사용하는 경우에는 좀 더 자세한 정보가 표시 될 수 있지만 여전히 가능합니다.

Answer 2

지도를 사용하는 경우 새 AtomicLongMap 인스턴스를 동기화해야합니다. 대신 LoadingCache을 사용하는 것이 좋습니다. 실제 "캐싱"기능을 사용하지 않을 수도 있지만 "로드 중"기능은 AtomicLongMap 인스턴스를 동기화하는 데 매우 유용합니다. 예 :

LoadingCache<String, AtomicLongMap<String>> clientIdMetricCounterCache = 
     CacheBuilder.newBuilder().build(new CacheLoader<String, AtomicLongMap<String>>() { 
      @Override 
      public AtomicLongMap<String> load(String key) throws Exception { 
       return AtomicLongMap.create(); 
      } 
     }); 

이제 클라이언트가 새로운 것인지 아닌지에 대한 걱정없이 모든 클라이언트의 메트릭 개수 업데이트를 안전하게 시작할 수 있습니다. 예 :

clientIdMetricCounterCache.get(clientId).incrementAndGet(metricName);