diff options
author | Diego <diegolparra@gmail.com> | 2017-06-08 23:27:09 -0300 |
---|---|---|
committer | Diego <diegolparra@gmail.com> | 2017-06-08 23:27:09 -0300 |
commit | 0ad117a9255ccdbf26ce30222508070545579056 (patch) | |
tree | 0a53cb1051ca9275ff7e64671470410309b2c4e9 /kamon-core/src/main/scala/kamon/metric/MinMaxCounter.scala | |
parent | 0d3eb13669d3e9297b36d00aef03d177246efa27 (diff) | |
download | Kamon-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.scala | 14 |
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 +} |