[yt provider] Use rwlock

1 files changed, 8 insertions, 8 deletions

diff --git a/ydb/library/yql/utils/threading/async_queue.h b/ydb/library/yql/utils/threading/async_queue.h
index 173927a894..3dd75b9e08 100644
--- a/ydb/library/yql/utils/threading/async_queue.h
+++ b/ydb/library/yql/utils/threading/async_queue.h
@@ -7,7 +7,7 @@
 #include <util/generic/ptr.h>
 #include <util/generic/function.h>
 #include <util/system/guard.h>
-#include <util/system/mutex.h>
+#include <util/system/rwlock.h>
 
 #include <exception>
 
@@ -20,18 +20,18 @@ public:
     static TPtr Make(size_t numThreads, const TString& poolName);
 
     void Stop() {
-        with_lock(Lock_) {
-            if (MtpQueue_) {
-                MtpQueue_->Stop();
-                MtpQueue_.Destroy();
-            }
+        auto guard = TWriteGuard(Lock_);
+        if (MtpQueue_) {
+            MtpQueue_->Stop();
+            MtpQueue_.Destroy();
         }
     }
 
     template <typename TCallable>
     [[nodiscard]]
     ::NThreading::TFuture<::NThreading::TFutureType<::TFunctionResult<TCallable>>> Async(TCallable&& func) {
-        with_lock(Lock_) {
+        {
+            auto guard = TReadGuard(Lock_);
             if (MtpQueue_) {
                 return ::NThreading::Async(std::move(func), *MtpQueue_);
             }
@@ -44,7 +44,7 @@ private:
     TAsyncQueue(size_t numThreads, const TString& poolName);
 
 private:
-    TMutex Lock_;
+    TRWMutex Lock_;
     THolder<IThreadPool> MtpQueue_;
 };