From 5b847052920debb3f66d0043853c4b213895429a Mon Sep 17 00:00:00 2001 From: bunnei Date: Wed, 27 Nov 2019 11:56:27 -0500 Subject: [PATCH] common: SPSCQueue: Notify after incrementing queue size. --- src/common/threadsafe_queue.h | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/src/common/threadsafe_queue.h b/src/common/threadsafe_queue.h index e714ba5b3a..033a8627ad 100644 --- a/src/common/threadsafe_queue.h +++ b/src/common/threadsafe_queue.h @@ -46,9 +46,8 @@ public: ElementPtr* new_ptr = new ElementPtr(); write_ptr->next.store(new_ptr, std::memory_order_release); write_ptr = new_ptr; - cv.notify_one(); - ++size; + cv.notify_one(); } void Pop() {