Skip to content

Commit 3278173

Browse files
committed
use concurrent-ruby
1 parent b7ae7ab commit 3278173

14 files changed

Lines changed: 18 additions & 26 deletions

Gemfile

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -6,6 +6,7 @@ gem 'beefcake', '< 1.0.0'
66

77
group :test do
88
gem 'rake'
9+
gem 'test-unit'
910
gem 'riemann-client', '~> 0.0.7'
1011
gem 'rbtree', :platform => :mri_18
1112
end

lib/metriks.rb

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,4 @@
1+
require 'concurrent'
12

23
module Metriks
34
VERSION = '0.9.9.7'
@@ -29,6 +30,8 @@ def self.meter(name)
2930
def self.histogram(name)
3031
Metriks::Registry.default.histogram(name)
3132
end
33+
34+
Atomic = Concurrent::AtomicReference
3235
end
3336

3437
require 'metriks/registry'

lib/metriks/counter.rb

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,3 @@
1-
require 'atomic'
2-
31
module Metriks
42
# Public: Counters are one of the simplest metrics whose only operations
53
# are increment and decrement.
@@ -41,4 +39,4 @@ def count
4139
@count.value
4240
end
4341
end
44-
end
42+
end

lib/metriks/ewma.rb

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,3 @@
1-
require 'atomic'
2-
31
module Metriks
42
class EWMA
53
INTERVAL = 5.0
@@ -60,4 +58,4 @@ def rate
6058
@rate.value
6159
end
6260
end
63-
end
61+
end

lib/metriks/exponentially_decaying_sample.rb

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,3 @@
1-
require 'atomic'
21
require 'red_black_tree'
32
require 'metriks/snapshot'
43

@@ -99,4 +98,4 @@ def rescale(now, next_time)
9998
end
10099
end
101100
end
102-
end
101+
end

lib/metriks/gauge.rb

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,3 @@
1-
require 'atomic'
2-
31
module Metriks
42
class Gauge
53
# Public: Initialize a new Gauge.

lib/metriks/histogram.rb

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,3 @@
1-
require 'atomic'
21
require 'metriks/uniform_sample'
32
require 'metriks/exponentially_decaying_sample'
43

lib/metriks/meter.rb

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,3 @@
1-
require 'atomic'
2-
31
require 'metriks/ewma'
42

53
module Metriks
@@ -82,4 +80,4 @@ def mean_rate
8280
def stop
8381
end
8482
end
85-
end
83+
end

lib/metriks/simple_moving_average.rb

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,3 @@
1-
require 'atomic'
2-
31
module Metriks
42
class SimpleMovingAverage
53
INTERVAL = 5.0
@@ -57,4 +55,4 @@ def rate
5755
num / count / @interval.to_f
5856
end
5957
end
60-
end
58+
end

lib/metriks/timer.rb

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
1-
require 'atomic'
1+
require 'concurrent'
22
require 'hitimes'
33

44
require 'metriks/meter'
@@ -102,4 +102,4 @@ def stop
102102
@meter.stop
103103
end
104104
end
105-
end
105+
end

0 commit comments

Comments
 (0)