Searched refs:barrier_ (Results 1 – 4 of 4) sorted by relevance
124 barrier_.reset(new AlternatingBarrier(num_consumers)); in LaunchConsumerThreads()132 barrier_->WaitTurn(i); in LaunchConsumerThreads()137 barrier_->Done(i); in LaunchConsumerThreads()143 barrier_->WaitTurn(i); in LaunchConsumerThreads()147 barrier_->Done(i); in LaunchConsumerThreads()172 std::unique_ptr<AlternatingBarrier> barrier_; member in tensorflow::__anon9dc664200111::GPUAllocatorRetryTest
37 #define MP_FLIGHT_RECORD(barrier_, ap_func_, ap_arg_, bsp_func_, bsp_arg_) \ argument39 .barrier = ATOMIC_INIT(barrier_), \
756 barrier_(WaitableEvent::ResetPolicy::AUTOMATIC, in RemoveWhileNotificationIsRunningObserver()763 barrier_.Wait(); in Observe()767 void Unblock() { barrier_.Signal(); } in Unblock()771 WaitableEvent barrier_; member in base::__anone249295e0311::RemoveWhileNotificationIsRunningObserver
2031 barrier_(barrier) {} in ScavengingTask()2039 barrier_->Start(); in RunInParallel()2047 scavenger_->Process(barrier_); in RunInParallel()2048 } while (!barrier_->Wait()); in RunInParallel()2062 OneshotBarrier* const barrier_; member in v8::internal::ScavengingTask