WIP

Author: ioquatix

ext/io/event/worker_pool.c

@@ -180,7 +180,15 @@ static VALUE worker_thread_func(void *_worker) {
 
 	while (true) {
 		// Wait for work and execute it without holding GVL
-		struct IO_Event_WorkerPool_Work *work = (struct IO_Event_WorkerPool_Work *)rb_thread_call_without_gvl(worker_wait_and_execute, worker, worker_unblock_func, worker);
+		void *result = rb_thread_call_without_gvl(worker_wait_and_execute, worker, worker_unblock_func, worker);
+		
+		// Check for error conditions from rb_thread_call_without_gvl
+		if (result == (void*)-1) {
+			// rb_thread_call_without_gvl returned an error, break out of loop
+			break;
+		}
+		
+		struct IO_Event_WorkerPool_Work *work = (struct IO_Event_WorkerPool_Work *)result;
 
 		if (!work) {
 			// Shutdown signal received