get_work() — tailwindcss Function Reference

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

Function rust FileSystemIgnore GitignoreMatcher calls 5 called by 1

Entity Profile

FileSystemIgnore→ GitignoreMatcher→ get_work() — tailwindcss Function Reference

Dependency Diagram

graph TD
  7e8149e7_be6d_59ed_5d2d_2547dcd2a85d["get_work()"]
  daea13be_da9d_f3dd_7f4f_74a78b7b3852["run()"]
  daea13be_da9d_f3dd_7f4f_74a78b7b3852 -->|calls| 7e8149e7_be6d_59ed_5d2d_2547dcd2a85d
  44abdf61_b7a0_9b17_46b1_ae6f04072002["recv()"]
  7e8149e7_be6d_59ed_5d2d_2547dcd2a85d -->|calls| 44abdf61_b7a0_9b17_46b1_ae6f04072002
  2c6ad6f7_3a4f_d6b9_9b8e_79ee03c01411["is_quit_now()"]
  7e8149e7_be6d_59ed_5d2d_2547dcd2a85d -->|calls| 2c6ad6f7_3a4f_d6b9_9b8e_79ee03c01411
  8b2accf6_d61b_eb17_bca9_40fe26031480["send_quit()"]
  7e8149e7_be6d_59ed_5d2d_2547dcd2a85d -->|calls| 8b2accf6_d61b_eb17_bca9_40fe26031480
  94cbf9ae_2894_b52f_38b3_2a4bb19f955e["deactivate_worker()"]
  7e8149e7_be6d_59ed_5d2d_2547dcd2a85d -->|calls| 94cbf9ae_2894_b52f_38b3_2a4bb19f955e
  d045c298_25b9_db90_ee9b_6ddc83325038["activate_worker()"]
  7e8149e7_be6d_59ed_5d2d_2547dcd2a85d -->|calls| d045c298_25b9_db90_ee9b_6ddc83325038
  style 7e8149e7_be6d_59ed_5d2d_2547dcd2a85d fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

crates/ignore/src/walk.rs lines 1791–1838

    fn get_work(&mut self) -> Option<Work> {
        let mut value = self.recv();
        loop {
            // Simulate a priority channel: If quit_now flag is set, we can
            // receive only quit messages.
            if self.is_quit_now() {
                value = Some(Message::Quit)
            }
            match value {
                Some(Message::Work(work)) => {
                    return Some(work);
                }
                Some(Message::Quit) => {
                    // Repeat quit message to wake up sleeping threads, if
                    // any. The domino effect will ensure that every thread
                    // will quit.
                    self.send_quit();
                    return None;
                }
                None => {
                    if self.deactivate_worker() == 0 {
                        // If deactivate_worker() returns 0, every worker thread
                        // is currently within the critical section between the
                        // acquire in deactivate_worker() and the release in
                        // activate_worker() below.  For this to happen, every
                        // worker's local deque must be simultaneously empty,
                        // meaning there is no more work left at all.
                        self.send_quit();
                        return None;
                    }
                    // Wait for next `Work` or `Quit` message.
                    loop {
                        if let Some(v) = self.recv() {
                            self.activate_worker();
                            value = Some(v);
                            break;
                        }
                        // Our stack isn't blocking. Instead of burning the
                        // CPU waiting, we let the thread sleep for a bit. In
                        // general, this tends to only occur once the search is
                        // approaching termination.
                        let dur = std::time::Duration::from_millis(1);
                        std::thread::sleep(dur);
                    }
                }
            }
        }
    }