archive/ruby
1
0
Fork 0
mirror of https://github.com/ruby/ruby.git synced 2025-08-15 21:49:06 +02:00
Code Issues Projects Releases Packages Wiki Activity Actions 4

Add rb_thread_current_scheduler().

Browse source
This commit is contained in:
Samuel Williams 2020-08-20 13:47:55 +12:00
parent a9ccebbda0
commit 703e529751
Notes: git 2020-09-14 13:44:40 +09:00
2 changed files with 10 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

6
internal/thread.h
View file

@ -37,9 +37,11 @@ void rb_mutex_allow_trap(VALUE self, int val);
VALUE rb_uninterruptible(VALUE (*b_proc)(VALUE), VALUE data); VALUE rb_uninterruptible(VALUE (*b_proc)(VALUE), VALUE data);
VALUE rb_mutex_owned_p(VALUE self); VALUE rb_mutex_owned_p(VALUE self);
VALUE rb_thread_scheduler_get(VALUE); VALUE rb_thread_scheduler_get(VALUE thread);
VALUE rb_thread_scheduler_set(VALUE, VALUE); VALUE rb_thread_scheduler_set(VALUE thread, VALUE scheduler);
VALUE rb_thread_scheduler_if_nonblocking(VALUE thread); VALUE rb_thread_scheduler_if_nonblocking(VALUE thread);
VALUE rb_thread_current_scheduler();
RUBY_SYMBOL_EXPORT_BEGIN RUBY_SYMBOL_EXPORT_BEGIN
/* Temporary. This API will be removed (renamed). */ /* Temporary. This API will be removed (renamed). */

6
thread.c
View file

@ -3749,6 +3749,12 @@ rb_thread_scheduler(VALUE klass)
return rb_thread_scheduler_if_nonblocking(rb_thread_current()); return rb_thread_scheduler_if_nonblocking(rb_thread_current());
} }
static VALUE
rb_thread_current_scheduler()
{
return rb_thread_scheduler_if_nonblocking(rb_thread_current());
}
VALUE VALUE
rb_thread_scheduler_if_nonblocking(VALUE thread) rb_thread_scheduler_if_nonblocking(VALUE thread)
{ {