使用boost的deadline_timer实现一个异步定时器

简介: 概述 最近在工作上需要用到定时器,然后看到boost里面的deadline_timer可以实现一个定时器,所以就直接将其封装成了ATimer类,方便使用,ATimer有以下优点: 可以支持纳秒、毫秒、秒、分、小时定时。

概述

最近在工作上需要用到定时器,然后看到boost里面的deadline_timer可以实现一个定时器,所以就直接将其封装成了ATimer类,方便使用,ATimer有以下优点:

  1. 可以支持纳秒、毫秒、秒、分、小时定时。
  2. 可以随时停止定时器。
  3. 支持单次调用。
  4. 因为使用了deadline_timer,所以定时比较准确。

ATimer和Qt的QTimer使用方法类似,若没有类似的Timer类,使用最原始的方法,我们的代码可能会是这样的:

m_timerThread = std::thread([this]
{
    while (!m_bThreadStoped) { ++m_sleepCount; Sleep(SLEEP_DURATION_TIME); if (m_sleepCount == m_sleepAllCount) { m_sleepCount = 0; doSomeThing(); } } });

若使用QTimer的话,书写是这样的:

QTimer *timer = new QTimer(this); connect(timer, SIGNAL(timeout()), this, SLOT(update())); timer->start(1000);

再来看看ATimer的使用:

ATimer<> t;
t.bind([]{ std::cout << "Hello C++" << std::endl; }); t.start(1000);

从上面的例子可以看到,QTimer和ATimer的使用都非常方便,接下来看看ATimer的具体实现:

// ATimer.hpp
#ifndef _ATIMER_H #define _ATIMER_H #include <vector> #include <thread> #include <atomic> #include <functional> #include <boost/timer.hpp> #include <boost/asio.hpp> template<typename Duration = boost::posix_time::milliseconds> class ATimer { public: ATimer() : m_timer(m_ios, Duration(0)), m_isSingleShot(false) {} ~ATimer() { stop(); } void start(unsigned int duration) { if (m_ios.stopped()) { return; } m_isActive = true; m_duration = duration; m_timer.expires_at(m_timer.expires_at() + Duration(m_duration)); m_func = [this] { m_timer.async_wait([this](const boost::system::error_code&) { for (auto& func : m_funcVec) { func(); } if (!m_isSingleShot) { m_timer.expires_at(m_timer.expires_at() + Duration(m_duration)); m_func(); } }); }; m_func(); m_thread = std::thread([this]{ m_ios.run(); }); } void stop() { m_ios.stop(); if (m_thread.joinable()) { m_thread.join(); } m_isActive = false; } void bind(const std::function<void()>& func) { m_funcVec.emplace_back(func); } void setSingleShot(bool isSingleShot) { m_isSingleShot = isSingleShot; } bool isSingleShot() const { return m_isSingleShot; } bool isActive() const { return m_isActive; } private: boost::asio::io_service m_ios; boost::asio::deadline_timer m_timer; std::function<void()> m_func = nullptr; std::vector<std::function<void()>> m_funcVec; std::thread m_thread; unsigned int m_duration = 0; std::atomic<bool> m_isSingleShot; bool m_isActive = false; }; #endif 

下面是ATimer的具体使用例子:

// main.cpp
#include <iostream> #include "ATimer.hpp" void test() { std::cout << "Timer thread id: " << std::this_thread::get_id() << std::endl; } int main() { std::cout << "Main thread id: " << std::this_thread::get_id() << std::endl; ATimer<boost::posix_time::minutes> t0; t0.setSingleShot(true);// 单次调用 t0.bind(test); t0.start(1);// 一分钟之后调用 ATimer<> t;//默认使用毫秒定时器 t.bind(test); t.bind([]{ std::cout << "Hello C++" << std::endl; }); t.start(1000);//每1000ms调用一次 std::cin.get(); t0.stop(); t.stop(); std::cout << "Tiemr stop" << std::endl; std::cin.get(); std::cout << "Process end" << std::endl; return 0; }

from:http://www.cnblogs.com/highway-9/p/5737421.html
目录
相关文章
|
4月前
|
测试技术 PHP
Swoole 源码分析之 Timer 定时器模块
Swoole 中的毫秒精度的定时器。底层基于 `epoll_wait` 和 `setitimer` 实现,数据结构使用最小堆,可支持添加大量定时器。
77 0
Swoole 源码分析之 Timer 定时器模块
|
6月前
|
Java
【Java多线程】定时器Timer
【Java多线程】定时器Timer
51 0
【Java多线程】定时器Timer
|
6月前
|
缓存
muduo源码剖析之Timer定时器
Timer 类是 muduo 网络库中的一个定时器类,用于在指定的时间间隔后执行某个任务。Timer 类提供了一系列的方法来创建、启动、停止和删除定时器,以及设置定时器的时间间隔和回调函数等。在 muduo 网络库中,Timer 类被广泛应用于各种网络任务中,例如定期发送心跳包、更新缓存、清理资源等。通过使用 Timer 类,我们可以方便地实现定时任务,提高网络应用程序的可靠性和稳定性。:启动定时器,在指定的时间间隔后调用回调函数。:停止定时器,不再执行定时任务。
112 0
|
Linux
settime计时器和POSIX timer函数
settime计时器和POSIX timer函数
197 0
|
Java 测试技术
在多线程中自定义实现定时器(Timer)
在多线程中自定义实现定时器(Timer)
|
Java API 调度
Timer - 基础篇
Timer - 基础篇
172 0
Timer - 基础篇
ASIO的定时器
ASIO的定时器
640 0
|
消息中间件 Java C#
C# 三个Timer
C# 三个Timer
287 0
C# 三个Timer
|
Java
多线程十 Timer
多线程十 Timer
99 0