Split blocking

kdy1 · kdy1 · commit 5473b636eefe · 2025-05-23T11:02:11.000-07:00
diff --git a/turbopack/crates/turbo-tasks-backend/src/backend/mod.rs b/turbopack/crates/turbo-tasks-backend/src/backend/mod.rs
@@ -1887,7 +1887,7 @@ impl<B: BackingStorage> TurboTasksBackendInner<B> {
                     }
 
                     let this = self.clone();
-                    let snapshot = turbo_tasks::spawn_blocking(move || this.snapshot()).await;
+                    let snapshot = turbo_tasks::spawn_blocking_rayon(move || this.snapshot()).await;
                     if let Some((snapshot_start, new_data)) = snapshot {
                         last_snapshot = snapshot_start;
                         if new_data {
diff --git a/turbopack/crates/turbo-tasks-fs/src/retry.rs b/turbopack/crates/turbo-tasks-fs/src/retry.rs
@@ -29,7 +29,7 @@ where
 {
     let path = path.as_ref().to_owned();
 
-    turbo_tasks::spawn_blocking(move || {
+    turbo_tasks::spawn_blocking_tokio(move || {
         let mut attempt = 1;
 
         loop {

Original file line number	Diff line number	Diff line change
`@@ -1887,7 +1887,7 @@ impl<B: BackingStorage> TurboTasksBackendInner<B> {`
`1887`	`1887`	`}`
`1888`	`1888`
`1889`	`1889`	`let this = self.clone();`
`1890`		`- let snapshot = turbo_tasks::spawn_blocking(move \|\| this.snapshot()).await;`
	`1890`	`+ let snapshot = turbo_tasks::spawn_blocking_rayon(move \|\| this.snapshot()).await;`
`1891`	`1891`	`if let Some((snapshot_start, new_data)) = snapshot {`
`1892`	`1892`	`last_snapshot = snapshot_start;`
`1893`	`1893`	`if new_data {`
Original file line number	Diff line number	Diff line change
`@@ -29,7 +29,7 @@ where`
`29`	`29`	`{`
`30`	`30`	`let path = path.as_ref().to_owned();`
`31`	`31`
`32`		`- turbo_tasks::spawn_blocking(move \|\| {`
	`32`	`+ turbo_tasks::spawn_blocking_tokio(move \|\| {`
`33`	`33`	`let mut attempt = 1;`
`34`	`34`
`35`	`35`	`loop {`