Merge pull request #7 from samhendley/add-synchronization

add synchronization around removeGauge/addGauge to avoid race condition

src/main/scala/com/twitter/finagle/metrics/MetricsStatsReceiver.scala

@@ -13,16 +13,21 @@ object MetricsStatsReceiver {
   }
 
   private[metrics] case class MetricGauge(name: String)(f: => Float) extends Gauge {
-    // remove old gauge's value before adding a new one
-    metrics.getGauges(new MetricFilter() {
-      override def matches(metricName: String, metric: Metric): Boolean =
-        metricName == name
-    }).asScala
-      .foreach { case (gaugeName, _) => metrics.remove(gaugeName) }
-
-    metrics.register(name, new MGauge[Float]() {
-      override def getValue(): Float = f
-    })
+    // we need to synchronize so this is safe with multiple threads. Ideally the callers are themselves
+    // synchronized so they don't overwrite each others gauges but until they are we should protect
+    // ourselves from that race condition.
+    synchronized {
+      // remove old gauge's value before adding a new one
+      metrics.getGauges(new MetricFilter() {
+        override def matches(metricName: String, metric: Metric): Boolean =
+          metricName == name
+      }).asScala
+        .foreach { case (gaugeName, _) => metrics.remove(gaugeName) }
+
+      metrics.register(name, new MGauge[Float]() {
+        override def getValue(): Float = f
+      })
+    }
 
     override def remove(): Unit = metrics.remove(name)
   }