#ifndef LST_TIMER
#define LST_TIMER


#include <time.h>


#define BUFFER_SIZE 64
class util_timer;
//用戶數(shù)據(jù)結(jié)構(gòu)：客戶端地址、客戶端的socket、socket文件描述符、讀緩存和定時(shí)器
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; //超時(shí)時(shí)間，使用絕對時(shí)間
? ?void (*cb_func)( client_data* );//任務(wù)回調(diào)
? ?client_data* user_data;//用戶數(shù)據(jù)
? ?util_timer* prev;//雙向鏈表，前一個(gè)定時(shí)器
? ?util_timer* next;//雙向鏈表，后一個(gè)定時(shí)器
};
//定時(shí)器鏈表，它是一個(gè)升序、雙向鏈表，且?guī)в蓄^結(jié)點(diǎn)和尾節(jié)點(diǎn)
class sort_timer_lst
{
public:
? ? sort_timer_lst() : head( NULL ), tail( NULL ) {}
? ? //釋放內(nèi)存 ??
? ?~sort_timer_lst()
? ? {
? ? ? ? util_timer* tmp = head;
? ? ? ? while( tmp )
? ? ? ? {
? ? ? ? ? ? head = tmp->next;
? ? ? ? ? ? delete tmp;
? ? ? ? ? ? tmp = head;
? ? ? ? }
? ? }
//添加定時(shí)器
? ? void add_timer( util_timer* timer )
? ? {
? ? ? ? if( !timer )
? ? ? ? {
? ? ? ? ? ? return;
? ? ? ? }
? ? ? ? if( !head )
? ? ? ? {
? ? ? ? ? ? head = tail = timer;
? ? ? ? ? ? return;?
? ? ? ? }
//如果添加的定時(shí)器的時(shí)間比頭結(jié)點(diǎn)的時(shí)間要短，直接將其作為頭結(jié)點(diǎn)
? ? ? ? if( timer->expire < head->expire )
? ? ? ? {
? ? ? ? ? ? timer->next = head;
? ? ? ? ? ? head->prev = timer;
? ? ? ? ? ? head = timer;
? ? ? ? ? ? return;
? ? ? ? }
? ? ? ? add_timer( timer, head );
? ? }
//當(dāng)某一個(gè)定時(shí)器發(fā)生變化時(shí)候，要調(diào)整對應(yīng)定時(shí)器在鏈表中的位置
? ? void adjust_timer( util_timer* timer )
? ? {
? ? ? ? if( !timer )
? ? ? ? {
? ? ? ? ? ? return;
? ? ? ? }
? ? ? ? util_timer* tmp = timer->next;
//如果被調(diào)整的節(jié)點(diǎn)處于鏈表的尾部，或者新的超時(shí)值仍然小于其下一個(gè)定時(shí)器的超
//時(shí)值，則不需要調(diào)整

? ? ? ? if( !tmp || ( timer->expire < tmp->expire ) )
? ? ? ? {
? ? ? ? ? ? return;
? ? ? ? }
//如果定時(shí)器是頭部，則對該定時(shí)器從鏈表中去除并重新插入
? ? ? ? if( timer == head )
? ? ? ? {
? ? ? ? ? ? head = head->next;
? ? ? ? ? ? head->prev = NULL;
? ? ? ? ? ? timer->next = NULL;
? ? ? ? ? ? add_timer( timer, head );
? ? ? ? }
? ? ? ? else
? ? ? ? {
//如果目標(biāo)定時(shí)器不是鏈表的頭結(jié)點(diǎn)，則將定時(shí)器從鏈表中去除，然后插入其原來的所在位置之后的部分鏈表
? ? ? ? ? ? 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信號每一次被觸發(fā)就在其信號處理函數(shù)（如果是使用統(tǒng)一定位源，則是主函數(shù)）中執(zhí)

//行一次tick函數(shù)以處理鏈表上到期的任務(wù)

//tick相當(dāng)于一個(gè)心搏函數(shù)，每隔一段時(shí)間執(zhí)行一次，以處理到期的任務(wù)

? ? void tick()
? ? {
? ? ? ? if( !head )
? ? ? ? {
? ? ? ? ? ? return;
? ? ? ? }
? ? ? ? printf( "timer tick\n" );
? ? ? ? time_t cur = time( NULL );//獲取系統(tǒng)當(dāng)前時(shí)間
? ? ? ? util_timer* tmp = head;
//從頭結(jié)點(diǎn)開始依次處理每一個(gè)定時(shí)器，直到遇到一個(gè)尚未到期的定時(shí)器，
//這就是定時(shí)器的核心邏輯
? ? ? ? while( tmp )
? ? ? ? {
//使用的是絕對時(shí)間，因此將超時(shí)值與當(dāng)前系統(tǒng)時(shí)間進(jìn)行比較
? ? ? ? ? ? if( cur < tmp->expire )
? ? ? ? ? ? {
? ? ? ? ? ? ? ? break;
? ? ? ? ? ? }
//調(diào)用定時(shí)器的回調(diào)函數(shù)
? ? ? ? ? ? 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 創(chuàng)作挑戰(zhàn)賽新人創(chuàng)作獎(jiǎng)勵(lì)來咯，堅(jiān)持創(chuàng)作打卡瓜分現(xiàn)金大獎(jiǎng)

總結(jié)

以上是生活随笔為你收集整理的基于升序链表的定时器的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。