Fix exception handling in rb_fiber_scheduler_set
. (#10042)
This commit is contained in:
parent
78d9fe6947
commit
04729fe68d
18
scheduler.c
18
scheduler.c
@ -161,6 +161,21 @@ verify_interface(VALUE scheduler)
|
||||
}
|
||||
}
|
||||
|
||||
static VALUE
|
||||
fiber_scheduler_close(VALUE scheduler)
|
||||
{
|
||||
return rb_fiber_scheduler_close(scheduler);
|
||||
}
|
||||
|
||||
static VALUE
|
||||
fiber_scheduler_close_ensure(VALUE _thread)
|
||||
{
|
||||
rb_thread_t *thread = (rb_thread_t*)_thread;
|
||||
thread->scheduler = Qnil;
|
||||
|
||||
return Qnil;
|
||||
}
|
||||
|
||||
VALUE
|
||||
rb_fiber_scheduler_set(VALUE scheduler)
|
||||
{
|
||||
@ -178,7 +193,8 @@ rb_fiber_scheduler_set(VALUE scheduler)
|
||||
// That way, we do not need to consider interactions, e.g., of a Fiber from
|
||||
// the previous scheduler with the new scheduler.
|
||||
if (thread->scheduler != Qnil) {
|
||||
rb_fiber_scheduler_close(thread->scheduler);
|
||||
// rb_fiber_scheduler_close(thread->scheduler);
|
||||
rb_ensure(fiber_scheduler_close, thread->scheduler, fiber_scheduler_close_ensure, (VALUE)thread);
|
||||
}
|
||||
|
||||
thread->scheduler = scheduler;
|
||||
|
Loading…
x
Reference in New Issue
Block a user