Sha256: 5123174b300566a03509026be4f1fb744fb034cf0b224b2a11e1cfdece3ff0fe
Contents?: true
Size: 867 Bytes
Versions: 9
Compression:
Stored size: 867 Bytes
Contents
require 'lite_spec_helper'
describe Mongo::Semaphore do
let(:semaphore) do
described_class.new
end
it 'waits until signaled' do
consumer = Thread.new do
semaphore.wait(3)
end
# Context switch to start the thread
sleep 0.1
start_time = Time.now
semaphore.signal
consumer.join
(Time.now - start_time).should < 1
end
it 'waits until broadcast' do
consumer = Thread.new do
semaphore.wait(3)
end
# Context switch to start the thread
sleep 0.1
start_time = Time.now
semaphore.broadcast
consumer.join
(Time.now - start_time).should < 1
end
it 'times out' do
consumer = Thread.new do
semaphore.wait(2)
end
# Context switch to start the thread
sleep 0.1
start_time = Time.now
consumer.join
(Time.now - start_time).should > 1
end
end
Version data entries
9 entries across 9 versions & 1 rubygems