Merge pull request #38 from bherw/bherw/fix-close-race

fix: race condition in close #37
andreiavrammsd · Jan 25, 2024 · 51c39d5 · 51c39d5
2 parents 2cfe2c2 + 1dab254
commit 51c39d5
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/include/msd/channel.inl b/include/msd/channel.inl
@@ -65,7 +65,10 @@ constexpr bool channel<T>::empty() const noexcept
 template <typename T>
 void channel<T>::close() noexcept
 {
- is_closed_.store(true);
+ {
+ std::unique_lock<std::mutex> lock{mtx_};
+ is_closed_.store(true);
+ }
  cnd_.notify_all();
 }