intermediate changes

ref:cde9a383711a11544ce7e107a78147fb96cc4029

1 files changed, 22 insertions, 0 deletions

diff --git a/library/cpp/messagebus/session_job_count.cpp b/library/cpp/messagebus/session_job_count.cpp
new file mode 100644
index 0000000000..33322b1910
--- /dev/null
+++ b/library/cpp/messagebus/session_job_count.cpp
@@ -0,0 +1,22 @@
+#include "session_job_count.h"
+
+#include <util/system/yassert.h>
+
+using namespace NBus;
+using namespace NBus::NPrivate;
+
+TBusSessionJobCount::TBusSessionJobCount()
+    : JobCount(0)
+{
+}
+
+TBusSessionJobCount::~TBusSessionJobCount() {
+    Y_VERIFY(JobCount == 0, "must be 0 job count to destroy job");
+}
+
+void TBusSessionJobCount::WaitForZero() {
+    TGuard<TMutex> guard(Mutex);
+    while (AtomicGet(JobCount) > 0) {
+        CondVar.WaitI(Mutex);
+    }
+}