求索阁

最近在linux下写一个库，是给别人用的，要用到定时器这个功能，而且是多定时器任务的，在windows下实现是很方便的，但是在linux下就遇到了问题，linux下一个进程只能有一个定时器，如果我用了定时器去实现我的任务，那肯定是没问题的，如果用我库的人自己也创建了一个定时器，那么问题就出现了，我的定时器就被覆盖了。

我的功能肯定也受到了影响，所以linux下的定时器是需要解决的。

没办法，我就自己写了一个定时器类似功能的代码：

#ifndef CTIMER_H
#define CTIMER_H
#include<pthread.h>
#include <unistd.h>
#include <signal.h>
#include<pthread.h>
#include <time.h>
#include <sys/time.h>
#include <iostream>
#include <stdio.h>
#include <stdlib.h>
#include <list>
#include <mutex>
using namespace std;
#define N 100 //设置最大的定时器个数
 
typedef void (* Callback )( void *n_obj, void *user_data );//callback
struct 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<unistd.h>
#include<stdio.h>
#include<stdlib.h>
#include <sys/types.h>
#include <sys/time.h>
#include <iostream>
std::list<void*>m_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<void*>::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<CTimer*>(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<void*>(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);
}