intermediate changes

ref:cde9a383711a11544ce7e107a78147fb96cc4029

1 files changed, 41 insertions, 0 deletions

diff --git a/library/cpp/messagebus/actor/thread_extra.h b/library/cpp/messagebus/actor/thread_extra.h
new file mode 100644
index 0000000000..b5aa151618
--- /dev/null
+++ b/library/cpp/messagebus/actor/thread_extra.h
@@ -0,0 +1,41 @@
+#pragma once
+
+#include <util/thread/singleton.h>
+
+namespace NTSAN {
+    template <typename T>
+    inline void RelaxedStore(volatile T* a, T x) {
+        static_assert(std::is_integral<T>::value || std::is_pointer<T>::value, "expect std::is_integral<T>::value || std::is_pointer<T>::value");
+#ifdef _win_
+        *a = x;
+#else
+        __atomic_store_n(a, x, __ATOMIC_RELAXED);
+#endif
+    }
+
+    template <typename T>
+    inline T RelaxedLoad(volatile T* a) {
+#ifdef _win_
+        return *a;
+#else
+        return __atomic_load_n(a, __ATOMIC_RELAXED);
+#endif
+    }
+
+}
+
+void SetCurrentThreadName(const char* name);
+
+namespace NThreadExtra {
+    namespace NPrivate {
+        template <typename TValue, typename TTag>
+        struct TValueHolder {
+            TValue Value;
+        };
+    }
+}
+
+template <typename TValue, typename TTag>
+static inline TValue* FastTlsSingletonWithTag() {
+    return &FastTlsSingleton< ::NThreadExtra::NPrivate::TValueHolder<TValue, TTag>>()->Value;
+}