Searched refs:queue_impl (Results 1 – 4 of 4) sorted by relevance
97 void QueueFullHandler(QueueImpl* queue_impl) { in QueueFullHandler() argument98 if (!queue_impl) { in QueueFullHandler()103 const auto n = (queue_impl->size()) / 2; in QueueFullHandler()105 queue_impl->erase(queue_impl->begin(), queue_impl->begin() + n); in QueueFullHandler()
107 class queue_impl : public queue_impl_base class121 explicit queue_front(std::shared_ptr<queue_impl<T>> impl) in queue_front()141 std::shared_ptr<queue_impl<T>> impl_;151 explicit queue_back(std::shared_ptr<queue_impl<T>> impl) in queue_back()171 std::shared_ptr<queue_impl<T>> impl_;194 auto out_impl = std::make_shared<queue_impl<output_value_type>>(); in pipeline()220 auto out_impl = std::make_shared<queue_impl<output_value_type>>(); in pipeline()
90 class queue_impl : public queue_impl_base class104 explicit queue_front(std::shared_ptr<queue_impl<T>> impl) in queue_front()124 std::shared_ptr<queue_impl<T>> impl_;134 explicit queue_back(std::shared_ptr<queue_impl<T>> impl) in queue_back()154 std::shared_ptr<queue_impl<T>> impl_;186 auto out_impl = std::make_shared<queue_impl<output_value_type>>(); in pipeline()214 auto out_impl = std::make_shared<queue_impl<output_value_type>>(); in pipeline()
47 def __init__(self, queue_impl, canceled_flag): argument51 self.queue = queue_impl()218 queue_impl = multiprocessing.Queue229 queue_impl = queue.Queue234 provider = TestProvider(queue_impl, canceled_flag)