intermediate changes

ref:cde9a383711a11544ce7e107a78147fb96cc4029

1 files changed, 38 insertions, 0 deletions

diff --git a/library/cpp/coroutine/engine/condvar.h b/library/cpp/coroutine/engine/condvar.h
new file mode 100644
index 0000000000..ffceede6fa
--- /dev/null
+++ b/library/cpp/coroutine/engine/condvar.h
@@ -0,0 +1,38 @@
+#pragma once
+
+#include "events.h"
+#include "mutex.h"
+
+class TContCondVar {
+public:
+    int WaitD(TCont* current, TContMutex* mutex, TInstant deadline) {
+        mutex->UnLock();
+
+        const int ret = WaitQueue_.WaitD(current, deadline);
+
+        if (ret != EWAKEDUP) {
+            return ret;
+        }
+
+        return mutex->LockD(current, deadline);
+    }
+
+    int WaitT(TCont* current, TContMutex* mutex, TDuration timeout) {
+        return WaitD(current, mutex, timeout.ToDeadLine());
+    }
+
+    int WaitI(TCont* current, TContMutex* mutex) {
+        return WaitD(current, mutex, TInstant::Max());
+    }
+
+    void Signal() noexcept {
+        WaitQueue_.Signal();
+    }
+
+    void BroadCast() noexcept {
+        WaitQueue_.BroadCast();
+    }
+
+private:
+    TContWaitQueue WaitQueue_;
+};