#ifndef LST_TIMER
#define LST_TIMER
#include <time.h>
#define BUFFER_SIZE 64
class util_timer;
//用戶數據結構:客戶端地址、客戶端的socket、socket文件描述符、讀緩存和定時器
struct client_data
{
? ? sockaddr_in address;
? ? int sockfd;
? ? char buf[ BUFFER_SIZE ];
? ? util_timer* timer;
};
class util_timer
{
public:
? ? util_timer() : prev( NULL ), next( NULL ){}
public:
? ?time_t expire; //超時時間,使用絕對時間
? ?void (*cb_func)( client_data* );//任務回調
? ?client_data* user_data;//用戶數據
? ?util_timer* prev;//雙向鏈表,前一個定時器
? ?util_timer* next;//雙向鏈表,后一個定時器
};
//定時器鏈表,它是一個升序、雙向鏈表,且帶有頭結點和尾節點
class sort_timer_lst
{
public:
? ? sort_timer_lst() : head( NULL ), tail( NULL ) {}
? ? //釋放內存 ??
? ?~sort_timer_lst()
? ? {
? ? ? ? util_timer* tmp = head;
? ? ? ? while( tmp )
? ? ? ? {
? ? ? ? ? ? head = tmp->next;
? ? ? ? ? ? delete tmp;
? ? ? ? ? ? tmp = head;
? ? ? ? }
? ? }
//添加定時器
? ? void add_timer( util_timer* timer )
? ? {
? ? ? ? if( !timer )
? ? ? ? {
? ? ? ? ? ? return;
? ? ? ? }
? ? ? ? if( !head )
? ? ? ? {
? ? ? ? ? ? head = tail = timer;
? ? ? ? ? ? return;?
? ? ? ? }
//如果添加的定時器的時間比頭結點的時間要短,直接將其作為頭結點
? ? ? ? if( timer->expire < head->expire )
? ? ? ? {
? ? ? ? ? ? timer->next = head;
? ? ? ? ? ? head->prev = timer;
? ? ? ? ? ? head = timer;
? ? ? ? ? ? return;
? ? ? ? }
? ? ? ? add_timer( timer, head );
? ? }
//當某一個定時器發生變化時候,要調整對應定時器在鏈表中的位置
? ? void adjust_timer( util_timer* timer )
? ? {
? ? ? ? if( !timer )
? ? ? ? {
? ? ? ? ? ? return;
? ? ? ? }
? ? ? ? util_timer* tmp = timer->next;
//如果被調整的節點處于鏈表的尾部,或者新的超時值仍然小于其下一個定時器的超
//時值,則不需要調整
? ? ? ? if( !tmp || ( timer->expire < tmp->expire ) )
? ? ? ? {
? ? ? ? ? ? return;
? ? ? ? }
//如果定時器是頭部,則對該定時器從鏈表中去除并重新插入
? ? ? ? if( timer == head )
? ? ? ? {
? ? ? ? ? ? head = head->next;
? ? ? ? ? ? head->prev = NULL;
? ? ? ? ? ? timer->next = NULL;
? ? ? ? ? ? add_timer( timer, head );
? ? ? ? }
? ? ? ? else
? ? ? ? {
//如果目標定時器不是鏈表的頭結點,則將定時器從鏈表中去除,然后插入其原來的所在位置之后的部分鏈表
? ? ? ? ? ? timer->prev->next = timer->next;
? ? ? ? ? ? timer->next->prev = timer->prev;
? ? ? ? ? ? add_timer( timer, timer->next );
? ? ? ? }
? ? }
? ? void del_timer( util_timer* timer )
? ? {
? ? ? ? if( !timer )
? ? ? ? {
? ? ? ? ? ? return;
? ? ? ? }
? ? ? ? if( ( timer == head ) && ( timer == tail ) )
? ? ? ? {
? ? ? ? ? ? delete timer;
? ? ? ? ? ? head = NULL;
? ? ? ? ? ? tail = NULL;
? ? ? ? ? ? return;
? ? ? ? }
? ? ? ? if( timer == head )
? ? ? ? {
? ? ? ? ? ? head = head->next;
? ? ? ? ? ? head->prev = NULL;
? ? ? ? ? ? delete timer;
? ? ? ? ? ? return;
? ? ? ? }
? ? ? ? if( timer == tail )
? ? ? ? {
? ? ? ? ? ? tail = tail->prev;
? ? ? ? ? ? tail->next = NULL;
? ? ? ? ? ? delete timer;
? ? ? ? ? ? return;
? ? ? ? }
? ? ? ? timer->prev->next = timer->next;
? ? ? ? timer->next->prev = timer->prev;
? ? ? ? delete timer;
? ? }
//SIGARLM信號每一次被觸發就在其信號處理函數(如果是使用統一定位源,則是主函數)中執
? ? {
? ? ? ? if( !head )
? ? ? ? {
? ? ? ? ? ? return;
? ? ? ? }
? ? ? ? printf( "timer tick\n" );
? ? ? ? time_t cur = time( NULL );//獲取系統當前時間
? ? ? ? util_timer* tmp = head;
//從頭結點開始依次處理每一個定時器,直到遇到一個尚未到期的定時器,
//這就是定時器的核心邏輯
? ? ? ? while( tmp )
? ? ? ? {
//使用的是絕對時間,因此將超時值與當前系統時間進行比較
? ? ? ? ? ? if( cur < tmp->expire )
? ? ? ? ? ? {
? ? ? ? ? ? ? ? break;
? ? ? ? ? ? }
//調用定時器的回調函數
? ? ? ? ? ? tmp->cb_func( tmp->user_data );
//事件處理完畢之后就將其刪除
? ? ? ? ? ? head = tmp->next;
? ? ? ? ? ? if( head )
? ? ? ? ? ? {
? ? ? ? ? ? ? ? head->prev = NULL;
? ? ? ? ? ? }
? ? ? ? ? ? delete tmp;
? ? ? ? ? ? tmp = head;
? ? ? ? }
? ? }
private:
? ? void add_timer( util_timer* timer, util_timer* lst_head )
? ? {
? ? ? ? util_timer* prev = lst_head;
? ? ? ? util_timer* tmp = prev->next;
? ? ? ? while( tmp )
? ? ? ? {
? ? ? ? ? ? if( timer->expire < tmp->expire )
? ? ? ? ? ? {
? ? ? ? ? ? ? ? prev->next = timer;
? ? ? ? ? ? ? ? timer->next = tmp;
? ? ? ? ? ? ? ? tmp->prev = timer;
? ? ? ? ? ? ? ? timer->prev = prev;
? ? ? ? ? ? ? ? break;
? ? ? ? ? ? }
? ? ? ? ? ? prev = tmp;
? ? ? ? ? ? tmp = tmp->next;
? ? ? ? }
? ? ? ? if( !tmp )
? ? ? ? {
? ? ? ? ? ? prev->next = timer;
? ? ? ? ? ? timer->prev = prev;
? ? ? ? ? ? timer->next = NULL;
? ? ? ? ? ? tail = timer;
? ? ? ? }
? ? ? ??
? ? }
private:
? ? util_timer* head;
? ? util_timer* tail;
};
#endif
#define LST_TIMER
#include <time.h>
#define BUFFER_SIZE 64
class util_timer;
//用戶數據結構:客戶端地址、客戶端的socket、socket文件描述符、讀緩存和定時器
struct client_data
{
? ? sockaddr_in address;
? ? int sockfd;
? ? char buf[ BUFFER_SIZE ];
? ? util_timer* timer;
};
class util_timer
{
public:
? ? util_timer() : prev( NULL ), next( NULL ){}
public:
? ?time_t expire; //超時時間,使用絕對時間
? ?void (*cb_func)( client_data* );//任務回調
? ?client_data* user_data;//用戶數據
? ?util_timer* prev;//雙向鏈表,前一個定時器
? ?util_timer* next;//雙向鏈表,后一個定時器
};
//定時器鏈表,它是一個升序、雙向鏈表,且帶有頭結點和尾節點
class sort_timer_lst
{
public:
? ? sort_timer_lst() : head( NULL ), tail( NULL ) {}
? ? //釋放內存 ??
? ?~sort_timer_lst()
? ? {
? ? ? ? util_timer* tmp = head;
? ? ? ? while( tmp )
? ? ? ? {
? ? ? ? ? ? head = tmp->next;
? ? ? ? ? ? delete tmp;
? ? ? ? ? ? tmp = head;
? ? ? ? }
? ? }
//添加定時器
? ? void add_timer( util_timer* timer )
? ? {
? ? ? ? if( !timer )
? ? ? ? {
? ? ? ? ? ? return;
? ? ? ? }
? ? ? ? if( !head )
? ? ? ? {
? ? ? ? ? ? head = tail = timer;
? ? ? ? ? ? return;?
? ? ? ? }
//如果添加的定時器的時間比頭結點的時間要短,直接將其作為頭結點
? ? ? ? if( timer->expire < head->expire )
? ? ? ? {
? ? ? ? ? ? timer->next = head;
? ? ? ? ? ? head->prev = timer;
? ? ? ? ? ? head = timer;
? ? ? ? ? ? return;
? ? ? ? }
? ? ? ? add_timer( timer, head );
? ? }
//當某一個定時器發生變化時候,要調整對應定時器在鏈表中的位置
? ? void adjust_timer( util_timer* timer )
? ? {
? ? ? ? if( !timer )
? ? ? ? {
? ? ? ? ? ? return;
? ? ? ? }
? ? ? ? util_timer* tmp = timer->next;
//如果被調整的節點處于鏈表的尾部,或者新的超時值仍然小于其下一個定時器的超
//時值,則不需要調整
? ? ? ? if( !tmp || ( timer->expire < tmp->expire ) )
? ? ? ? {
? ? ? ? ? ? return;
? ? ? ? }
//如果定時器是頭部,則對該定時器從鏈表中去除并重新插入
? ? ? ? if( timer == head )
? ? ? ? {
? ? ? ? ? ? head = head->next;
? ? ? ? ? ? head->prev = NULL;
? ? ? ? ? ? timer->next = NULL;
? ? ? ? ? ? add_timer( timer, head );
? ? ? ? }
? ? ? ? else
? ? ? ? {
//如果目標定時器不是鏈表的頭結點,則將定時器從鏈表中去除,然后插入其原來的所在位置之后的部分鏈表
? ? ? ? ? ? timer->prev->next = timer->next;
? ? ? ? ? ? timer->next->prev = timer->prev;
? ? ? ? ? ? add_timer( timer, timer->next );
? ? ? ? }
? ? }
? ? void del_timer( util_timer* timer )
? ? {
? ? ? ? if( !timer )
? ? ? ? {
? ? ? ? ? ? return;
? ? ? ? }
? ? ? ? if( ( timer == head ) && ( timer == tail ) )
? ? ? ? {
? ? ? ? ? ? delete timer;
? ? ? ? ? ? head = NULL;
? ? ? ? ? ? tail = NULL;
? ? ? ? ? ? return;
? ? ? ? }
? ? ? ? if( timer == head )
? ? ? ? {
? ? ? ? ? ? head = head->next;
? ? ? ? ? ? head->prev = NULL;
? ? ? ? ? ? delete timer;
? ? ? ? ? ? return;
? ? ? ? }
? ? ? ? if( timer == tail )
? ? ? ? {
? ? ? ? ? ? tail = tail->prev;
? ? ? ? ? ? tail->next = NULL;
? ? ? ? ? ? delete timer;
? ? ? ? ? ? return;
? ? ? ? }
? ? ? ? timer->prev->next = timer->next;
? ? ? ? timer->next->prev = timer->prev;
? ? ? ? delete timer;
? ? }
//SIGARLM信號每一次被觸發就在其信號處理函數(如果是使用統一定位源,則是主函數)中執
//行一次tick函數以處理鏈表上到期的任務
//tick相當于一個心搏函數,每隔一段時間執行一次,以處理到期的任務
? ? void tick()? ? {
? ? ? ? if( !head )
? ? ? ? {
? ? ? ? ? ? return;
? ? ? ? }
? ? ? ? printf( "timer tick\n" );
? ? ? ? time_t cur = time( NULL );//獲取系統當前時間
? ? ? ? util_timer* tmp = head;
//從頭結點開始依次處理每一個定時器,直到遇到一個尚未到期的定時器,
//這就是定時器的核心邏輯
? ? ? ? while( tmp )
? ? ? ? {
//使用的是絕對時間,因此將超時值與當前系統時間進行比較
? ? ? ? ? ? if( cur < tmp->expire )
? ? ? ? ? ? {
? ? ? ? ? ? ? ? break;
? ? ? ? ? ? }
//調用定時器的回調函數
? ? ? ? ? ? tmp->cb_func( tmp->user_data );
//事件處理完畢之后就將其刪除
? ? ? ? ? ? head = tmp->next;
? ? ? ? ? ? if( head )
? ? ? ? ? ? {
? ? ? ? ? ? ? ? head->prev = NULL;
? ? ? ? ? ? }
? ? ? ? ? ? delete tmp;
? ? ? ? ? ? tmp = head;
? ? ? ? }
? ? }
private:
? ? void add_timer( util_timer* timer, util_timer* lst_head )
? ? {
? ? ? ? util_timer* prev = lst_head;
? ? ? ? util_timer* tmp = prev->next;
? ? ? ? while( tmp )
? ? ? ? {
? ? ? ? ? ? if( timer->expire < tmp->expire )
? ? ? ? ? ? {
? ? ? ? ? ? ? ? prev->next = timer;
? ? ? ? ? ? ? ? timer->next = tmp;
? ? ? ? ? ? ? ? tmp->prev = timer;
? ? ? ? ? ? ? ? timer->prev = prev;
? ? ? ? ? ? ? ? break;
? ? ? ? ? ? }
? ? ? ? ? ? prev = tmp;
? ? ? ? ? ? tmp = tmp->next;
? ? ? ? }
? ? ? ? if( !tmp )
? ? ? ? {
? ? ? ? ? ? prev->next = timer;
? ? ? ? ? ? timer->prev = prev;
? ? ? ? ? ? timer->next = NULL;
? ? ? ? ? ? tail = timer;
? ? ? ? }
? ? ? ??
? ? }
private:
? ? util_timer* head;
? ? util_timer* tail;
};
#endif