aboutsummaryrefslogtreecommitdiff
path: root/kamon-core/src/main/scala/kamon/metric/MinMaxCounter.scala
diff options
context:
space:
mode:
authorDiego <diegolparra@gmail.com>2017-06-08 23:27:09 -0300
committerDiego <diegolparra@gmail.com>2017-06-08 23:27:09 -0300
commit0ad117a9255ccdbf26ce30222508070545579056 (patch)
tree0a53cb1051ca9275ff7e64671470410309b2c4e9 /kamon-core/src/main/scala/kamon/metric/MinMaxCounter.scala
parent0d3eb13669d3e9297b36d00aef03d177246efa27 (diff)
downloadKamon-0ad117a9255ccdbf26ce30222508070545579056.tar.gz
Kamon-0ad117a9255ccdbf26ce30222508070545579056.tar.bz2
Kamon-0ad117a9255ccdbf26ce30222508070545579056.zip
* 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
Diffstat (limited to 'kamon-core/src/main/scala/kamon/metric/MinMaxCounter.scala')
-rw-r--r--kamon-core/src/main/scala/kamon/metric/MinMaxCounter.scala14
1 files changed, 6 insertions, 8 deletions
diff --git a/kamon-core/src/main/scala/kamon/metric/MinMaxCounter.scala b/kamon-core/src/main/scala/kamon/metric/MinMaxCounter.scala
index 211a1916..ae12f635 100644
--- a/kamon-core/src/main/scala/kamon/metric/MinMaxCounter.scala
+++ b/kamon-core/src/main/scala/kamon/metric/MinMaxCounter.scala
@@ -18,8 +18,7 @@ package kamon.metric
import java.lang.Math.abs
import java.util.concurrent.atomic.AtomicLong
-import kamon.jsr166.LongMaxUpdater
-import kamon.util.MeasurementUnit
+import kamon.util.{AtomicLongMaxUpdater, MeasurementUnit}
import scala.concurrent.duration.Duration
@@ -35,12 +34,11 @@ trait MinMaxCounter {
def sample(): Unit
}
+class SimpleMinMaxCounter(name: String, tags: Map[String, String], underlyingHistogram: Histogram with DistributionSnapshotInstrument,
+ val sampleInterval: Duration) extends SnapshotableMinMaxCounter {
-class PaddedMinMaxCounter(name: String, tags: Map[String, String], underlyingHistogram: Histogram with DistributionSnapshotInstrument,
- val sampleInterval: Duration) extends SnapshotableMinMaxCounter {
-
- private val min = new LongMaxUpdater(0L)
- private val max = new LongMaxUpdater(0L)
+ private val min = AtomicLongMaxUpdater()
+ private val max = AtomicLongMaxUpdater()
private val sum = new AtomicLong()
def dynamicRange: DynamicRange =
@@ -88,4 +86,4 @@ class PaddedMinMaxCounter(name: String, tags: Map[String, String], underlyingHis
underlyingHistogram.record(currentMin)
underlyingHistogram.record(currentMax)
}
-} \ No newline at end of file
+}