realtimebiomechanics / concurrency Goto Github PK

#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;
}