From c08e2ed8fc58fd3d3cffa29fcb1459747c8cfad7 Mon Sep 17 00:00:00 2001
From: Peter Johnson <johnson.peter@gmail.com>
Date: Sat, 18 Jul 2015 01:32:21 -0700
Subject: [PATCH] ConcurrentQueue: Add size() function.

---
 src/support/ConcurrentQueue.h | 5 +++++
 1 file changed, 5 insertions(+)

diff --git a/src/support/ConcurrentQueue.h b/src/support/ConcurrentQueue.h
index 3a62ebc537..b2d108457a 100644
--- a/src/support/ConcurrentQueue.h
+++ b/src/support/ConcurrentQueue.h
@@ -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()) {