MCPcopy Create free account
hub / github.com/cameron314/concurrentqueue / consumer

Function consumer

tests/CDSChecker/enqueue_dequeue_many.cpp:8–29  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

6#include "corealgo.h"
7
8void consumer(void* param)
9{
10 int id = *(int*)param;
11 int& dequeueCount = *(int*)param;
12 dequeueCount = 0;
13
14 int last = 0;
15
16 int element;
17 bool success = try_dequeue(element);
18 if (success) {
19 MODEL_ASSERT(element > last);
20 last = element;
21 ++dequeueCount;
22 }
23 success = try_dequeue(element);
24 if (success) {
25 MODEL_ASSERT(element > last);
26 last = element;
27 ++dequeueCount;
28 }
29}
30
31void producer(void* param)
32{

Callers 1

producerFunction · 0.85

Calls 1

try_dequeueFunction · 0.85

Tested by

no test coverage detected