50 lines
935 B
Ruby
50 lines
935 B
Ruby
require 'spec_helper'
|
|
require_dependency 'distributed_mutex'
|
|
|
|
describe DistributedMutex do
|
|
it "allows only one mutex object to have the lock at a time" do
|
|
mutexes = (1..10).map do
|
|
DistributedMutex.new("test_mutex_key")
|
|
end
|
|
|
|
x = 0
|
|
mutexes.map do |m|
|
|
Thread.new do
|
|
m.synchronize do
|
|
y = x
|
|
sleep 0.001
|
|
x = y + 1
|
|
end
|
|
end
|
|
end.map(&:join)
|
|
|
|
x.should == 10
|
|
end
|
|
|
|
it "handles auto cleanup correctly" do
|
|
m = DistributedMutex.new("test_mutex_key")
|
|
|
|
$redis.setnx "test_mutex_key", Time.now.to_i - 1
|
|
|
|
|
|
start = Time.now.to_i
|
|
m.synchronize do
|
|
"nop"
|
|
end
|
|
|
|
# no longer than a second
|
|
Time.now.to_i.should <= start + 1
|
|
end
|
|
|
|
it "maintains mutex semantics" do
|
|
m = DistributedMutex.new("test_mutex_key")
|
|
|
|
lambda {
|
|
m.synchronize do
|
|
m.synchronize{}
|
|
end
|
|
}.should raise_error(ThreadError)
|
|
end
|
|
|
|
end
|