Searched refs:work_queue_ (Results 1 – 5 of 5) sorted by relevance
41 work_queue_.reset(new WorkQueue(task_queue_.get(), "test", in SetUp()44 work_queue_sets_->AddQueue(work_queue_.get(), 0); in SetUp()47 void TearDown() override { work_queue_sets_->RemoveQueue(work_queue_.get()); } in TearDown()78 std::unique_ptr<WorkQueue> work_queue_; member in base::sequence_manager::internal::WorkQueueTest84 EXPECT_TRUE(work_queue_->Empty()); in TEST_F()85 work_queue_->Push(FakeTaskWithEnqueueOrder(1)); in TEST_F()86 EXPECT_FALSE(work_queue_->Empty()); in TEST_F()90 work_queue_->Push(FakeTaskWithEnqueueOrder(1)); in TEST_F()91 work_queue_->InsertFence(EnqueueOrder::blocking_fence()); in TEST_F()92 EXPECT_FALSE(work_queue_->Empty()); in TEST_F()[all …]
71 if (!work_queue_.empty()) { in ~UnboundedThreadPool()107 work_queue_.push_back({std::move(fn), join_notification}); in RunOnPooledThread()111 all_threads_busy = work_queue_.size() > num_idle_threads_; in RunOnPooledThread()135 while (!cancelled_ && work_queue_.empty()) { in PooledThreadFunc()143 work_item = std::move(work_queue_.front()); in PooledThreadFunc()144 work_queue_.pop_front(); in PooledThreadFunc()
69 std::deque<WorkItem> work_queue_ GUARDED_BY(work_queue_mu_);
456 work_queue_.push_back(std::move(work_item)); in Schedule()466 while (!cancelled_ && work_queue_.empty()) { in WorkerLoop()472 DCHECK(!work_queue_.empty()); in WorkerLoop()473 work_item = std::move(work_queue_.front()); in WorkerLoop()474 work_queue_.pop_front(); in WorkerLoop()
939 std::deque<std::function<void()>> work_queue_ GUARDED_BY(mu_);