| | |
| | | D &operator*() const { return *p_; } |
| | | }; |
| | | |
| | | template <class T, class Mutex = std::mutex, class Lock = std::unique_lock<Mutex>> |
| | | template <class T, class TMutex = std::mutex, class Lock = std::unique_lock<TMutex>> |
| | | class Synced |
| | | { |
| | | typedef T Data; |
| | | Mutex mutex_; |
| | | TMutex mutex_; |
| | | Data data_; |
| | | typedef SyncedPtr<Data, Mutex, Lock> Ptr; |
| | | typedef SyncedPtr<Data, TMutex, Lock> Ptr; |
| | | |
| | | public: |
| | | template <class... P> |
| | |
| | | } |
| | | }; |
| | | |
| | | template <class T, class Tag> |
| | | class StaticDataRef |
| | | { |
| | | typedef T *Ptr; |
| | | static inline Ptr &ptr() |
| | | { |
| | | static Ptr sp(nullptr); |
| | | return sp; |
| | | } |
| | | |
| | | protected: |
| | | static inline T &GetData() |
| | | { |
| | | if (!ptr()) { throw std::string("Must set ShmMsg shm before use!"); } |
| | | return *ptr(); |
| | | } |
| | | |
| | | public: |
| | | static bool SetData(T &t) |
| | | { |
| | | auto Bind = [&]() { ptr() = &t; return true; }; |
| | | return ptr() ? false : Bind(); |
| | | } |
| | | }; |
| | | |
| | | // macro helper |
| | | #define JOIN_IMPL(a, b) a##b |
| | | #define JOIN(a, b) JOIN_IMPL(a, b) |