Sha256: 2c3a15728f217a7ca327cd44e75a645f30f04cf5952af9cd52f2c4431d78f338
Contents?: true
Size: 1.26 KB
Versions: 17
Compression:
Stored size: 1.26 KB
Contents
require_relative 'test_helper'
require 'logger'
clock_class = Dynflow::Clock
describe clock_class do
let(:clock) { clock_class.new Logger.new($stderr) }
it 'refuses who without #<< method' do
clock.initialized.wait
-> { clock.ping Object.new, 0.1, :pong }.must_raise TypeError
clock.ping [], 0.1, :pong
end
it 'pongs' do
q = Queue.new
clock.initialized.wait
start = Time.now
clock.ping q, 0.1, o = Object.new
assert_equal o, q.pop
finish = Time.now
assert_in_delta 0.1, finish - start, 0.08
end
it 'pongs on expected times' do
q = Queue.new
clock.initialized.wait
start = Time.now
clock.ping q, 0.3, :a
clock.ping q, 0.1, :b
clock.ping q, 0.2, :c
assert_equal :b, q.pop
assert_in_delta 0.1, Time.now - start, 0.08
assert_equal :c, q.pop
assert_in_delta 0.2, Time.now - start, 0.08
assert_equal :a, q.pop
assert_in_delta 0.3, Time.now - start, 0.08
end
it 'works under stress' do
clock.initialized.wait
threads = Array.new(4) do
Thread.new do
q = Queue.new
times = 20
times.times { |i| clock.ping q, rand, i }
assert_equal (0...times).to_a, Array.new(times) { q.pop }.sort
end
end
threads.each &:join
end
end
Version data entries
17 entries across 17 versions & 1 rubygems