about summary refs log tree commit diff
path: root/compiler/rustc_data_structures/src/sync/parallel.rs
diff options
context:
space:
mode:
authorJohn Kåre Alsaker <john.kare.alsaker@gmail.com>2024-03-02 18:32:42 +0100
committerJohn Kåre Alsaker <john.kare.alsaker@gmail.com>2025-04-29 14:03:07 +0200
commitef9403371f2d4759cd7b0d0a276e63aae2ce68fe (patch)
treee08c50bc567a888aa52f2d4d346bf846c867bfc1 /compiler/rustc_data_structures/src/sync/parallel.rs
parentefcbb94dccbe0fcc1076f031f88332db4a6a2a52 (diff)
downloadrust-ef9403371f2d4759cd7b0d0a276e63aae2ce68fe.tar.gz
rust-ef9403371f2d4759cd7b0d0a276e63aae2ce68fe.zip
Drop AST on a separate thread and prefetch `hir_crate`
Diffstat (limited to 'compiler/rustc_data_structures/src/sync/parallel.rs')
-rw-r--r--compiler/rustc_data_structures/src/sync/parallel.rs11
1 files changed, 11 insertions, 0 deletions
diff --git a/compiler/rustc_data_structures/src/sync/parallel.rs b/compiler/rustc_data_structures/src/sync/parallel.rs
index ba3c85ef5b1..64db39cc4c6 100644
--- a/compiler/rustc_data_structures/src/sync/parallel.rs
+++ b/compiler/rustc_data_structures/src/sync/parallel.rs
@@ -93,6 +93,17 @@ macro_rules! parallel {
         };
     }
 
+pub fn spawn(func: impl FnOnce() + DynSend + 'static) {
+    if mode::is_dyn_thread_safe() {
+        let func = FromDyn::from(func);
+        rayon_core::spawn(|| {
+            (func.into_inner())();
+        });
+    } else {
+        func()
+    }
+}
+
 // This function only works when `mode::is_dyn_thread_safe()`.
 pub fn scope<'scope, OP, R>(op: OP) -> R
 where