Synchronize access race in HistogramMetric

Author: angelodipaolo

Sources/OpenTelemetrySdk/Metrics/HistogramMetricSdk.swift

@@ -10,18 +10,24 @@ internal class HistogramMetricSdk<T: SignedNumeric & Comparable>: HistogramMetri
     public private(set) var boundInstruments = [LabelSet: BoundHistogramMetricSdkBase<T>]()
     let metricName: String
     let explicitBoundaries: Array<T>?
+    let bindUnbindLock = Lock()
 
     init(name: String, explicitBoundaries: Array<T>? = nil) {
         metricName = name
         self.explicitBoundaries = explicitBoundaries
     }
 
     func bind(labelset: LabelSet) -> BoundHistogramMetric<T> {
-        var boundInstrument = boundInstruments[labelset]
-        if boundInstrument == nil {
-            boundInstrument = createMetric()
-            boundInstruments[labelset] = boundInstrument!
+        var boundInstrument: BoundHistogramMetricSdkBase<T>?
+
+        bindUnbindLock.withLock {
+            var boundInstrument = boundInstruments[labelset]
+            if boundInstrument == nil {
+                boundInstrument = createMetric()
+                boundInstruments[labelset] = boundInstrument!
+            }
         }
+
         return boundInstrument!
     }
 

Sources/OpenTelemetrySdk/Metrics/MeterSdk.swift

@@ -194,14 +194,18 @@ class MeterSdk: Meter {
                 let metricName = histogram.key
                 let measureInstrument = histogram.value
                 var metric = Metric(namespace: meterName, name: metricName, desc: meterName + metricName, type: AggregationType.doubleHistogram, resource: resource, instrumentationScopeInfo: instrumentationScopeInfo)
-                measureInstrument.boundInstruments.forEach { boundInstrument in
-                    let labelSet = boundInstrument.key
-                    let aggregator = boundInstrument.value.getAggregator()
-                    aggregator.checkpoint()
-                    var metricData = aggregator.toMetricData()
-                    metricData.labels = labelSet.labels
-                    metric.data.append(metricData)
+
+                measureInstrument.bindUnbindLock.withLock {
+                    measureInstrument.boundInstruments.forEach { boundInstrument in
+                        let labelSet = boundInstrument.key
+                        let aggregator = boundInstrument.value.getAggregator()
+                        aggregator.checkpoint()
+                        var metricData = aggregator.toMetricData()
+                        metricData.labels = labelSet.labels
+                        metric.data.append(metricData)
+                    }
                 }
+
                 metricProcessor.process(metric: metric)
             }