Ability to get size of messages queue of async thread pool

2026-01-02 09:57:55 +08:00 · 2020-11-13 13:12:32 +03:00
parent 18e3f07f7d
commit e17ee87f38
3 changed files with 12 additions and 0 deletions
--- a/include/spdlog/details/mpmc_blocking_q.h
+++ b/include/spdlog/details/mpmc_blocking_q.h
@@ -110,6 +110,12 @@ public:
        return q_.overrun_counter();
    }

+    size_t size()
+    {
+        std::unique_lock<std::mutex> lock(queue_mutex_);
+        return q_.size();
+    }
+
 private:
    std::mutex queue_mutex_;
    std::condition_variable push_cv_;