From 53fb702512fda050b9405de8a6f11404d763e68b Mon Sep 17 00:00:00 2001 From: Peter Johnson Date: Mon, 13 Jul 2015 22:56:58 -0700 Subject: [PATCH] ConcurrentQueue: Add empty() function. Change-Id: I563c0343f70a5e4577a6387914d821728cbdd007 --- src/support/ConcurrentQueue.h | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/src/support/ConcurrentQueue.h b/src/support/ConcurrentQueue.h index dcbc039dae..3a62ebc537 100644 --- a/src/support/ConcurrentQueue.h +++ b/src/support/ConcurrentQueue.h @@ -15,6 +15,11 @@ template class ConcurrentQueue { public: + bool empty() const { + std::unique_lock mlock(mutex_); + return queue_.empty(); + } + T pop() { std::unique_lock mlock(mutex_); while (queue_.empty()) {