| 1066 | std::atomic<bool> writer_closed{false}; |
| 1067 | std::atomic<bool> reader_closed{false}; |
| 1068 | void close_write() { |
| 1069 | writer_closed.store(true, std::memory_order_relaxed); |
| 1070 | cv.notify_all(); |
| 1071 | } |
| 1072 | void close_read() { |
| 1073 | reader_closed.store(true, std::memory_order_relaxed); |
| 1074 | cv.notify_all(); |