2022-01-20 21:37:14 +01:00
|
|
|
#include <Logging/Logger.h>
|
|
|
|
#include <Service.h>
|
|
|
|
|
|
|
|
#include "TaskMgr.h"
|
|
|
|
#include "Task/Task.h"
|
|
|
|
|
|
|
|
using namespace Sapphire::World::Manager;
|
|
|
|
using namespace Sapphire::World;
|
|
|
|
|
|
|
|
void TaskMgr::update( uint64_t tickCount )
|
|
|
|
{
|
|
|
|
|
2022-01-20 22:45:48 +01:00
|
|
|
for( auto it = m_taskList.begin(); it != m_taskList.end(); )
|
2022-01-20 21:37:14 +01:00
|
|
|
{
|
|
|
|
auto pTask = *it;
|
|
|
|
// is the task ready for execution?
|
|
|
|
if( ( tickCount - pTask->getQueueTimeMs() ) >= pTask->getDelayTimeMs() )
|
|
|
|
{
|
2022-01-20 23:40:18 +01:00
|
|
|
Logger::info( "[TaskMgr] " + pTask->toString() );
|
2022-01-20 21:37:14 +01:00
|
|
|
pTask->execute();
|
|
|
|
it = m_taskList.erase( it );
|
|
|
|
}
|
|
|
|
else
|
|
|
|
++it;
|
|
|
|
}
|
|
|
|
|
|
|
|
m_lastTick = tickCount;
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
void TaskMgr::queueTask( const TaskPtr& pTask )
|
|
|
|
{
|
|
|
|
pTask->onQueue();
|
|
|
|
m_taskList.push_back( pTask );
|
|
|
|
}
|