always send large futures to heap

Author: mhils

tokio/src/runtime/blocking/pool.rs

@@ -300,7 +300,7 @@ impl Spawner {
         R: Send + 'static,
     {
         let (join_handle, spawn_result) =
-            if cfg!(debug_assertions) && std::mem::size_of::<F>() > BOX_FUTURE_THRESHOLD {
+            if std::mem::size_of::<F>() > BOX_FUTURE_THRESHOLD {
                 self.spawn_blocking_inner(Box::new(func), Mandatory::NonMandatory, None, rt)
             } else {
                 self.spawn_blocking_inner(func, Mandatory::NonMandatory, None, rt)
@@ -327,7 +327,7 @@ impl Spawner {
             F: FnOnce() -> R + Send + 'static,
             R: Send + 'static,
         {
-            let (join_handle, spawn_result) = if cfg!(debug_assertions) && std::mem::size_of::<F>() > BOX_FUTURE_THRESHOLD {
+            let (join_handle, spawn_result) = if std::mem::size_of::<F>() > BOX_FUTURE_THRESHOLD {
                 self.spawn_blocking_inner(
                     Box::new(func),
                     Mandatory::Mandatory,

tokio/src/runtime/handle.rs

@@ -189,7 +189,7 @@ impl Handle {
         F: Future + Send + 'static,
         F::Output: Send + 'static,
     {
-        if cfg!(debug_assertions) && std::mem::size_of::<F>() > BOX_FUTURE_THRESHOLD {
+        if std::mem::size_of::<F>() > BOX_FUTURE_THRESHOLD {
             self.spawn_named(Box::pin(future), None)
         } else {
             self.spawn_named(future, None)
@@ -296,7 +296,7 @@ impl Handle {
     /// [`tokio::time`]: crate::time
     #[track_caller]
     pub fn block_on<F: Future>(&self, future: F) -> F::Output {
-        if cfg!(debug_assertions) && std::mem::size_of::<F>() > BOX_FUTURE_THRESHOLD {
+        if std::mem::size_of::<F>() > BOX_FUTURE_THRESHOLD {
             self.block_on_inner(Box::pin(future))
         } else {
             self.block_on_inner(future)

tokio/src/runtime/runtime.rs

@@ -241,7 +241,7 @@ impl Runtime {
         F: Future + Send + 'static,
         F::Output: Send + 'static,
     {
-        if cfg!(debug_assertions) && std::mem::size_of::<F>() > BOX_FUTURE_THRESHOLD {
+        if std::mem::size_of::<F>() > BOX_FUTURE_THRESHOLD {
             self.handle.spawn_named(Box::pin(future), None)
         } else {
             self.handle.spawn_named(future, None)
@@ -329,7 +329,7 @@ impl Runtime {
     /// [handle]: fn@Handle::block_on
     #[track_caller]
     pub fn block_on<F: Future>(&self, future: F) -> F::Output {
-        if cfg!(debug_assertions) && std::mem::size_of::<F>() > BOX_FUTURE_THRESHOLD {
+        if std::mem::size_of::<F>() > BOX_FUTURE_THRESHOLD {
             self.block_on_inner(Box::pin(future))
         } else {
             self.block_on_inner(future)

tokio/src/task/builder.rs

@@ -89,7 +89,7 @@ impl<'a> Builder<'a> {
         Fut::Output: Send + 'static,
     {
         Ok(
-            if cfg!(debug_assertions) && std::mem::size_of::<Fut>() > BOX_FUTURE_THRESHOLD {
+            if std::mem::size_of::<Fut>() > BOX_FUTURE_THRESHOLD {
                 super::spawn::spawn_inner(Box::pin(future), self.name)
             } else {
                 super::spawn::spawn_inner(future, self.name)
@@ -111,7 +111,7 @@ impl<'a> Builder<'a> {
         Fut::Output: Send + 'static,
     {
         Ok(
-            if cfg!(debug_assertions) && std::mem::size_of::<Fut>() > BOX_FUTURE_THRESHOLD {
+            if std::mem::size_of::<Fut>() > BOX_FUTURE_THRESHOLD {
                 handle.spawn_named(Box::pin(future), self.name)
             } else {
                 handle.spawn_named(future, self.name)
@@ -140,7 +140,7 @@ impl<'a> Builder<'a> {
         Fut::Output: 'static,
     {
         Ok(
-            if cfg!(debug_assertions) && std::mem::size_of::<Fut>() > BOX_FUTURE_THRESHOLD {
+            if std::mem::size_of::<Fut>() > BOX_FUTURE_THRESHOLD {
                 super::local::spawn_local_inner(Box::pin(future), self.name)
             } else {
                 super::local::spawn_local_inner(future, self.name)
@@ -207,7 +207,7 @@ impl<'a> Builder<'a> {
     {
         use crate::runtime::Mandatory;
         let (join_handle, spawn_result) =
-            if cfg!(debug_assertions) && std::mem::size_of::<Function>() > BOX_FUTURE_THRESHOLD {
+            if std::mem::size_of::<Function>() > BOX_FUTURE_THRESHOLD {
                 handle.inner.blocking_spawner().spawn_blocking_inner(
                     Box::new(function),
                     Mandatory::NonMandatory,

tokio/src/task/local.rs

@@ -367,7 +367,7 @@ cfg_rt! {
         F: Future + 'static,
         F::Output: 'static,
     {
-        if cfg!(debug_assertions) && std::mem::size_of::<F>() > BOX_FUTURE_THRESHOLD {
+        if std::mem::size_of::<F>() > BOX_FUTURE_THRESHOLD {
             spawn_local_inner(Box::pin(future), None)
         } else {
             spawn_local_inner(future, None)
@@ -649,7 +649,7 @@ impl LocalSet {
         F: Future + 'static,
         F::Output: 'static,
     {
-        if cfg!(debug_assertions) && std::mem::size_of::<F>() > BOX_FUTURE_THRESHOLD {
+        if std::mem::size_of::<F>() > BOX_FUTURE_THRESHOLD {
             self.spawn_named_inner(Box::pin(future), name)
         } else {
             self.spawn_named_inner(future, name)

tokio/src/task/spawn.rs

@@ -169,7 +169,7 @@ cfg_rt! {
     {
         // preventing stack overflows on debug mode, by quickly sending the
         // task to the heap.
-        if cfg!(debug_assertions) && std::mem::size_of::<F>() > BOX_FUTURE_THRESHOLD {
+        if std::mem::size_of::<F>() > BOX_FUTURE_THRESHOLD {
             spawn_inner(Box::pin(future), None)
         } else {
             spawn_inner(future, None)