亚洲精品网址在线观看,亚洲日本在线观看,亚洲国产精品精华液2区45

自動(dòng)刪除的定時(shí)器隊(duì)列

自動(dòng)刪除的定時(shí)器隊(duì)列

（金慶的專欄）

網(wǎng)游服務(wù)器中使用定時(shí)器隊(duì)列代替角色遍歷可以提高性能，同時(shí)簡(jiǎn)代邏輯。
游戲主循環(huán)中不必遍歷角色，只需觸發(fā)定時(shí)器動(dòng)作。

主循環(huán)代碼如：

RootTimerQueue & rTimerQueue = Singleton<RootTimerQueue>();
do
{
   UpdateTimeNow(); // update m_rNow
   bool bTimerActed = rTimerQueue.TryToTickOne(m_rNow);
   size_t nCount = HandleMessages();

   if (0 == nCount)
   {
       if (m_bStopped) break;
       if (bTimerActed) continue;
       boost::this_thread::sleep(boost::posix_time::milliseconds(1));
   }
} while (true);

定時(shí)器運(yùn)行與主循環(huán)線程。
RootTimerQueue為根隊(duì)列，單件，各功能的定時(shí)器為RootTimerQueue的子隊(duì)列。

定時(shí)器隊(duì)列需要一個(gè)自動(dòng)刪除功能。
如角色相關(guān)的一大堆定時(shí)器動(dòng)作需要在角色退出時(shí)自動(dòng)刪除。
不然定時(shí)器動(dòng)作在角色不存在時(shí)或重新登錄后觸發(fā)，會(huì)造成錯(cuò)誤。
如果采用角色臨時(shí)ID（會(huì)話ID）, 每次登錄都不相同，
可以避免錯(cuò)誤，定時(shí)器動(dòng)作就成為一個(gè)空動(dòng)作。
但是該動(dòng)作一直存在于隊(duì)列中會(huì)占用內(nèi)存，無法清除。

解決方案是每個(gè)角色擁有一個(gè)自己的定時(shí)器隊(duì)列，該隊(duì)列為根隊(duì)列的子隊(duì)列。
角色退出時(shí)，子隊(duì)列的刪除會(huì)自動(dòng)刪除所有的定時(shí)器動(dòng)作。

class TimerQueue : boost::noncopyable
{
public:
   typedef boost::function<void ()> Action;
   typedef UInt64 TimerId;

public:
    TimerId Insert(time_t tStart, const Action & act, unsigned int nIntervalSec = 0);
   void Erase(TiemrId id);

public:
    void SetParent(TimerQueue * p);

public:
    bool TryToTickOne(time_t tNow);
};

時(shí)間精度為秒，因?yàn)楝F(xiàn)在的應(yīng)用只需秒即可，可以稍加改動(dòng)替換成高精度時(shí)間。

定時(shí)器動(dòng)作分為2類：
1. 只做一次，nIntervalSec為0表示只做一次。
2. 重復(fù)做，nIntervalSec非0.

添加定時(shí)器只有一個(gè)開始時(shí)間（有需要可以加個(gè)結(jié)束時(shí)間）。
開始時(shí)間可以是登錄前的一個(gè)時(shí)間點(diǎn)，這樣就可以計(jì)算離線期間所發(fā)生的改變。

通過SetParent()將自己設(shè)為某個(gè)隊(duì)列的子隊(duì)列。

實(shí)現(xiàn)部分如下：

class TimerQueue : boost::nonecopyable
{
private:
   void TickOne();
   void SetNextTime();
   void EraseParentTimer();

private:
   typedef UInt64 TimerSeq;

private:
   struct TimerItem
   {
       time_t t;
       TimerSeq seq;
       Action act;
       unsigned int nIntervalSec;
   };

private:
   void InsertItem(const TimerItem & itm);
   TimerItem Pop();

private:
    struct TimerOrder {};

   typedef boost::multi_index::multi_index_container
   <
       TimerItem,

       boost::multi_index::indexed_by
       <
           boost::multi_index::ordered_unique<
               boost::multi_index::tag<TimerOrder>,
               boost::multi_index::composite_key<
                   TimerItem,
                   boost::multi_index::member<TimerItem, time_t, &TimerItem::t>,
                   boost::multi_index::member<IimerItem, TimerSeq, &TimerItem::seq>
               > // composite_key
           >, // ordered_unique
           boost::multi_index::hashed_unique<
               boost::multi_index::tag<TimerId>,
               boost::multi_index::member<TimerItem, TimerSeq, &TimerItem::seq>
           > // hashed_unique
       > // indexed_by
   > TimerItemSet;

   typedef TimerItemSet::index<TimerOrder>::type QueueByTime;
   typedef TimerItemSet::index<TimerId>::type QueueById;

private:
    TimerItemSet m_set;

private:
    TimerSeq m_seq;
   time_t m_tNext;

   TimerQueue * m_pParent;
   TimerId m_idParentTimer; // Used to erase timer from parent
};

TimerItemSet以時(shí)間和序號(hào)排序，允許時(shí)間相同，但序號(hào)是唯一的。
并且也能用ID號(hào)索引，用于刪除定時(shí)器。

TimerQueue.cpp

TimerQueue::TimerQueue()
   : m_seq(0) // 0 is illegal
   , m_pParent(NULL)
   , m_idParentTimer(0)
{
   SetNextTime();
}

TimerQueue::~TimerQueue()
{
   EraseParentTimer();
}

TimerQueue::TimerId TimerQueue::Insert(
   time_t tStart, const Action & act, unsigned int nIntervalSec)
{
   TimerItem itm = {tStart, ++m_seq, act, nIntervalSec};
   InsertItem(itm);
   return itm.seq;
}

TimerQueue::Erase(TimerId id)
{
   SetById & rSet = mset.get<TimerId>();
   SetById::iterator itr = rSet.find(id);
   if (itr == rSet.end())
       return;

   time_t t = (*itr).t;
   TimerSeq seqErase = (*itr).seq; // Used to set next time.
   TimerSeq seqFront = m_set.get<TimerOrder>().begin()->seq;
   rSet.erase(itr);
   if (seqErase == seqFront)
       SetNextTime();
}

void TimerQueue::SetParent(TimerQueue * p)
{
   EraseParentTimer()
   m_pParent = p
   SetNextTime();
}

bool TimerQueue::TryToTickOne(time_t tNow)
{
   if (tNow < m_tNext)
       return false;
   if (m_set.empty())
       return false;

   TickOne();
   return true;
}

void TimerQueue::TickOne()
{
   BOOST_ASSERT(!m_set.empty());
   TimerItem itm = Pop();
   itm.act();

   if (0 == itm.nIntervalSec)
       return;
   itm.t += itm.nIntervalSec;
   InsertItem(itm);
}

TimerQueue::TimerItem TimerQueue::Pop()
{
   BOOST_ASSERT(!m_set.empty());
   QueueByTime & rQ = m_set.get<TimerOrder>();
   QueueByTime::iterator itr = rQ.begin();
   TimerItem itm = *itr;
   rQ.erase(itr);
   BOOST_ASSERT(itm.t == m_tNext);
   SetNextTime();
   return itm;
}

void TimerQueue::SetNextTime()
{
   EraseParentTimer();

   if (m_set.empty())
   {
       m_tNext = std::numeric_limits<time_t>::max();
       return;
   }
   time_t tNew = (*m_set.get<TimeOrder>().begin()).t;
   m_tNext = tNew;
   if (NULL == m_pParent)
        return;
   m_idParentTimer = m_pParent->Insert(m_tNext,
       boost::bind(&TimerQueue::TickOne, this));
   BOOST_ASSERT(m_idParentTimer); // 0 is illegal ID.
}

void TimerQueue::EraseParentTimer()
{
   if (m_pParent && m_idParentTimer)
       m_pParent->Erase(m_idParentTimer);
   m_idParentTimer = 0;
}

void TimerQueue::InsertItem(const TimerIten & itm)
{
   m_set.insert(itm);
   if (itm.t < m_tNext)
       SetNextTiem();
}

RootTimerQueue是TimerQueue的子類。
另外再派生子類
class LogicTimerQueue : public TimerQueue
{
public:
   LogicTimerQueue();
};

LogicTimerQueue::LogicTimerQueue()
{
   SetParent(&Singleton<RootTimerQueue>());
}

這樣就讓每個(gè)LogicTimerQueue成為根隊(duì)列的子隊(duì)列。

玩家類中就可以添加LogicTimerQueue成員，來執(zhí)行定時(shí)動(dòng)作。

class Player
{
public:
   Player()
   {
       ...
        // Check mail every hour.
       m_timer->Insert(time(NULL),
           boost::bind(&Player::CheckMail, this),
           3600);
       ...
   }

...

private:
   LogicTimerQueue m_timer;
   ...
};

posted on 2012-06-20 13:28 金慶閱讀(1146) 評(píng)論(2) 編輯收藏引用所屬分類: 1. C/C++ 、2. 網(wǎng)游開發(fā)

評(píng)論

# re: 自動(dòng)刪除的定時(shí)器隊(duì)列 2012-11-14 09:08 zozoiiiiii

class Player
{
Player(){注冊(cè)定時(shí)器}
~Player(){注銷定時(shí)器}
}

利用構(gòu)造函數(shù)和析構(gòu)函數(shù)來保證角色退出時(shí)定時(shí)器的注冊(cè)和注銷，不很簡(jiǎn)單么，干嘛要那么復(fù)雜回復(fù) 更多評(píng)論

# re: 自動(dòng)刪除的定時(shí)器隊(duì)列 2012-11-14 19:23 金慶

@zozoiiiiii
沒錯(cuò)，是在~Player()中注銷的。上面的代碼是如何注銷。假設(shè)某個(gè)Player注冊(cè)了上千個(gè)定時(shí)器，需要在~Player()中調(diào)用上千次注銷方法嗎？回復(fù) 更多評(píng)論

刷新評(píng)論列表

只有注冊(cè)用戶登錄后才能發(fā)表評(píng)論。
【推薦】100%開源！大型工業(yè)跨平臺(tái)軟件C++源碼提供，建模，組態(tài)！

相關(guān)文章: How are dtLinks created in NavMesh C++ parameter passing rules Naming Conventions for Accessors Visual Studio 2019 Compiler Hangs Fbx File Format Identifier 查找內(nèi)存錯(cuò)誤 std::thread 中的異常會(huì)丟失調(diào)用棧用賦值代替 protobuf CopyFrom() vs2017 linux 編譯輸出改成 vs 格式為 LiteIDE 添加選中標(biāo)記

網(wǎng)站導(dǎo)航: 博客園 IT新聞 BlogJava 博問 Chat2DB 管理

金慶的專欄

公告

留言簿(12)

隨筆分類(502)

隨筆檔案(423)

相冊(cè)

搜索

積分與排名

最新評(píng)論

閱讀排行榜

評(píng)論排行榜

評(píng)論