use constants

Author: sokra

turbopack/crates/turbo-tasks-backend/src/backend/mod.rs

@@ -72,6 +72,16 @@ use crate::{
     },
 };
 
+/// Threshold for parallelizing making dependent tasks dirty.
+/// If the number of dependent tasks exceeds this threshold,
+/// the operation will be parallelized.
+const DEPENDENT_TASKS_DIRTY_PARALLIZATION_THRESHOLD: usize = 128;
+
+/// Threshold for parallelizing prefetching tasks.
+/// If the number of tasks to prefetch exceeds this threshold,
+/// the operation will be parallelized.
+const PREFETCH_TASKS_PARALLIZATION_THRESHOLD: usize = 128;
+
 const SNAPSHOT_REQUESTED_BIT: usize = 1 << (usize::BITS - 1);
 
 /// Configurable idle timeout for snapshot persistence.
@@ -2212,7 +2222,7 @@ impl<B: BackingStorage> TurboTasksBackendInner<B> {
             span.record("result", "marked dirty");
         }
 
-        if output_dependent_tasks.len() > 128 {
+        if output_dependent_tasks.len() > DEPENDENT_TASKS_DIRTY_PARALLIZATION_THRESHOLD {
             let chunk_size = good_chunk_size(output_dependent_tasks.len());
             let chunks = into_chunks(output_dependent_tasks.to_vec(), chunk_size);
             let _ = scope_and_block(chunks.len(), |scope| {
@@ -2605,7 +2615,7 @@ impl<B: BackingStorage> TurboTasksBackendInner<B> {
                     let range: Range<usize> = if let Some(range) = range {
                         range
                     } else {
-                        if data.len() > 128 {
+                        if data.len() > PREFETCH_TASKS_PARALLIZATION_THRESHOLD {
                             let chunk_size = good_chunk_size(data.len());
                             let chunks = data.len().div_ceil(chunk_size);
                             for i in 0..chunks {

turbopack/crates/turbo-tasks-backend/src/backend/operation/connect_children.rs

@@ -125,10 +125,10 @@ pub fn connect_children(
     // This avoids long pauses of more than 30µs * 10k = 300ms.
     // We don't want to parallelize too eagerly as spawning tasks and the temporary allocations have
     // a cost as well.
-    const MIN_CHILDREN_FOR_PARALLEL: usize = 10000;
+    const CONNECT_CHILDREN_PARALLIZATION_THRESHOLD: usize = 10000;
 
     let len = new_follower_ids.len();
-    if len >= MIN_CHILDREN_FOR_PARALLEL {
+    if len >= CONNECT_CHILDREN_PARALLIZATION_THRESHOLD {
         let new_follower_ids = new_follower_ids.into_vec();
         let chunk_size = good_chunk_size(len);
         let _ = scope_and_block(len.div_ceil(chunk_size), |scope| {