* Introduce Java 8 Unsafe intrinsics in LogAdder (lock addq and lock xchg)

* Introduce atomic variant of LongAdder::sumThenReset -> LongAdder::sumAndReset
* Remove LongMaxUpdater in favor to AtomicLongMaxUpdater

1 files changed, 4 insertions, 8 deletions

diff --git a/kamon-core/src/main/scala/kamon/metric/Counter.scala b/kamon-core/src/main/scala/kamon/metric/Counter.scala
index bbcce858..b5f8353c 100644
--- a/kamon-core/src/main/scala/kamon/metric/Counter.scala
+++ b/kamon-core/src/main/scala/kamon/metric/Counter.scala
@@ -15,9 +15,8 @@
 
 package kamon.metric
 
-import java.util.concurrent.atomic.LongAdder
-
 import com.typesafe.scalalogging.StrictLogging
+import kamon.jsr166.LongAdder
 import kamon.util.MeasurementUnit
 
 trait Counter {
@@ -36,12 +35,9 @@ class LongAdderCounter(name: String, tags: Map[String, String], val measurementU
     adder.increment()
 
   def increment(times: Long): Unit = {
-    if (times >= 0)
-      adder.add(times)
-    else
-      logger.warn(s"Ignored attempt to decrement counter [$name]")
+    if (times >= 0) adder.add(times)
+    else logger.warn(s"Ignored attempt to decrement counter [$name]")
   }
 
-  def snapshot(): MetricValue =
-    MetricValue(name, tags, measurementUnit, adder.sumThenReset())
+  def snapshot(): MetricValue = MetricValue(name, tags, measurementUnit, adder.sumAndReset())
 }