fix use-after-free

fix use-after-free

1 files changed, 5 insertions, 0 deletions

diff --git a/ydb/public/sdk/cpp/client/ydb_persqueue_core/impl/impl_tracker.h b/ydb/public/sdk/cpp/client/ydb_persqueue_core/impl/impl_tracker.h
index 98be271edf4..9fe0d3ae04e 100644
--- a/ydb/public/sdk/cpp/client/ydb_persqueue_core/impl/impl_tracker.h
+++ b/ydb/public/sdk/cpp/client/ydb_persqueue_core/impl/impl_tracker.h
@@ -72,6 +72,11 @@ public:
     };
 
 public:
+    ~TImplTracker() {
+        // to synchronize with last Decrement() in other thread
+        TGuard guard(Lock);
+    }
+
     std::shared_ptr<TWire> MakeTrackedWire() {
         return std::make_shared<TWire>(*this);
     }