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 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114
| #include <mutex> #include <atomic>
template<typename T> class ThreadSafeSharedPtr { private: struct ControlBlock { std::atomic<size_t> count; T* ptr; std::mutex mutex;
explicit ControlBlock(T* p) : count(1), ptr(p) {} ~ControlBlock() { delete ptr; } };
ControlBlock* controlBlock;
void acquire() { if (controlBlock) { std::lock_guard<std::mutex> lock(controlBlock->mutex); ++(controlBlock->count); } }
void release() { if (controlBlock) { bool shouldDelete = false; { std::lock_guard<std::mutex> lock(controlBlock->mutex); if (--(controlBlock->count) == 0) { shouldDelete = true; } } if (shouldDelete) { delete controlBlock; } } }
public: explicit ThreadSafeSharedPtr(T* ptr = nullptr) : controlBlock(nullptr) { if (ptr) { controlBlock = new ControlBlock(ptr); } }
ThreadSafeSharedPtr(const ThreadSafeSharedPtr& other) : controlBlock(other.controlBlock) { acquire(); }
ThreadSafeSharedPtr(ThreadSafeSharedPtr&& other) noexcept : controlBlock(other.controlBlock) { other.controlBlock = nullptr; }
~ThreadSafeSharedPtr() { release(); }
ThreadSafeSharedPtr& operator=(const ThreadSafeSharedPtr& other) { if (this != &other) { release(); controlBlock = other.controlBlock; acquire(); } return *this; }
ThreadSafeSharedPtr& operator=(ThreadSafeSharedPtr&& other) noexcept { if (this != &other) { release(); controlBlock = other.controlBlock; other.controlBlock = nullptr; } return *this; }
T& operator*() const { return *(controlBlock->ptr); }
T* operator->() const { return controlBlock->ptr; }
T* get() const { return controlBlock ? controlBlock->ptr : nullptr; }
size_t use_count() const { if (!controlBlock) return 0; std::lock_guard<std::mutex> lock(controlBlock->mutex); return controlBlock->count; }
void reset(T* ptr = nullptr) { release(); if (ptr) { controlBlock = new ControlBlock(ptr); } else { controlBlock = nullptr; } } };
|