/* This file is part of Raul. Copyright 2007-2012 David Robillard Raul 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 any later version. Raul 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 Raul. If not, see . */ #include #include "raul/log.hpp" #include "raul/AtomicInt.hpp" #include "raul/Semaphore.hpp" #include "raul/Thread.hpp" #include "raul/ThreadVar.hpp" using namespace std; using namespace Raul; Raul::ThreadVar var(0); Raul::AtomicInt n_errors(0); class Waiter : public Raul::Thread { public: Waiter(Semaphore& sem) : Raul::Thread("Waiter"), _sem(sem) { if (set_scheduling(true, 10)) { Raul::warn << "Set priority on non-existent thread" << endl; } } private: void _run() { if (!set_scheduling(true, 10)) { Raul::error << "Failed to set priority" << endl; } var = 41; cout << "[Waiter] Waiting for signal..." << endl; _sem.wait(); cout << "[Waiter] Received signal, exiting" << endl; var = 42; if (var != 42) { Raul::error << "[Waiter] var != 42" << endl; ++n_errors; } } Semaphore& _sem; }; int main() { Thread& main_thread = Thread::get("Main"); if (main_thread.name() != "Main") { Raul::error << "[Main] Thread name is not 'Main'" << endl; return 1; } Semaphore sem(0); Waiter waiter(sem); waiter.start(); var = 24; cout << "[Main] Signalling..." << endl; sem.post(); cout << "[Main] Waiting for waiter..." << endl; waiter.join(); cout << "[Main] Exiting" << endl; if (var != 24) { Raul::error << "[Main] var != 24" << endl; ++n_errors; } return n_errors.get(); }