diff options
Diffstat (limited to 'src')
| -rw-r--r-- | src/common/Threading/MPSCQueue.h | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/src/common/Threading/MPSCQueue.h b/src/common/Threading/MPSCQueue.h index ac245e1b332..5f71b9dac42 100644 --- a/src/common/Threading/MPSCQueue.h +++ b/src/common/Threading/MPSCQueue.h @@ -95,10 +95,10 @@ class MPSCQueueIntrusive public: MPSCQueueIntrusive() : _dummyPtr(reinterpret_cast<T*>(std::addressof(_dummy))), _head(_dummyPtr), _tail(_dummyPtr) { - T* front = _head.load(std::memory_order_relaxed); - (front->*IntrusiveLink).store(nullptr, std::memory_order_relaxed); - // _dummy is constructed from aligned_storage and is left uninitialized so we init only its Next here - (_dummyPtr->*IntrusiveLink).store(nullptr, std::memory_order_relaxed); + // _dummy is constructed from aligned_storage and is intentionally left uninitialized (it might not be default constructible) + // so we init only its IntrusiveLink here + std::atomic<T*>* dummyNext = new (&(_dummyPtr->*IntrusiveLink)) std::atomic<T*>(); + dummyNext->store(nullptr, std::memory_order_relaxed); } ~MPSCQueueIntrusive() |