spsc-bugfix: fix deadlocked signalling bug

diff --git a/spsc-bugfix/queue-relacy.h b/spsc-bugfix/queue-relacy.h
index 71aac2a3992bd4be17499cb32297301648597d39..783357645bd3b57e43fcfd04f267bd3f47a2e0cb 100644 (file)
--- a/spsc-bugfix/queue-relacy.h
+++ b/spsc-bugfix/queue-relacy.h
@@ -22,7 +22,7 @@ public:
                node* n = new node (data);
                head($)->next.store(n, std::memory_order_release);
                head($) = n;
-               ec.signal_relaxed();
+               ec.signal();
        }
 
        T dequeue()

diff --git a/spsc-bugfix/queue.h b/spsc-bugfix/queue.h
index c77425f5b662f1de1982e9738ede23bcff4e4a07..2e2f494b6a4cf3faf497edf7c4a2c09dd9809a62 100644 (file)
--- a/spsc-bugfix/queue.h
+++ b/spsc-bugfix/queue.h
@@ -25,7 +25,7 @@ public:
                node* n = new node (data);
                head($)->next.store(n, std::memory_order_release);
                head = n;
-               ec.signal_relaxed();
+               ec.signal();
        }
 
        T dequeue()