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
37
38
39
40
41
42
43
44
45
46
|
describe 'Accessing ISO3166::Country instances data in multiple threads' do
before do
if Thread.respond_to?(:report_on_exception)
@report_on_exception_value = Thread.report_on_exception
Thread.report_on_exception = false
end
ISO3166::Data.reset
end
def create_countries_threaded
nthreads = 100
threads = []
alpha2_codes = ['us', 'es', 'nl', 'ca', 'de', 'fr', 'mx', 'ru', 'ch', 'jp']
nthreads.times do
threads << Thread.new do
alpha2_codes.each do |a2|
country = ISO3166::Country[a2]
# This will fail if data['translations'] has been
# left nil due to a race condition
country.translation
end
end
end
threads.map(&:join)
end
it "doesn't raise any exceptions when using a mutex" do
expect { create_countries_threaded }.to_not raise_error
end
xit "raises NoMethodError when not using a mutex" do
allow(ISO3166::Data).to receive(:use_mutex?).and_return(false)
expect { create_countries_threaded }.to raise_error(NoMethodError)
end
after do
if Thread.respond_to?(:report_on_exception)
Thread.report_on_exception = @report_on_exception_value
end
end
end
|
