Change waitingForZeroQueueSizeMessage type is atomic_bool.

shibd · shibd · commit 3256ba175cc2 · 2022-10-10T16:13:56.000+08:00
diff --git a/lib/ConsumerImpl.h b/lib/ConsumerImpl.h
@@ -160,7 +160,7 @@ class ConsumerImpl : public ConsumerImplBase {
     ConsumerStatsBasePtr consumerStatsBasePtr_;
 
    private:
-    volatile bool waitingForZeroQueueSizeMessage;
+    std::atomic_bool waitingForZeroQueueSizeMessage;
     std::shared_ptr<ConsumerImpl> get_shared_this_ptr();
     bool uncompressMessageIfNeeded(const ClientConnectionPtr& cnx, const proto::MessageIdData& messageIdData,
                                    const proto::MessageMetadata& metadata, SharedBuffer& payload,
