Lines Matching defs:queueT_
61 while (queueT_.size() >= maxSize_) {
63 cvNotFull_.wait(lock, [&]() { return (queueT_.size() < maxSize_); });
67 queueT_.push(elem);
84 while (queueT_.empty()) {
86 cvNotEmpty_.wait(lock, [&] { return !queueT_.empty(); });
89 T elem = queueT_.front();
90 queueT_.pop();
108 if (queueT_.size() >= maxSize_) {
112 queueT_.push(elem);
130 if (queueT_.empty()) {
133 outtask = queueT_.front();
134 queueT_.pop();
144 return queueT_.size();
150 return queueT_.empty();
156 return queueT_.size() == maxSize_;
166 std::queue<T> queueT_;
196 while (queueT_.size() >= maxSize_) {
198 cvNotFull_.wait(lock, [&]() { return (queueT_.size() < maxSize_); });
202 queueT_.push(elem);
218 if (queueT_.size() >= maxSize_) {
222 queueT_.push(elem);
279 using SafeBlockQueue<T>::queueT_;