source: trunk/test/queue.cc

// $Id: queue.cc 3999 2020-10-08 23:22:32Z peter $

/*
  Copyright (C) 2013, 2020 Peter Johansson

  This file is part of the yat library, http://dev.thep.lu.se/yat

  The yat library is free software; you can redistribute it and/or
  modify it under the terms of the GNU General Public License as
  published by the Free Software Foundation; either version 3 of the
  License, or (at your option) any later version.

  The yat library is distributed in the hope that it will be useful,
  but WITHOUT ANY WARRANTY; without even the implied warranty of
  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
  General Public License for more details.

  You should have received a copy of the GNU General Public License
  along with yat. If not, see <http://www.gnu.org/licenses/>.
*/

#include <config.h>

#include "Suite.h"

#include "yat/utility/Queue.h"

#include <iostream>
#include <thread>
#include <vector>

using namespace theplu::yat;
using utility::Queue;

class Worker
{
public:
  Worker(Queue<std::string>& q)
  : queue_(q) {}

  void operator()(void)
  {
    std::string str = " ";
    while (str.size()) {
      queue_.pop(str);
      if (str.size()) {
        queue_.push(str.substr(1));
        if (str.size()>1)
          queue_.push(str.substr(0,str.size()-1));
      }
      sleep(1);
    }
  }

private:
  Queue<std::string>& queue_;
};

int main(int argc,char* argv[])
{
  test::Suite suite(argc, argv);
  Queue<std::string> queue;
  queue.push("Peter");

  std::vector<std::thread> threads;
  threads.push_back(std::thread(Worker(queue)));
  threads.push_back(std::thread(Worker(queue)));
  threads.push_back(std::thread(Worker(queue)));
  threads.push_back(std::thread(Worker(queue)));

  for (size_t i=0; i<threads.size(); ++i)
    threads[i].join();

  Queue<std::string> queue2(queue);

  queue2 = queue;

  return suite.return_value();
}