intermediate changes

ref:cde9a383711a11544ce7e107a78147fb96cc4029

1 files changed, 61 insertions, 0 deletions

diff --git a/library/cpp/monlib/dynamic_counters/contention_ut.cpp b/library/cpp/monlib/dynamic_counters/contention_ut.cpp
new file mode 100644
index 0000000000..8798044ee3
--- /dev/null
+++ b/library/cpp/monlib/dynamic_counters/contention_ut.cpp
@@ -0,0 +1,61 @@
+#include "counters.h"
+#include <library/cpp/testing/unittest/registar.h>
+#include <util/system/event.h>
+#include <util/system/thread.h>
+
+using namespace NMonitoring;
+
+Y_UNIT_TEST_SUITE(TDynamicCountersContentionTest) {
+
+    Y_UNIT_TEST(EnsureNonlocking) {
+        TDynamicCounterPtr counters = MakeIntrusive<TDynamicCounters>();
+
+        class TConsumer : public ICountableConsumer {
+            TAutoEvent Ev;
+            TAutoEvent Response;
+            TDynamicCounterPtr Counters;
+            TThread Thread;
+
+        public:
+            TConsumer(TDynamicCounterPtr counters)
+                : Counters(counters)
+                , Thread(std::bind(&TConsumer::ThreadFunc, this))
+            {
+                Thread.Start();
+            }
+
+            ~TConsumer() override {
+                Thread.Join();
+            }
+
+            void OnCounter(const TString& /*labelName*/, const TString& /*labelValue*/, const TCounterForPtr* /*counter*/) override {
+                Ev.Signal();
+                Response.Wait();
+            }
+
+            void OnHistogram(const TString& /*labelName*/, const TString& /*labelValue*/, IHistogramSnapshotPtr /*snapshot*/, bool /*derivative*/) override {
+            }
+
+            void OnGroupBegin(const TString& /*labelName*/, const TString& /*labelValue*/, const TDynamicCounters* /*group*/) override {
+            }
+
+            void OnGroupEnd(const TString& /*labelName*/, const TString& /*labelValue*/, const TDynamicCounters* /*group*/) override {
+            }
+
+        private:
+            void ThreadFunc() {
+                // acts like a coroutine
+                Ev.Wait();
+                auto ctr = Counters->GetSubgroup("label", "value")->GetCounter("name");
+                Y_VERIFY(*ctr == 42);
+                Response.Signal();
+            }
+        };
+
+        auto ctr = counters->GetSubgroup("label", "value")->GetCounter("name");
+        *ctr = 42;
+        TConsumer consumer(counters);
+        counters->Accept({}, {}, consumer);
+    }
+
+}