Introduce IO::Event::WorkerPool for blocking operation execution.

Author: samuel-williams-shopify

ext/extconf.rb

@@ -23,7 +23,7 @@
 	append_cflags(["-DRUBY_DEBUG", "-O0"])
 end
 
-$srcs = ["io/event/event.c", "io/event/time.c", "io/event/fiber.c", "io/event/selector/selector.c"]
+$srcs = ["io/event/event.c", "io/event/time.c", "io/event/fiber.c", "io/event/worker_pool.c", "io/event/selector/selector.c"]
 $VPATH << "$(srcdir)/io/event"
 $VPATH << "$(srcdir)/io/event/selector"
 
@@ -56,6 +56,11 @@
 have_func("&rb_fiber_raise")
 have_func("epoll_pwait2")
 
+# Feature detection for blocking operation support
+have_func("rb_fiber_scheduler_blocking_operation_extract")
+have_func("rb_fiber_scheduler_blocking_operation_execute")
+have_func("rb_fiber_scheduler_blocking_operation_cancel")
+
 have_header("ruby/io/buffer.h")
 
 if ENV.key?("RUBY_SANITIZE")

ext/io/event/event.c

@@ -3,6 +3,7 @@
 
 #include "event.h"
 #include "fiber.h"
+#include "worker_pool.h"
 #include "selector/selector.h"
 
 void Init_IO_Event(void)
@@ -14,6 +15,7 @@ void Init_IO_Event(void)
 	VALUE IO_Event = rb_define_module_under(rb_cIO, "Event");
 
 	Init_IO_Event_Fiber(IO_Event);
+	Init_IO_Event_WorkerPool(IO_Event);
 
 	VALUE IO_Event_Selector = rb_define_module_under(IO_Event, "Selector");
 	Init_IO_Event_Selector(IO_Event_Selector);

ext/io/event/fiber.c

@@ -35,7 +35,7 @@ VALUE IO_Event_Fiber_raise(VALUE fiber, int argc, VALUE *argv) {
 #ifndef HAVE_RB_FIBER_CURRENT
 static ID id_current;
 
-static VALUE IO_Event_Fiber_current(void) {
+VALUE IO_Event_Fiber_current(void) {
 	return rb_funcall(rb_cFiber, id_current, 0);
 }
 #endif