Sha256: 131f6e0141cfda24d29c809a851d83a05163cb81f6ac7a39a2a3f26a751e0c9f
Contents?: true
Size: 1.07 KB
Versions: 18
Compression:
Stored size: 1.07 KB
Contents
# frozen_string_literal: true
# encoding: utf-8
require 'lite_spec_helper'
describe Mongo::DistinguishingSemaphore do
let(:semaphore) do
described_class.new
end
it 'waits until signaled' do
result = nil
consumer = Thread.new do
result = 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
result.should be true
end
it 'waits until broadcast' do
result = nil
consumer = Thread.new do
result = 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
result.should be true
end
it 'times out' do
result = nil
consumer = Thread.new do
result = 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
result.should be false
end
end
Version data entries
18 entries across 18 versions & 1 rubygems