Класс C ++ 11 Watchdog, тестовое приложение не хочет выходить

Я использую онлайн C++11 компилятор, ссылка найдена здесь: cpp.sh (C ++ Shell).

В моем текущем проекте я хотел бы иметь класс-сторож, чтобы иметь возможность каким-либо образом проверять состояние потока или FSM (например).

После некоторой работы (я не C++11 гуру), я наконец получил код ниже, который компилируется нормально.
Я также сделал некоторые основные / тривиальные тесты, но кажется тестовая программа не хочет выходить.
Это говорит «Программа работает«и единственный способ (принудительно) выйти — ударить»Стопкнопка … 🙁

Ну мой вопрос : Что я делаю неправильно?
Любые идеи, предложения, которые вы можете предоставить, высоко ценятся.

Здесь full codeвключая мое тестовое приложение:

Сторожевой таймер (как MCVE):

#include <thread>
#include <atomic>
#include <chrono>
#include <condition_variable>
#include <mutex>
#include <iostream>

using namespace std::chrono;

class Watchdog
{
public:
Watchdog();
~Watchdog();
void Start(unsigned int milliseconds, std::function<void()> callback = 0);
void Stop();
void Pet();

private:
unsigned int m_interval;
std::atomic<bool> m_running;
std::thread m_thread;
std::function<void()> m_callback;
std::mutex m_mutex;
steady_clock::time_point m_lastPetTime;
std::condition_variable m_stopCondition;
void Loop();
};

Watchdog::Watchdog()
{
m_running = false;
}

Watchdog::~Watchdog()
{
Stop();
}

void Watchdog::Start(unsigned int milliseconds, std::function<void()> callback)
{
std::unique_lock<std::mutex> locker(m_mutex);
if(m_running == false)
{
m_lastPetTime = steady_clock::now();
m_interval = milliseconds;
m_callback = callback;
m_running = true;
m_thread = std::thread(&Watchdog::Loop, this);
}
}

void Watchdog::Stop()
{
std::unique_lock<std::mutex> locker(m_mutex);
if(m_running == true)
{
m_running = false;
m_stopCondition.notify_all();
m_thread.join();
}
}

void Watchdog::Pet()
{
std::unique_lock<std::mutex> locker(m_mutex);
m_lastPetTime = steady_clock::now();
m_stopCondition.notify_all();
}

void Watchdog::Loop()
{
std::unique_lock<std::mutex> locker(m_mutex);
while(m_running == true)
{
if(m_stopCondition.wait_for(locker, milliseconds(m_interval)) == std::cv_status::timeout)
{
if(m_callback != nullptr)
m_callback();
}
}
}

int main(int argc, char *argv[])
{
Watchdog wdog;

wdog.Start(3000, [] { std::cout << " WDOG TRIGGERED!!! "; });
for(auto i = 0; i < 10; i++)
{
std::cout << "[+]";
wdog.Pet();
std::this_thread::sleep_for(std::chrono::milliseconds(500));
}
}

1

Решение

Вы делаете тупик здесь.

void Watchdog::Stop()
{
std::unique_lock<std::mutex> locker(m_mutex);
if(m_running == true)
{
m_running = false;
m_stopCondition.notify_all();
m_thread.join();
^ ~~~~~~~~~~~~~~
m_mutex is locked; m_thread cannot continue execution
}
}

Некоторые дополнительные предложения: используйте простые if условия, не сравнить с true или же false,

2

Другие решения

Других решений пока нет …

По вопросам рекламы [email protected]