source: trunk/test/queue.cc @ 3057

// $Id: queue.cc 3057 2013-07-01 05:38:07Z peter $

/*
  Copyright (C) 2013 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 <boost/thread.hpp>

#include <iostream>

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);
      // Make sure we can be interrupted
      boost::this_thread::interruption_point();
    }
  }

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

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

  boost::thread_group workers;
  workers.create_thread(Worker(queue));
  workers.create_thread(Worker(queue));
  workers.create_thread(Worker(queue));
  workers.create_thread(Worker(queue));

  workers.join_all();

  std::cerr << "OK\n";
  return 0;
}