We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 7e4e3c6 commit b33534fCopy full SHA for b33534f
1 file changed
test/stdexec/detail/test_intrusive_mpsc_queue.cpp
@@ -42,22 +42,22 @@ namespace {
42
43
std::set<test_node*> consumed_addrs;
44
45
- std::jthread producer1([&]() {
+ std::thread producer1([&]() {
46
for (int i = 0; i < num_items_per_producer; ++i) {
47
queue.push_back(nodes1[i].get());
48
produced_count.fetch_add(1, std::memory_order_relaxed);
49
}
50
});
51
52
- std::jthread producer2([&]() {
+ std::thread producer2([&]() {
53
54
queue.push_back(nodes2[i].get());
55
56
57
58
59
std::set<int> consumed;
60
- std::jthread consumer([&]() {
+ std::thread consumer([&]() {
61
int count = 0;
62
while (count < total_items) {
63
test_node* node = queue.pop_front();
0 commit comments