Searched refs:num_searching (Results 1 – 3 of 3) sorted by relevance
106 if 2 * state.num_searching() >= self.num_workers { in transition_worker_to_searching()155 state.num_searching() == 0 && state.num_unparked() < self.num_workers in notify_should_wakeup()164 debug_assert_eq!(0, ret.num_searching()); in new()172 fn unpark_one(cell: &AtomicUsize, num_searching: usize) { in unpark_one()173 cell.fetch_add(num_searching | (1 << UNPARK_SHIFT), SeqCst); in unpark_one()183 state.num_searching() == 1 in dec_num_searching()197 is_searching && prev.num_searching() == 1 in dec_num_unparked()201 fn num_searching(self) -> usize { in num_searching() method227 .field("num_searching", &self.num_searching()) in fmt()239 assert_eq!(0, state.num_searching()); in test_state()
13 num_searching: AtomicUsize, field48 num_searching: AtomicUsize::new(0), in new()73 pub(super) fn num_searching(&self) -> usize { in num_searching() method74 self.num_searching.load(Acquire) in num_searching()100 if self.num_searching.load(Acquire) != 0 { in notify_local()115 .num_searching in notify_local()139 self.num_searching.fetch_add(1, AcqRel); in notify_remote()173 self.num_searching.fetch_sub(1, Release); in notify_synced()291 let num_searching = self.num_searching.load(Acquire); in try_transition_worker_to_searching() localVariable294 if 2 * num_searching >= self.num_cores - num_idle { in try_transition_worker_to_searching()[all …]
801 cx.shared().inject.len() / cx.shared().idle.num_searching() + 1 in next_remote_task_batch_synced()