change spinlock

Author: k-morozov

src/components/sync/queue_spinlock.h

@@ -16,6 +16,10 @@ class QueueSpinLock final {
             host.Acquire(this);
         }
         ~Guard() {
+            Release();
+        }
+
+        void Release() {
             host.Release(this);
         }
 

src/fiber/awaiter/mutex_awaiter.h

@@ -8,6 +8,7 @@
 
 #include <components/intrusive/list.h>
 #include <components/sync/spinLock.h>
+#include <components/sync/queue_spinlock.h>
 #include <fiber/awaiter/awaiter.h>
 
 namespace NFibers {
@@ -16,25 +17,27 @@ template <class M>
 class AsyncMutexWaiter : public IAwaiter,
                          public NComponents::Node<AsyncMutexWaiter<M>> {
 public:
-    using Guard = std::unique_lock<typename M::Spinlock>;
+    using Guard = NSync::QueueSpinLock::Guard;
 
-    AsyncMutexWaiter(M* mutex, Guard guard)
-        : mutex(mutex), guard(std::move(guard)){};
+    AsyncMutexWaiter(M* async_mutex, Guard& guard)
+        : async_mutex(async_mutex), guard(guard){};
 
     void AwaitSuspend(StoppedFiber handle) override {
         assert(handle.IsValid());
 
         stopped_handle = handle;
-        mutex->Park(this);
-        guard.release()->unlock();
+        async_mutex->Park(this);
+
+//        guard.release()->unlock();
+        guard.Release();
     }
 
     void Schedule() { stopped_handle.Schedule(); }
 
 private:
-    M* mutex;
+    M* async_mutex;
     StoppedFiber stopped_handle;
-    Guard guard;
+    Guard& guard;
 };
 
 }  // namespace NFibers

src/fiber/sync/async_mutex.cpp

@@ -11,7 +11,7 @@ namespace NFibers {
 void AsyncMutex::Lock() {
     Waiter::Guard guard(spinlock_);
     if (locked_) {
-        Waiter waiter(this, std::move(guard));
+        Waiter waiter(this, guard);
         Suspend(&waiter);
     } else {
         locked_ = true;

src/fiber/sync/async_mutex.h

@@ -8,12 +8,13 @@
 
 #include <components/intrusive/list.h>
 #include <components/sync/spinLock.h>
+#include <components/sync/queue_spinlock.h>
 #include <fiber/awaiter/mutex_awaiter.h>
 
 namespace NFibers {
 
 class AsyncMutex {
-    using Spinlock = NSync::SpinLock;
+    using Spinlock = NSync::QueueSpinLock;
     using Waiter = AsyncMutexWaiter<AsyncMutex>;
 
     friend Waiter;