common: SPSCQueue: Notify after incrementing queue size.

2019-11-27 11:56:27 -05:00
1 changed files with 1 additions and 2 deletions
--- 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() {