We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 9cadd15 commit 4ad3896Copy full SHA for 4ad3896
src/consumer_queue.cpp
@@ -22,6 +22,8 @@ consumer_queue::~consumer_queue() {
22
}
23
24
void consumer_queue::push_sample(const sample_p &sample) {
25
+ // acquire lock for more predictable behavior in regards to pop_sample()
26
+ std::unique_lock<std::mutex> lk(lock_);
27
while (!buffer_.push(sample)) {
28
sample_p dummy;
29
buffer_.pop(dummy);
0 commit comments