parent
5ae2c1b093
commit
3353baac3d
@ -39,11 +39,12 @@ require 'drb/drb'
|
|||||||
|
|
||||||
module DRbNamedObject
|
module DRbNamedObject
|
||||||
DRbNAMEDICT = {}
|
DRbNAMEDICT = {}
|
||||||
|
DRBNAMEMUTEX = Thread::Mutex.new
|
||||||
attr_reader(:drb_name)
|
attr_reader(:drb_name)
|
||||||
|
|
||||||
def drb_name=(name)
|
def drb_name=(name)
|
||||||
@drb_name = name
|
@drb_name = name
|
||||||
Thread.exclusive do
|
DRBNAMEMUTEX.synchronize do
|
||||||
raise(IndexError, name) if DRbNAMEDICT[name]
|
raise(IndexError, name) if DRbNAMEDICT[name]
|
||||||
DRbNAMEDICT[name] = self
|
DRbNAMEDICT[name] = self
|
||||||
end
|
end
|
||||||
|
Loading…
x
Reference in New Issue
Block a user