1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
|
require 'concurrent/constants'
require 'concurrent/utility/monotonic_time'
require 'concurrent/channel/tick'
require 'concurrent/channel/buffer/timer'
module Concurrent
class Channel
module Buffer
class Ticker < Timer
private
def ns_initialize(interval)
@interval = interval.to_f
@next_tick = Concurrent.monotonic_time + interval
self.capacity = 1
end
def do_poll
synchronize do
if ns_closed?
return Concurrent::NULL, false
elsif (now = Concurrent.monotonic_time) >= @next_tick
tick = Concurrent::Channel::Tick.new(@next_tick)
@next_tick = now + @interval
return tick, true
else
return nil, true
end
end
end
end
end
end
end
|
