Searched refs:QueueList (Results 1 – 14 of 14) sorted by relevance
82 QueueList<std::pair<TensorRow, filterCtrl>> filter_queues_;84 QueueList<TensorRow> worker_queues_; // internal queue for syncing worker
119 QueueList<std::unique_ptr<IOBlock>> io_block_queues_; // queues of IOBlocks
109 QueueList<std::unique_ptr<IOBlock>> prefetch_queues_;
153 QueueList<TensorRow> receive_queues_;
278 …QueueList<std::pair<std::unique_ptr<TensorQTable>, CBatchInfo>> worker_queues_; // internal queue…
75 auto send_to_que = [](QueueList<std::unique_ptr<IOBlock>> &qList, int32_t worker_id, in FetchSamplesToWorkers()
176 class QueueList {178 QueueList() {} in QueueList() function204 ~QueueList() = default;
107 QueueList<std::unique_ptr<IOBlock>> io_block_queues_; // queues of IOBlocks
151 QueueList<std::unique_ptr<FilenameBlock>> io_block_queues_;
133 QueueList<std::unique_ptr<MapWorkerJob>> local_queues_;
192 QueueList<T> queues_;
165 QueueList<std::unique_ptr<int>> my_list_of_queues; in TEST_F()
286 std::shared_ptr<QueueList<CacheServerRequest *>> cache_q_;
63 cache_q_ = std::make_shared<QueueList<CacheServerRequest *>>(); in DoServiceStart()