new_for_each_thread() — tailwindcss Function Reference

Architecture documentation for the new_for_each_thread() function in walk.rs from the tailwindcss codebase.

Function rust FileSystemIgnore GitignoreMatcher calls 1 called by 1

Entity Profile

FileSystemIgnore→ GitignoreMatcher→ new_for_each_thread() — tailwindcss Function Reference

Dependency Diagram

graph TD
  654d5ef1_1b1b_7e5c_528a_7066dc9d25ad["new_for_each_thread()"]
  d73ec138_1801_f65e_9f01_1730eee813b7["visit()"]
  d73ec138_1801_f65e_9f01_1730eee813b7 -->|calls| 654d5ef1_1b1b_7e5c_528a_7066dc9d25ad
  e16c7a27_1865_9055_554b_f50df737dd8e["push()"]
  654d5ef1_1b1b_7e5c_528a_7066dc9d25ad -->|calls| e16c7a27_1865_9055_554b_f50df737dd8e
  style 654d5ef1_1b1b_7e5c_528a_7066dc9d25ad fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

crates/ignore/src/walk.rs lines 1520–1547

    fn new_for_each_thread(threads: usize, init: Vec<Message>) -> Vec<Stack> {
        // Using new_lifo() ensures each worker operates depth-first, not
        // breadth-first. We do depth-first because a breadth first traversal
        // on wide directories with a lot of gitignores is disastrous (for
        // example, searching a directory tree containing all of crates.io).
        let deques: Vec<Deque<Message>> = std::iter::repeat_with(Deque::new_lifo)
            .take(threads)
            .collect();
        let stealers =
            Arc::<[Stealer<Message>]>::from(deques.iter().map(Deque::stealer).collect::<Vec<_>>());
        let stacks: Vec<Stack> = deques
            .into_iter()
            .enumerate()
            .map(|(index, deque)| Stack {
                index,
                deque,
                stealers: stealers.clone(),
            })
            .collect();
        // Distribute the initial messages, reverse the order to cancel out
        // the other reversal caused by the inherent LIFO processing of the
        // per-thread stacks which are filled here.
        init.into_iter()
            .rev()
            .zip(stacks.iter().cycle())
            .for_each(|(m, s)| s.push(m));
        stacks
    }