免费企业网站 优帮云,计算机网络技术吃香吗,亿企搜网站建设,主机屋如何做网站个人认为一个完备的定时器需要有如下功能#xff1a;在某一时间点执行某一任务在某段时间后执行某一任务重复执行某一任务N次#xff0c;任务间隔时间T那么如何实现定时器呢#xff1f;下面是我自己实现的定时器逻辑#xff0c;源码链接最后会附上。定时器中主要的数据结构… 个人认为一个完备的定时器需要有如下功能在某一时间点执行某一任务在某段时间后执行某一任务重复执行某一任务N次任务间隔时间T那么如何实现定时器呢下面是我自己实现的定时器逻辑源码链接最后会附上。定时器中主要的数据结构优先级任务队列队列中存储任务每个任务会添加时间戳最近的时间戳的任务会先出队。锁和条件变量当有任务需要执行时用于通知正在等待的线程从任务队列中取出任务执行。线程池各个任务会放在线程池中执行。下面是相关代码class TimerQueue {public: struct InternalS { std::chrono::time_pointstd::chrono::high_resolution_clock time_point_; std::functionvoid() func_; bool operator(const InternalS b) const { return time_point_ b.time_point_; } }; enum class RepeatedIdState { kInit 0, kRunning 1, kStop 2 };
private: std::priority_queuequeue_; bool running_ false; std::mutex mutex_; std::condition_variable cond_;wzq::ThreadPool thread_pool_;std::atomicint repeated_func_id_; wzq::ThreadSafeMapint, RepeatedIdState repeated_id_state_map_;};
如何开启定时器功能打开内部的线程池功能用于执行放入定时器中的任务同时新开一个线程循环等待任务到来后送入线程池中执行。bool Run() { bool ret thread_pool_.Start(); if (!ret) { return false; } std::thread([this]() { RunLocal(); }).detach(); return true;}
void RunLocal() { while (running_) { std::unique_lockstd::mutex lock(mutex_); if (queue_.empty()) { cond_.wait(lock); continue; } auto s queue_.top(); auto diff s.time_point_ - std::chrono::high_resolution_clock::now(); if (std::chrono::duration_caststd::chrono::milliseconds(diff).count() 0) { cond_.wait_for(lock, diff); continue; } else { queue_.pop(); lock.unlock(); thread_pool_.Run(std::move(s.func_)); } }}
如何在某一时间点执行任务根据时间戳构造InternalS放入队列中template typename F, typename... Args
void AddFuncAtTimePoint(const std::chrono::time_pointstd::chrono::high_resolution_clock time_point, F f, Args... args) { InternalS s; s.time_point_ time_point; s.func_ std::bind(std::forward(f), std::forward(args)...); std::unique_lockstd::mutex lock(mutex_); queue_.push(s); cond_.notify_all();}
如何循环执行任务首先为这个循环任务生成标识ID外部可以通过ID来取消此任务继续执行代码如下内部以类似递归的方式循环执行任务。template typename R, typename P, typename F, typename... Argsint AddRepeatedFunc(int repeat_num, const std::chrono::duration time, F f, Args... args) { int id GetNextRepeatedFuncId(); repeated_id_state_map_.Emplace(id, RepeatedIdState::kRunning); auto tem_func std::bind(std::forward(f), std::forward(args)...); AddRepeatedFuncLocal(repeat_num - 1, time, id, std::move(tem_func)); return id;}
int GetNextRepeatedFuncId() { return repeated_func_id_; }
template typename R, typename P, typename Fvoid AddRepeatedFuncLocal(int repeat_num, const std::chrono::duration time, int id, F f) { if (!this-repeated_id_state_map_.IsKeyExist(id)) { return; } InternalS s; s.time_point_ std::chrono::high_resolution_clock::now() time; auto tem_func std::move(f); s.repeated_id id; s.func_ [this, tem_func, repeat_num, time, id]() { tem_func(); if (!this-repeated_id_state_map_.IsKeyExist(id) || repeat_num 0) { return; } AddRepeatedFuncLocal(repeat_num - 1, time, id, std::move(tem_func)); }; std::unique_lockstd::mutex lock(mutex_); queue_.push(s); lock.unlock(); cond_.notify_all();}
声明本文于网络整理版权归原作者所有如来源信息有误或侵犯权益请联系我们删除或授权事宜。
