From 2bb774a52983db3466ed344e7be6ec8bb08eae97 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Guillermo=20C=C3=A9spedes=20Tab=C3=A1rez?=
 <1295883+dertin@users.noreply.github.com>
Date: Tue, 4 Mar 2025 05:30:49 -0300
Subject: [PATCH] fix(introspection): add conditional arbiter creation for
 io-uring support

---
 actix-web/src/introspection.rs | 13 ++++++++++++-
 1 file changed, 12 insertions(+), 1 deletion(-)

diff --git a/actix-web/src/introspection.rs b/actix-web/src/introspection.rs
index 75f5dd39..7fb0fb4e 100644
--- a/actix-web/src/introspection.rs
+++ b/actix-web/src/introspection.rs
@@ -380,14 +380,25 @@ mod tests {
         // Spawn tasks on the arbiter. Each task runs the full introspection flow and then signals completion.
         for _ in 0..NUM_TASKS {
             let (tx, rx) = oneshot::channel();
-            // Create an Arbiter with a dedicated Tokio runtime.
+
+            #[cfg(all(target_os = "linux", feature = "experimental-io-uring"))]
+            let arbiter = {
+                // TODO: pass max blocking thread config when tokio-uring enable configuration
+                // on building runtime.
+                let _ = config.max_blocking_threads;
+                Arbiter::new()
+            };
+
+            #[cfg(not(all(target_os = "linux", feature = "experimental-io-uring")))]
             let arbiter = actix_rt::Arbiter::with_tokio_rt(move || {
+                // Create an Arbiter with a dedicated Tokio runtime.
                 tokio::runtime::Builder::new_current_thread()
                     .enable_all()
                     .max_blocking_threads(max_blocking_threads)
                     .build()
                     .unwrap()
             });
+
             // Spawn the task on the arbiter.
             arbiter.spawn(async move {
                 run_full_introspection_flow();