[#883, !506] must use mutex when changing state of predicate component

diff --git a/src/lib/util/thread_pool.h b/src/lib/util/thread_pool.h
index 946958dcbddbd687f36631eeeb00686e51d81be5..87727f0efdfceb93fc489c9479b206e6b7b872ad 100644 (file)
--- a/src/lib/util/thread_pool.h
+++ b/src/lib/util/thread_pool.h
@@ -207,6 +207,7 @@ private:
         ///
         /// Sets the queue state to 'enabled'
         void enable() {
+            std::lock_guard<std::mutex> lock(mutex_);
             enabled_ = true;
         }
 
@@ -214,7 +215,10 @@ private:
         ///
         /// Sets the queue state to 'disabled'
         void disable() {
-            enabled_ = false;
+            {
+                std::lock_guard<std::mutex> lock(mutex_);
+                enabled_ = false;
+            }
             // Notify pop so that it can exit.
             cv_.notify_all();
         }