realtimebiomechanics/concurrency

Lightweight modern C++ library for thread synchronization with no dependencies

concurrency's Issues

ReadMe example is no longer working - Hanging on `subscribersMissingRead_`

I am trying to make a sample around Queue to understand how it works. But the sample inside the readme doesn't seem to work.

My exact code:

#include <thread>
#include <iostream>
#include "rtb/concurrency/Concurrency.h"

using rtb::Concurrency::Queue;

void produce(int n, Queue<int>* q) {
    for (int i = 0; i < n; ++i) {
        q->push(i);
    }
}

void consume(Queue<int>* q) {

    std::cout << "Starting consume..." << std::endl;

    q->subscribe();

    auto val = q->pop();
    std::cout << val << std::endl;

    q->unsubscribe();
}

int main() {

    Queue<int> q;

    std::thread consThr(&consume, &q);
    std::thread prodThr(&produce, 10, &q);

    prodThr.join();
    consThr.join();

    return 0;
}

But debugger shows the consume method keeps hanging on q->pop(), here exactly: https://github.com/RealTimeBiomechanics/Concurrency/blob/develop/lib/include/rtb/concurrency/Queue.cpp#L24

Any clue what I'm doing wrong here?

EDIT: Currently up-to-date with the master branch.