Note: this may get published twice… I posted via the email list but
it never went through…
I’m getting the following error when I I try to join some threads:
c:/ruby/lib/ruby/1.8/monitor.rb:215:in mon_enter': undefined method+’
for nil:NilClass (NoMethodError)
from simulator2.rb:48:in join' from simulator2.rb:48:ininit’
from simulator2.rb:48:in each' from simulator2.rb:48:ininit’
from simulator2.rb:163
For some reason @mon_count within monitor.rb is nil, but I’m not sure
why any type of synchronization is being done at this point. Does
Thread do some synchronization when join is called?
Below is the code from simulator2.rb on line 48 (along with other
potentially informative code):
threads = Array.new
outages.each do |range| @logger.debug “New thread – Start: #{range.first}, Finish:
#{range.last}”
threads << Thread.new do
Simulator2.new(@file, @interface,
“c:\log-#{threads.length}.txt”).run(range.first, range.last)
end
end
threads.each { |thread| thread.join }
I am doing some synchronization of methods and variables within the
Simulator2#run method… but would this show up as coming from the
Thread#join method?
Just for clarification, yes I am creating a new instance of Simulator2
(which is the class which this code resides in). The code above resides
in Simulator2#init.
So this doesn’t have anything to do with Thread.join and such… it
instead has to do with some synchronization I’m doing in another class.
Here’s what it looks like:
class StatsTracker < Monitor
include Singleton
…
def foo
synchronize do
# do something
end
end
…
end
I get an error at the ‘synchronize do’ line similar to what I describe
in my first post, essentially saying @mon_count is nil. I tried
including MonitorMixin vs extending Monitor, but that didn’t fix the
problem. I then tried doing the following and it worked:
class StatsTracker
include Singleton
def initialize @semaphore = Mutex.new
end
…
def foo @semaphore.synchronize do
# do something
end
end
…
end
Does anyone know what I’m doing wrong to make the Monitor approach not
work?
def foo
synchronize do
# do something
end
end
…
end
Hope that helps someone.
Just an additional note: the reason why the exception appears to come
out of Thread.join is this:
irb(main):004:0> t = Thread.new { raise ArgumentError, “test” }
=> #<Thread:0x100ea960 run>
irb(main):005:0> t.join
ArgumentError: test
from (irb):4:in `block in irb_binding’
irb(main):006:0>
In other words: since the exception is not caught in the thread,
thread exits but the exception survives. When you do the join, it
will come to haunt you. This does make sense when you consider
Thread.value:
irb(main):006:0> t = Thread.new { “result” }
=> #<Thread:0x100e0b54 run>
irb(main):007:0> t.value
=> “result”
irb(main):008:0> t = Thread.new { raise ArgumentError, “test” }
=> #<Thread:0x10016aac run>
irb(main):009:0> t.value
ArgumentError: test
from (irb):8:in `block in irb_binding’
irb(main):010:0>