ThreadsafeQueue: add wakeup event instead of custom termination markers

This avoids the issue that the ~SDR termination marker doesn't reach the
consumer because it's still prebuffering

1 files changed, 1 insertions, 5 deletions

diff --git a/src/MemlessPoly.h b/src/MemlessPoly.h
index 4c67d46..7f00261 100644
--- a/src/MemlessPoly.h
+++ b/src/MemlessPoly.h
@@ -78,8 +78,6 @@ private:
 
     struct worker_t {
         struct input_data_t {
-            bool terminate = false;
-
             dpd_type_t dpd_type;
 
             // Valid for polynomial types
@@ -112,9 +110,7 @@ private:
 
         ~worker_t() {
             if (thread.joinable()) {
-                input_data_t terminate_tag;
-                terminate_tag.terminate = true;
-                in_queue.push(terminate_tag);
+                in_queue.trigger_wakeup();
                 thread.join();
             }
         }