diff options
author | nobu <nobu@b2dd03c8-39d4-4d8f-98ff-823fe69b080e> | 2007-04-19 05:52:49 +0000 |
---|---|---|
committer | nobu <nobu@b2dd03c8-39d4-4d8f-98ff-823fe69b080e> | 2007-04-19 05:52:49 +0000 |
commit | 378c35fc75dfeac15daec6fc055e73eb574687cc (patch) | |
tree | 638bc791ee70b988880cf1d7664e8af1173f2b59 /lib | |
parent | 7595c80e5570399fa98c455360f602297c97b1a1 (diff) |
* lib/monitor.rb (ConditionVariable#wait, mon_enter, mon_exit_for_cond):
ensures Thread.critical to be false. [ruby-talk:248300]
git-svn-id: svn+ssh://ci.ruby-lang.org/ruby/branches/ruby_1_8@12193 b2dd03c8-39d4-4d8f-98ff-823fe69b080e
Diffstat (limited to 'lib')
-rw-r--r-- | lib/monitor.rb | 21 |
1 files changed, 13 insertions, 8 deletions
diff --git a/lib/monitor.rb b/lib/monitor.rb index 4ed4e41222..4c146c8086 100644 --- a/lib/monitor.rb +++ b/lib/monitor.rb @@ -105,14 +105,17 @@ module MonitorMixin return false ensure Thread.critical = true - if timer && timer.alive? - Thread.kill(timer) + begin + if timer && timer.alive? + Thread.kill(timer) + end + if @waiters.include?(Thread.current) # interrupted? + @waiters.delete(Thread.current) + end + @monitor.instance_eval {mon_enter_for_cond(count)} + ensure + Thread.critical = false end - if @waiters.include?(Thread.current) # interrupted? - @waiters.delete(Thread.current) - end - @monitor.instance_eval {mon_enter_for_cond(count)} - Thread.critical = false end end @@ -210,6 +213,7 @@ module MonitorMixin Thread.critical = true mon_acquire(@mon_entering_queue) @mon_count += 1 + ensure Thread.critical = false end @@ -299,8 +303,9 @@ module MonitorMixin def mon_exit_for_cond count = @mon_count @mon_count = 0 - mon_release return count + ensure + mon_release end end |