* lib/thread.rb (ConditionVariable#broadcast): s/RuntimeError/StandardError/
* lib/thread.rb (ConditionVariable#signal): ditto. git-svn-id: svn+ssh://ci.ruby-lang.org/ruby/trunk@38088 b2dd03c8-39d4-4d8f-98ff-823fe69b080e
This commit is contained in:
parent
3357d88ada
commit
028ca79f98
@ -1,3 +1,8 @@
|
||||
Sat Dec 1 03:38:04 2012 KOSAKI Motohiro <kosaki.motohiro@gmail.com>
|
||||
|
||||
* lib/thread.rb (ConditionVariable#broadcast): s/RuntimeError/StandardError/
|
||||
* lib/thread.rb (ConditionVariable#signal): ditto.
|
||||
|
||||
Sat Dec 1 03:29:52 2012 KOSAKI Motohiro <kosaki.motohiro@gmail.com>
|
||||
|
||||
* lib/thread.rb (SizedQueue#pop): rewrite by using ConditionVariable.
|
||||
|
@ -84,7 +84,7 @@ class ConditionVariable
|
||||
# Wakes up the first thread in line waiting for this lock.
|
||||
#
|
||||
def signal
|
||||
Thread.async_interrupt_timing(RuntimeError => :on_blocking) do
|
||||
Thread.async_interrupt_timing(StandardError => :on_blocking) do
|
||||
begin
|
||||
t = @waiters_mutex.synchronize {@waiters.shift}
|
||||
t.run if t
|
||||
@ -99,7 +99,7 @@ class ConditionVariable
|
||||
# Wakes up all threads waiting for this lock.
|
||||
#
|
||||
def broadcast
|
||||
Thread.async_interrupt_timing(RuntimeError => :on_blocking) do
|
||||
Thread.async_interrupt_timing(StandardError => :on_blocking) do
|
||||
waiters0 = nil
|
||||
@waiters_mutex.synchronize do
|
||||
waiters0 = @waiters.dup
|
||||
|
Loading…
x
Reference in New Issue
Block a user