linux下如何实现多个定时器
最近在linux下写一个库,是给别人用的,要用到定时器这个功能,而且是多定时器任务的,在windows下实现是很方便的,但是
在linux下就遇到了问题,linux下一个进程只能有一个定时器,如果我用了定时器去实现我的任务,那肯定是没问题的,如果用我库的人自己也创建了一个定时器,
那么问题就出现了,我的定时器就被覆盖了。
我的功能肯定也受到了影响,所以linux下的定时器是需要解决的。
没办法,我就自己写了一个定时器类似功能的代码:
#ifndef CTIMER_H#define CTIMER_H#include#include #include #include#include #include #include #include #include #include #include using namespace std;#define N 100 //设置最大的定时器个数 typedef void (* Callback )( void *n_obj, void *user_data );//callbackstruct Timer //Timer结构体,用来保存一个定时器的信息{ void *user_data;//回调函数参数 void *user_obj;//回调函数参数 int microsecond_time; //每隔total_time秒 int second_time; //还剩left_time秒 int cont_time;//记录时间 int func; //该定时器超时,要执行的代码的标志 Callback n_cb;//回调函数指针}; //定义Timer类型的数组,用来保存所有的定时器class CTimer{public:CTimer();virtual~CTimer(); void addTimer(int ,int,Callback,void *,void*); //新建一个计时器 static void timeout(); //判断定时器是否超时,以及超时时所要执行的动作 void start(); void stop();private:};#endif // CTIMER_H下面是cpp;
#include "ctimer.h"#include#include#include#include #include #include std::listm_node_list; int is=0,tb=1; //i代表定时器的个数;t表示时间,逐秒递增 bool statues=true;//状态信息 std::mutex m_locker;//锁void CTimer::addTimer(int m_time,int sec_time,Callback p,void* parm1,void *parm2 ) //新建一个计时器{ struct Timer *a=new Timer; a->microsecond_time=m_time; a->second_time=sec_time; a->cont_time=sec_time; a->n_cb=p;//huidiao a->user_obj=parm1; a->user_data=parm2; m_node_list.push_back( ( void *)( a ));}CTimer::CTimer(){}CTimer::~CTimer(){}void CTimer:: timeout()//判断定时器是否超时,以及超时时所要执行的动作{ std::list::iterator it;Timer *n; for ( it = m_node_list.begin( ); it != m_node_list.end( ); it ++ ) { if ( *it != 0 ) { n = ( Timer *)( *it ); n->cont_time--; if(n->cont_time==0) { n->cont_time=n->second_time;//重新设置时间 (*n->n_cb )(n->user_data, n->user_obj );//执行回调 } } }}void CTimer::stop(){ m_locker.lock(); statues=false; m_locker.unlock();}void* singlesa(void*p){ signal(SIGUSR1,(__sighandler_t)static_cast(p)->timeout); //接到SIGALRM信号,则执行timeout函数 while(1) { sleep(1); //每隔一秒发送一个SIGALRM kill(getpid(),SIGUSR1);//SIGUSR1是用户自定义信号。利用kill来发送信号
if(!statues){break;} }}void CTimer::start(){ pthread_t thread_timer;//创建一个线程去发送信号 pthread_create(&thread_timer, NULL, singlesa,static_cast(this));}//public methods//下面是main.cpp 测试一下
void UserCallback( void *obj, void *pa ){ printf(" UserCallback:: ( obj = 0x%x ) T_ID=%u\n", obj, pthread_self());}int main() //测试函数,定义三个定时器{CTimer ab;ab.addTimer(1,1,&UserCallback,( void *)0x11,0);ab.start();getchar();ab.stop();getchar(); exit(0);}
贴出运行结果:
版权声明:本文内容由网络用户投稿,版权归原作者所有,本站不拥有其著作权,亦不承担相应法律责任。如果您发现本站中有涉嫌抄袭或描述失实的内容,请联系我们jiasou666@gmail.com 处理,核实后本网站将在24小时内删除侵权内容。
暂时没有评论,来抢沙发吧~