waitQueuesTest.cpp

Go to the documentation of this file.

#include "../waitQueues.h"
#include <iostream>
#include <thread>
#include <vector>
#include <chrono>
 
void o2s(int i,
     waitQueues::simple<int> &sq,
     waitQueues::ordered<int> &oq) {
  std::this_thread::sleep_for(std::chrono::milliseconds(i*100));
  std::cout << "start worker " << i << std::endl;
  while (auto item = oq.dequeue()) {
    sq.enqueue(item);
    std::this_thread::sleep_for(std::chrono::seconds(1));
  }
  std::cout << "stop worker " << i << std::endl;
}
 
int main(int argc, const char*argv[]) {
  std::cout << argv[0] << "\n";
  waitQueues::simple<int> sq;
  waitQueues::ordered<int> oq;
 
  std::vector<std::thread> workers;
  for (auto i=argc; i ; --i) {
    workers.emplace_back(o2s, i, std::ref(sq), std::ref(oq));
  }
  std::thread overseer(sq.signalDoneThread(workers.begin(),workers.end()));
  
  
  for (int i=0; i<20; i++) {
    oq.emplace(i);
    std::cout << "enqueue " << i << std::endl;
  }
  oq.enqueue(nullptr);
  std::cout << "\n";
 
  
  std::cout << "start dequeing" << std::endl;
  while (auto item=sq.dequeue()) {
    std::cout << *item << " ";
    std::cout.flush();
    delete item;
  }
  std::cout << "\n";
  oq.enqueue(nullptr);
  return 0;
}