2018-03-04 10:09:32 -05:00
|
|
|
require_relative '../../spec_helper'
|
2017-05-07 08:04:49 -04:00
|
|
|
|
|
|
|
describe "Thread.exclusive" do
|
|
|
|
before :each do
|
|
|
|
ScratchPad.clear
|
|
|
|
end
|
|
|
|
|
|
|
|
it "yields to the block" do
|
|
|
|
Thread.exclusive { ScratchPad.record true }
|
|
|
|
ScratchPad.recorded.should == true
|
|
|
|
end
|
|
|
|
|
|
|
|
it "returns the result of yielding" do
|
|
|
|
Thread.exclusive { :result }.should == :result
|
|
|
|
end
|
|
|
|
|
2018-11-27 15:38:57 -05:00
|
|
|
it "blocks the caller if another thread is also in an exclusive block" do
|
|
|
|
m = Mutex.new
|
|
|
|
q1 = Queue.new
|
|
|
|
q2 = Queue.new
|
|
|
|
|
|
|
|
t = Thread.new {
|
|
|
|
Thread.exclusive {
|
|
|
|
q1.push :ready
|
|
|
|
q2.pop
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
q1.pop.should == :ready
|
|
|
|
|
|
|
|
lambda { Thread.exclusive { } }.should block_caller
|
|
|
|
|
|
|
|
q2.push :done
|
|
|
|
t.join
|
|
|
|
end
|
|
|
|
|
|
|
|
it "is not recursive" do
|
|
|
|
Thread.exclusive do
|
|
|
|
lambda { Thread.exclusive { } }.should raise_error(ThreadError)
|
|
|
|
end
|
|
|
|
end
|
2017-05-07 08:04:49 -04:00
|
|
|
end
|