Lines Matching refs:sleepers
17 sleepers: Mutex<Vec<usize>>, field
36 sleepers: Mutex::new(Vec::with_capacity(num_workers)), in new()
58 let mut sleepers = self.sleepers.lock().unwrap(); in worker_to_notify() localVariable
70 let ret = sleepers.pop(); in worker_to_notify()
80 let mut sleepers = self.sleepers.lock().unwrap(); in transition_worker_to_parked() localVariable
86 sleepers.push(worker); in transition_worker_to_parked()
115 let mut sleepers = self.sleepers.lock().unwrap(); in unpark_worker_by_id() localVariable
117 for index in 0..sleepers.len() { in unpark_worker_by_id()
118 if sleepers[index] == worker_id { in unpark_worker_by_id()
119 sleepers.swap_remove(index); in unpark_worker_by_id()
131 let sleepers = self.sleepers.lock().unwrap(); in is_parked() localVariable
132 sleepers.contains(&worker_id) in is_parked()