scheduler.cpp

天之炼狱1服务器端源文件游戏服务端不完整

///////////////////////////////////////////////////////////////////
// 胶纳临傅等 累诀阑 困茄 Scheduler 努贰胶 备泅
///////////////////////////////////////////////////////////////////

#include "Scheduler.h"
#include "Assert.h"

Scheduler::Scheduler()
	throw()
{
}
Scheduler::~Scheduler()
	throw()
{
	clear();
}

void Scheduler::clear()
	throw (Error)
{
	__BEGIN_TRY

	while ( !m_RecentSchedules.empty() )
	{
		Schedule* pSchedule = m_RecentSchedules.top();
		m_RecentSchedules.pop();

		SAFE_DELETE(pSchedule);
	}

	__END_CATCH
}

//--------------------------------------------------------------------------------
//
// addSchedule( Schedule* )
//
//--------------------------------------------------------------------------------
// Schedule篮 RecentSchedules客 Schedules俊 悼矫俊 殿废登绢 乐促.
//--------------------------------------------------------------------------------
void Scheduler::addSchedule( Schedule* pSchedule )  
	throw (Error)
{ 
	__BEGIN_TRY

	m_RecentSchedules.push( pSchedule ); 
	pSchedule->m_pScheduler = this;

	__END_CATCH
}

//--------------------------------------------------------------------------------
//
// popRecentWork( Schedule* pSchedule )
//
//--------------------------------------------------------------------------------
// m_RecentSchedules, m_Schedules俊辑 力芭
// pRecentSchedule狼 Work绰 return窍绊 pRecentSchedule篮 瘤款促
//--------------------------------------------------------------------------------
Work* Scheduler::popRecentWork()
	throw (Error)
{
	__BEGIN_TRY

	Schedule* pRecentSchedule = m_RecentSchedules.top();

	m_RecentSchedules.pop();

	Work* pWork = pRecentSchedule->popWork();
	SAFE_DELETE( pRecentSchedule );

	return pWork;

	__END_CATCH	
}

//--------------------------------------------------------------------------------
//
// Work* heartbeat()
//
//--------------------------------------------------------------------------------
// 啊厘 辟贰?俊 角青瞪 荐 乐绰 Schedule阑 眉农秦焊绊 角青灯促搁,
// Schedule狼 Work甫 return茄促. 捞 锭, Schedule篮 瘤款促.
//--------------------------------------------------------------------------------
Work* Scheduler::heartbeat()
	throw (Error)
{
	__BEGIN_TRY

	if( m_RecentSchedules.empty() ) return NULL;
	
	// priority queue 狼 top()篮 啊厘 累篮 (困狼 Former 俊 狼秦辑) 盔家甫 府畔茄促.
	// 救鸥滨霸档 瘤陛篮 啊厘 狐弗 霸 唱棵瘤 词篮霸 唱棵瘤 葛福摆促. -.-;;;
	// 2003. 1.23. by Sequoia
	// Former 努贰胶甫 Latter 努贰胶肺 官层辑 瘤陛篮 啊厘 狐弗 霸 唱柯促.
	Schedule* pRecentSchedule = m_RecentSchedules.top();

	if( pRecentSchedule->heartbeat() ) 
	{
		return popRecentWork();
	}

	return NULL;

	__END_CATCH
}