Lines Matching refs:pending_threads
719 AtomicInteger pending_threads;
735 pending_threads.StoreRelaxed(list_.size() - num_ignored);
742 bool updated = thread->ModifySuspendCount(self, +1, &pending_threads, reason);
745 // Must install the pending_threads counter first, then check thread->IsSuspend() and clear
750 thread->ClearSuspendBarrier(&pending_threads);
751 pending_threads.FetchAndSubSequentiallyConsistent(1);
764 int32_t cur_val = pending_threads.LoadRelaxed();
767 if (futex(pending_threads.Address(), FUTEX_WAIT, cur_val, &wait_timeout, nullptr, 0) != 0) {
778 } // else re-check pending_threads in the next iteration (this may be a spurious wake-up).
