ConcurrentQueue: Add size() function.

This commit is contained in:
Peter Johnson
2015-07-18 01:32:21 -07:00
parent 2437f06c7f
commit c08e2ed8fc

View File

@@ -20,6 +20,11 @@ class ConcurrentQueue {
return queue_.empty();
}
typename std::queue<T>::size_type size() const {
std::unique_lock<std::mutex> mlock(mutex_);
return queue_.size();
}
T pop() {
std::unique_lock<std::mutex> mlock(mutex_);
while (queue_.empty()) {