kotovalexarian-likes-github/ruby--ruby
1
0
Fork 0
mirror of https://github.com/ruby/ruby.git synced 2022-11-09 12:17:21 -05:00
Code Releases Activity

* thread.c (lock_func): optimized and checks for interrupt_flag.

Browse source 
based on a patch from Sylvain Joyeux in [ruby-Patches-19361] and
  [ruby-Patches-19362].


git-svn-id: svn+ssh://ci.ruby-lang.org/ruby/trunk@15931 b2dd03c8-39d4-4d8f-98ff-823fe69b080e
This commit is contained in:
nobu 2008-04-09 05:43:29 +00:00
parent 5098d7ae0d
commit 69352c0d4d
2 changed files with 17 additions and 25 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

11
ChangeLog
View file

@ -1,12 +1,15 @@
Wed Apr 9 14:43:26 2008 Nobuyoshi Nakada <nobu@ruby-lang.org>
* thread.c (lock_func): optimized and checks for interrupt_flag.
based on a patch from Sylvain Joyeux in [ruby-Patches-19361] and
[ruby-Patches-19362].
Wed Apr 9 12:12:01 2008 Nobuyoshi Nakada <nobu@ruby-lang.org> Wed Apr 9 12:12:01 2008 Nobuyoshi Nakada <nobu@ruby-lang.org>
* test/ruby/test_thread.rb: new tests from Sylvain Joyeux in * test/ruby/test_thread.rb: new tests from Sylvain Joyeux in
[ruby-Patches-19361]. [ruby-Patches-19361].
Tue Apr 8 21:38:55 2008 Nobuyoshi Nakada <nobu@ruby-lang.org> Tue Apr 8 21:36:40 2008 Nobuyoshi Nakada <nobu@ruby-lang.org>
* thread.c (lock_func): optimized. based on a patch from Sylvain
Joyeux in [ruby-Patches-19362].
* thread.c (rb_mutex_sleep): ensures to re-acquire at waking up. * thread.c (rb_mutex_sleep): ensures to re-acquire at waking up.
[ruby-Patches-19361] [ruby-Patches-19361]

31
thread.c
View file

@ -2320,30 +2320,19 @@ rb_mutex_trylock(VALUE self)
static VALUE static VALUE
lock_func(rb_thread_t *th, mutex_t *mutex) lock_func(rb_thread_t *th, mutex_t *mutex)
{ {
int locked = 0; native_mutex_lock(&mutex->lock);
while (mutex->th) {
mutex->cond_waiting++;
native_cond_wait(&mutex->cond, &mutex->lock);
while (locked == 0) { if (th->interrupt_flag) {
native_mutex_lock(&mutex->lock); native_mutex_unlock(&mutex->lock);
{ RUBY_VM_CHECK_INTS();
if (mutex->th == 0) { native_mutex_lock(&mutex->lock);
mutex->th = th;
locked = 1;
}
else {
mutex->cond_waiting++;
native_cond_wait(&mutex->cond, &mutex->lock);
if (th->interrupt_flag) {
locked = 1;
}
else if (mutex->th == 0) {
mutex->th = th;
locked = 1;
}
}
} }
native_mutex_unlock(&mutex->lock);
} }
mutex->th = th;
native_mutex_unlock(&mutex->lock);
return Qnil; return Qnil;
} }