многопоточность — нужна помощь в реализации класса таймера / тикера в переполнении стека
Нужна помощь в реализации класса тикера с функциями запуска / остановки / паузы, присваиваемого обратного вызова (onTick) с выполнением в отдельном потоке каждый интервал интервала. Интервал может быть указан и обновлен. Надеюсь, это должно быть кроссплатформенным.
Вот моя наивная попытка, но она не очень хороша (цикл while в start () в настоящее время блокирует, но в идеале он должен выполняться в отдельном потоке, но я не могу понять, как этого добиться), так как я довольно нуб Модель многопоточности C ++:
#include <cstdint>
#include <functional>
#include <chrono>
#include <thread>
#include <future>
class Ticker {
public:
typedef std::chrono::duration<int64_t, std::nano> tick_interval_t;
typedef std::function<void()> on_tick_t;
Ticker (std::function<void()> onTick, std::chrono::duration<int64_t, std::nano> tickInterval)
: _onTick (onTick)
, _tickInterval (tickInterval)
, _running (false) {}
~Ticker () {}
void start () {
if (_running) return;
_running = true;
while (_running) {
std::async( std::launch::async, _onTick );
std::this_thread::sleep_for( _tickInterval );
}
}
void stop () { _running = false; }
private:
on_tick_t _onTick;
tick_interval_t _tickInterval;
bool _running;
};
Я совершенно не прав в своей попытке или это довольно близко?
Решение
Рассмотрим следующий код с примером использования. Надеюсь, я вас правильно понял.
Просто запустите свой while цикл в отдельном потоке.
#include <cstdint>
#include <functional>
#include <chrono>
#include <thread>
#include <future>
#include <condition_variable>
#include <iostream>
#include <mutex>
class Ticker {
public:
typedef std::chrono::duration<int64_t, std::nano> tick_interval_t;
typedef std::function<void()> on_tick_t;
Ticker (std::function<void()> onTick, std::chrono::duration<int64_t, std::nano> tickInterval)
: _onTick (onTick)
, _tickInterval (tickInterval)
, _running (false) {}
~Ticker () {}
void start () {
if (_running) return;
_running = true;
std::thread run(&Ticker::timer_loop, this);
run.detach();
}
void stop () { _running = false; }
void setDuration(std::chrono::duration<int64_t, std::nano> tickInterval)
{
_tickIntervalMutex.lock();
_tickInterval = tickInterval;
_tickIntervalMutex.unlock();
}
private:
void timer_loop()
{
while (_running) {
std::thread run(_onTick );
run.detach();
_tickIntervalMutex.lock();
std::chrono::duration<int64_t, std::nano> tickInterval = _tickInterval;
_tickIntervalMutex.unlock();
std::this_thread::sleep_for( tickInterval );
}
}
on_tick_t _onTick;
tick_interval_t _tickInterval;
volatile bool _running;
std::mutex _tickIntervalMutex;
};
void tick()
{
std::cout << "tick\n";
}
void main()
{
std::chrono::duration<int, std::milli> timer_duration1(1000);
std::chrono::duration<int, std::milli> timer_duration2(500);
std::chrono::duration<int> main_wait(5);
Ticker ticker(std::function<void()>(tick), timer_duration1);
ticker.start();
std::this_thread::sleep_for(main_wait);
ticker.setDuration(timer_duration2);
std::this_thread::sleep_for(main_wait);
ticker.stop();
}
Другие решения