Searched refs:queues_ (Results 1 – 3 of 3) sorted by relevance
25 queues_(num_threads), in env_()55 queues_.push_back(new Queue()); in env_()71 for (size_t i = 0; i < threads_.size(); i++) delete queues_[i]; in ~NonBlockingThreadPoolTempl() local79 Queue* q = queues_[pt->thread_id]; in Schedule()84 Queue* q = queues_[Rand(&pt->rand) % queues_.size()]; in Schedule()126 MaxSizeVector<Queue*> queues_; variable140 Queue* q = queues_[thread_id]; in WorkerLoop()175 const size_t size = queues_.size(); in Steal()180 Task t = queues_[victim]->PopBack(); in Steal()204 *t = queues_[victim]->PopBack(); in WaitForWork()[all …]
241 for (std::vector<Queue *>::iterator it = queues_[i].begin(); it != queues_[i].end(); it++) in ~Device()243 queues_[i].clear(); in ~Device()325 queues_[GRAPHICS].push_back(new Queue(queue, i)); in init_queues()329 queues_[COMPUTE].push_back(new Queue(queue, i)); in init_queues()333 queues_[DMA].push_back(new Queue(queue, i)); in init_queues()340 EXPECT(!queues_[GRAPHICS].empty() || !queues_[COMPUTE].empty()); in init_queues()
159 const std::vector<Queue *> &graphics_queues() const { return queues_[GRAPHICS]; } in graphics_queues()160 const std::vector<Queue *> &compute_queues() { return queues_[COMPUTE]; } in compute_queues()161 const std::vector<Queue *> &dma_queues() { return queues_[DMA]; } in dma_queues()218 std::vector<Queue *> queues_[QUEUE_COUNT]; variable