Mirrors/moodycamel_ConcurrentQueue
0
0
Fork 0
mirror of https://github.com/cameron314/concurrentqueue.git synced 2026-01-18 06:11:16 +01:00
Code Issues Packages Projects Releases Wiki Activity

Fixed bug in example (count can become negative) -- see issue #252

Browse Source
This commit is contained in:
Cameron
2021-07-26 07:35:50 -04:00
parent 8e960d6971
commit a724a69854
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
samples.md
View File

@@ -186,7 +186,7 @@ for (int i = 0; i != ProducerCount; ++i) {
for (int i = 0; i != ConsumerCount; ++i) {
consumers[i] = std::thread([&]() {
Item item;
while (promisedElementsRemaining.fetch_sub(1, std::memory_order_relaxed)) {
while (promisedElementsRemaining.fetch_sub(1, std::memory_order_relaxed) > 0) {
q.wait_dequeue(item);
consumeItem(item);
}