summaryrefslogtreecommitdiffstats
path: root/library/cpp/threading/thread_local/generic.h
blob: f60d5b786dd094c3d8268e42942c752b3e5cc16b (plain) (blame)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
#pragma once

#include <util/generic/ptr.h>
#include <util/generic/vector.h>

#include <functional>
#include <mutex>

namespace NThreading {

    class IGenericLocalStorage {
    public:
        struct TTraits {
            size_t Size = 0;
            std::function<void(void*)> Constructor;
            std::function<void(void*)> Destructor;
        };

        struct TData
            : TNonCopyable
        {
            TVector<char> Memory;
            std::function<void(void*)> Destructor;
        public:
            ~TData() {
                if (Destructor) {
                    Destructor(&Memory[0]);
                }
            }
        };
    public:
        virtual ~IGenericLocalStorage() {};

        void* GetMemory(const TTraits& traits) const {
            TData* data = GetData();
            if (!data->Destructor) {
                data->Destructor = traits.Destructor;
                data->Memory.resize(traits.Size);
                traits.Constructor(&data->Memory[0]);
            }
            return &data->Memory[0];
        }
    private:
        virtual TData* GetData() const = 0;
    };

    using TGenericLocalStorageFactory = std::function<THolder<IGenericLocalStorage>()>;

    void SetGenericLocalStorageFactory(TGenericLocalStorageFactory factory);
    THolder<IGenericLocalStorage> MakeGenericLocalStorage();

    template <typename T>
    class TGenericLocalValue {
    private:
        static const auto& Traits() {
            const static IGenericLocalStorage::TTraits traits = {
                .Size = sizeof(T),
                .Constructor = [](void* addr) { new (addr) T(); },
                .Destructor = [](void* addr) { static_cast<T*>(addr)->~T(); }
            };

            return traits;
        };
    public:
        T* Get() const {
            std::call_once(InitOnce_, [this]() {
                Storage_ = MakeGenericLocalStorage();
            });

            return static_cast<T*>(Storage_->GetMemory(Traits()));
        }

        T& GetRef() const {
            return *Get();
        }
    private:
        mutable std::once_flag InitOnce_;
        mutable THolder<IGenericLocalStorage> Storage_;
    };
}