Fix MpscPollableQueue:is_empty.

This commit is contained in:
levlam 2023-04-30 16:54:55 +03:00
parent 5aff4aa27b
commit 14eda7a97c

View File

@ -33,6 +33,8 @@ class MpscPollableQueue {
auto guard = lock_.lock(); auto guard = lock_.lock();
if (writer_vector_.empty()) { if (writer_vector_.empty()) {
if (i == 1) { if (i == 1) {
reader_vector_.clear();
reader_pos_ = 0;
wait_event_fd_ = true; wait_event_fd_ = true;
return 0; return 0;
} }