intermediate changes

ref:cde9a383711a11544ce7e107a78147fb96cc4029

1 files changed, 36 insertions, 0 deletions

diff --git a/library/cpp/messagebus/cc_semaphore.h b/library/cpp/messagebus/cc_semaphore.h
new file mode 100644
index 0000000000..0df8a3d664
--- /dev/null
+++ b/library/cpp/messagebus/cc_semaphore.h
@@ -0,0 +1,36 @@
+#pragma once
+
+#include "latch.h"
+
+template <typename TThis>
+class TComplexConditionSemaphore {
+private:
+    TLatch Latch;
+
+public:
+    void Updated() {
+        if (GetThis()->TryWait()) {
+            Latch.Unlock();
+        }
+    }
+
+    void Wait() {
+        while (!GetThis()->TryWait()) {
+            Latch.Lock();
+            if (GetThis()->TryWait()) {
+                Latch.Unlock();
+                return;
+            }
+            Latch.Wait();
+        }
+    }
+
+    bool IsLocked() {
+        return Latch.IsLocked();
+    }
+
+private:
+    TThis* GetThis() {
+        return static_cast<TThis*>(this);
+    }
+};