waitQueuesTest.cpp File Reference

(v0.19-24-g0617ca1 with changes)

#include "../waitQueues.h"
#include <iostream>
#include <thread>
#include <vector>
#include <chrono>

Include dependency graph for waitQueuesTest.cpp:

Go to the source code of this file.

Functions
void	o2s (int i, waitQueues::simple< int > &sq, waitQueues::ordered< int > &oq)
int	main (int argc, const char *argv[])

Function Documentation

main()

int main	(	int	argc,
		const char *	argv[]
	)

Definition at line 19 of file waitQueuesTest.cpp.

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

References waitQueues::simple< T >::dequeue(), waitQueues::ordered< T, ascending, Container >::emplace(), waitQueues::ordered< T, ascending, Container >::enqueue(), o2s(), and waitQueues::simple< T >::signalDoneThread().

Here is the call graph for this function:

o2s()

void o2s	(	int	i,
		waitQueues::simple< int > &	sq,
		waitQueues::ordered< int > &	oq
	)

Definition at line 7 of file waitQueuesTest.cpp.

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

References waitQueues::ordered< T, ascending, Container >::dequeue(), and waitQueues::simple< T >::enqueue().

Referenced by main().

Here is the call graph for this function:

Here is the caller graph for this function: