make sure not producer threads are waiting before joining

stan-dev · Feb 12, 2025 · 7bd2826 · 7bd2826
1 parent 456f290
commit 7bd2826
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/src/stan/callbacks/concurrent_writer.hpp b/src/stan/callbacks/concurrent_writer.hpp
@@ -182,6 +182,8 @@ struct concurrent_writer {
   void wait() {
     continue_writing_ = false;
     if (thread_.joinable()) {
+      // If any threads are waiting for the queues to empty, notify them
+      cv.notify_all();
       thread_.join();
     }
   }