Linux — C ++ не может остановить динамические циклы в многопоточном приложении

Я пишу многопоточный сервер с C ++ и libev и имеет одну проблему. Я запускаю default_loop в основном потоке и создаю и запускаю dynamic_loop в каждом подчиненном потоке. Когда я обрабатываю сигналы для остановки процесса, я вызываю break_loop (ev :: ALL). После того, как этот цикл событий по умолчанию остановился, но все динамические циклы работают, нужна помощь, чтобы остановить динамические циклы.

Среда:
ОС: Opensuse 13.1

компилятор: g ++ (SUSE Linux) 4.8.1 20130909

libev: 4.15

источник:

#include <vector>
#include <memory>
#include <ev++.h>
#include <thread>
#include <iostream>

class Thread
{
public:
typedef std::thread thread_t;
Thread() {std::cout << "thread created" << std::endl;}
~Thread() {std::cout << "Thread destructed" << std::endl;}
virtual void start() {this->thread = thread_t(&Thread::run, this);}
virtual void stop()
{
std::cout << "unloop" << std::endl;
std::cout << this->thread.get_id() << std::endl;

if(this->thread.joinable())
std::cout << " it's joinable" << std::endl;

this->loop->break_loop(ev::ALL);

this->thread.join();
std::cout << "Thread " << this->thread.get_id() << " stopped" << std::endl;
}

void run()
{
this->loop = new ev::dynamic_loop(ev::AUTO);

this->timer.set(*this->loop);
this->timer.set<Thread, &Thread::on_timer>(this);
this->timer.start(1, 1);

std::cout << "Thread " << this->thread.get_id() << " started" << std::endl;

this->loop->run(0);

this->timer.stop();

std::cout << "Thread " << this->thread.get_id() << " finalized" << std::endl;
}

void on_timer()
{
std::cout << "Time event" << std::endl;
}
protected:
thread_t thread;
ev::dynamic_loop *loop;
ev::timer timer;
private:
Thread(const Thread &) = delete;
void operator=(const Thread &) = delete;
};

class Server {
public:
void run()
{
std::cout << "Start server" << std::endl;

this->sigint.set<&Server::on_terminate_signal>();
this->sigint.start(SIGINT);

this->sigterm.set<&Server::on_terminate_signal>();
this->sigterm.start(SIGTERM);

this->sigkill.set<Server::on_terminate_signal>();
this->sigkill.start(SIGKILL);

std::vector<Thread*> threads;

for(auto i = 0; i< 5; i++)
{
auto buf = new Thread();
buf->start();
threads.push_back(buf);
}

this->loop.run(0);

this->sigint.stop();
this->sigterm.stop();
this->sigkill.stop();

for(auto *iter: threads)
{
iter->stop();
delete (&iter);
}

std::cout << "Gracefull exit" << std::endl;
}
protected:
ev::default_loop loop;
ev::sig sigint;
ev::sig sigkill;
ev::sig sigterm;

static void on_terminate_signal(ev::sig& signal, int)
{
signal.loop.break_loop(ev::ALL);
signal.stop();
std::cout << "Signal handled" << std::endl;
}
};

int main(int, char**)
{
std::cout << "libev " << ev::version_major() << "." << ev::version_minor() << std::endl;
Server server;
server.run();

return 0;
}

Выход:

  libev 4.15
Start server
thread created
thread created
thread created
thread created
thread created
Thread 139639372617472 started
Thread 139639326365440 started
Thread 139639337928448 started
Thread 139639361054464 started
Thread 139639349491456 started
Time event
Time event
Time event
Time event
Time event
Time event
Time event
Time eventTime event

Time event
Time event
Time event
Time event
Time event
Time event
^CSignal handled
unloop
139639372617472
it's joinable
Time eventTime event

Time event
Time event
Time event
Time event
Time event
Time event
Time event

Time event

флаги компиляции: -O0 -g -std = c ++ 11

флаги компоновщика: -lev

UPD, исходный код с кодом wok:

    #include <vector>
#include <memory>
#include <ev++.h>
#include <thread>
#include <iostream>

class Thread {
public:
typedef std::thread thread_t;
Thread(): loop(ev::AUTO) {std::cout << "thread created" << std::endl;}
virtual ~Thread() {std::cout << "Thread destructed" << std::endl;}
virtual void start() {this->thread = thread_t(&Thread::run, this);}
virtual void stop()
{
std::cout << "Try stopping " << this->thread.get_id() << std::endl;

this->stopper.send();
this->thread.join();
}

void run()
{
this->timer.set(this->loop);
this->timer.set<Thread, &Thread::on_timer>(this);
this->timer.start(1, 1);

this->stopper.set(this->loop);
this->stopper.set<Thread, &Thread::on_stop>(this);
this->stopper.start();

std::cout << "Thread " << this->thread.get_id() << " started" << std::endl;

this->loop.run(0);

std::cout << "Thread " << this->thread.get_id() << " finalized" << std::endl;
}
protected:
thread_t thread;
ev::dynamic_loop loop;
ev::timer timer;
ev::async stopper;

void on_timer()
{
std::cout << "Time event" << std::endl;
}

void on_stop()
{
std::cout << "On stop event " << std::endl;

this->stopper.stop();
this->timer.stop();

this->loop.break_loop(ev::ALL);
}
private:
Thread(const Thread &) = delete;
void operator=(const Thread &) = delete;
};

class Server {
public:
void run()
{
std::cout << "Start server" << std::endl;

this->sigint.set<&Server::on_terminate_signal>();
this->sigint.start(SIGINT);

this->sigterm.set<&Server::on_terminate_signal>();
this->sigterm.start(SIGTERM);

this->sigkill.set<Server::on_terminate_signal>();
this->sigkill.start(SIGKILL);

std::vector<Thread*> threads;

for(auto i = 0; i< 5; i++)
{
auto buf = new Thread();
buf->start();
threads.push_back(buf);
}

this->loop.run(0);

this->sigint.stop();
this->sigterm.stop();
this->sigkill.stop();

for (auto &iter: threads)
{
iter->stop();
delete iter;
}

std::cout << "Gracefull exit" << std::endl;
}
protected:
ev::default_loop loop;
ev::sig sigint;
ev::sig sigkill;
ev::sig sigterm;

static void on_terminate_signal(ev::sig& signal, int)
{
signal.loop.break_loop(ev::ALL);
signal.stop();
std::cout << "Signal handled" << std::endl;
}
};

int main(int, char**)
{
std::cout << "libev " << ev::version_major() << "." << ev::version_minor() << std::endl;
Server server;
server.run();

return 0;
}