void CAIApp::Process()
{psarmor l_pa(*this);Scheduler::Init();while(!GetExitTaskFlag() && l_pa(psobj::realtime)){//如果到game的连接断开，执行错误处理并尝试重连while(!m_flag2Game){//连接断了，要清除所有已经绑定的Ai对象//g_AiObjMap为空的话不可能有任务在运行if(!g_AiObjMap.empty()){    //连接已经断开，停掉所有运行的AI
                {std::map<uLong,rptr<AiAvatar> >::iterator it =  g_AiObjMap.begin();std::map<uLong,rptr<AiAvatar> >::iterator end =  g_AiObjMap.end();for( ; it != end; ++it)it->second->StopAi();}//清理active列表
                Scheduler::ClearActiveList();//清理timeout列表
                Scheduler::ClearTimeOut();{std::cout << "到gameserver的连接断开,清除所有绑定对象" << std::endl;std::map<uLong,rptr<AiAvatar> >::iterator it =  g_AiObjMap.begin();std::map<uLong,rptr<AiAvatar> >::iterator end =  g_AiObjMap.end();for( ; it != end; ++it)it->second = 0;g_AiObjMap.clear();}//清理aigroup
                {std::map<long,rptr<AiGroup> >::iterator it =  g_GroupMap.begin();std::map<long,rptr<AiGroup> >::iterator end =  g_GroupMap.end();for( ; it != end; ++it)it->second = 0;g_GroupMap.clear();}}m_pToGame = 0;while(m_pToGame._nil()){rptr<DataSocket> l_sock    =g_aiapp->Connect(g_aiapp->m_config.m_gameip,g_aiapp->m_config.m_gameport);if(l_sock._nil()){std::cout << "连接game失败!5秒后重试..." << std::endl;}else{printf("连接game成功...");WPacket    l_wpk    =g_aiapp->GetWPacket();l_wpk.WriteCmd(CMD_AM_AILOGIN);l_wpk.WriteShort(g_aiapp->m_config.m_mapcount);for( int i = 0;i < g_aiapp->m_config.m_mapcount; ++i){l_wpk.WriteString(g_aiapp->m_config.m_names[i].c_str());}l_sock->SendData(l_wpk);m_pToGame = l_sock;m_flag2Game = true;break;}Sleep(5000);}}Scheduler::Schedule();PeekPacket(50);}Scheduler::Destroy();
}

void Scheduler::Schedule()
{//将所有等待添加到m_activeList中的纤程都添加进去
    {for(unsigned int i = 0; i < pending_index; ++i){uthread *ut = m_uthreads[m_pendingAdd[i]];ut->SetNext(0);if(m_active_tail){m_active_tail->SetNext(ut);m_active_tail = ut;}else{m_active_head = m_active_tail = ut;}}pending_index = 0;}uthread *cur = m_active_head;uthread *pre = NULL;while(cur){g_aiapp->PeekPacket(0);m_curuid = cur->GetUid();SwitchToFiber(cur->GetUContext());m_curuid = -1;unsigned char status = cur->GetStatus();//当纤程处于以下状态时需要从可运行队列中移除if(status == DEAD || status == SLEEP || status == WAIT4EVENT || status == UNACTIVED || status == YIELD){//删除首元素if(cur == m_active_head){//同时也是尾元素if(cur == m_active_tail)m_active_head = m_active_tail = NULL;elsem_active_head = cur->Next();}else if(cur == m_active_tail){pre->SetNext(NULL);m_active_tail = pre;}elsepre->SetNext(cur->Next());uthread *tmp = cur;cur = cur->Next();tmp->SetNext(0);//如果仅仅是让出处理器，需要重新投入到可运行队列中if(status == YIELD)Add2Active(tmp);}else{pre = cur;cur = cur->Next();}}//看看有没有timeout的纤程
    {uLong now = dbc::GetTickCount();while(m_timeoutlist.Min() !=0 && m_timeoutlist.Min() <= now){st_timeout *timeout = m_timeoutlist.PopMin();if(timeout->ut->GetStatus() == WAIT4EVENT || timeout->ut->GetStatus() == SLEEP){timeout->ut->wakeuptick = timeout->_timeout;Add2Active(timeout->ut);}}}
}

int AiAvatar::Move(Point3D &pt,short cntx,uLong ms)
{class PosBlock : public BlockStruct{    public:PosBlock(Point3D &pos,AiAvatar *ava):m_ava(ava),m_targetpos(pos){}//返回true则纤程从阻塞中恢复bool WakeUp(){//到达了请求点，恢复if(m_targetpos.x == m_ava->GetPos().x &&m_targetpos.y == m_ava->GetPos().y ){return true;}return false;}private:Point3D m_targetpos;AiAvatar *m_ava;};//printf("开始移动/n");//向GameServer发送移动请求WPacket    l_wpk = g_aiapp->GetWPacket();l_wpk.WriteCmd(CMD_AM_BEGMOV);l_wpk.WriteLong(pt.x);l_wpk.WriteLong(pt.y);l_wpk.WriteLong(pt.z);l_wpk.WriteShort(cntx);Send2Game(this,l_wpk);//阻塞所在fiber直到pos到达要求的值/或者收到移动失败消息/或则AI被请求停止PosBlock pb(pt,this);Scheduler::Block(&pb,ms);//接到了停止AI的命令if(!isAiRunning())return -1;bool ret = (pt.x == m_pos.x && pt.y == m_pos.y);return ret ? 1:0;
}

function monster_routine(this)        --出生点local start_pos = {}start_pos.x,start_pos.y,start_pos.z = getbegpos(this)local c = 1--巡逻点local points = {{x=start_pos.x+300,y=start_pos.y,z=start_pos.z},{x=start_pos.x,y=start_pos.y,z=start_pos.z}}--生成状态机stateMachine = AiStateMachine:new()stateMachine.owner = this--初始化tracestateMachine.state_trace = trace:new():init(this,stateMachine,start_pos)--stateMachine.state_trace:init(this,stateMachine,start_pos)--初始化partolstateMachine.state_partol = partol:new():init(this,stateMachine,start_pos,points)--stateMachine.state_partol:init(this,stateMachine,start_pos,points)--初始化attackstateMachine.state_attack = attack:new():init(this,stateMachine)--stateMachine.state_attack:init(this,stateMachine)--初始化gobackstateMachine.state_goback = goback:new():init(this,stateMachine,start_pos)--stateMachine.state_goback:init(this,stateMachine,start_pos)--初始化helpstateMachine.state_help = help:new():init(this,stateMachine)--stateMachine.state_help:init(this,stateMachine)stateMachine.cur_state = stateMachine.state_partolwhile isAiRunning(this) == true doif isdead(this) == true thensc_yield()else    stateMachine.cur_pos.x,stateMachine.cur_pos.y,stateMachine.cur_pos.z = getpos(this)stateMachine.target = get_target(this)if stateMachine.target == nil thenstateMachine.target = select_target(this)end--查看是否有消息要处理local senderlocal recverlocal msglocal sendticksender,recver,msg,sendtick = PopMsg(this)if sender ~= nil thenprint("消息队列非空")if msg == "help" then--如果自己没有目标才处理帮助请求if stateMachine.target == nil thenstateMachine.target = senderstateMachine.cur_state = stateMachine.state_helpendendendlocal ret = 0ret,stateMachine.cur_state = stateMachine.cur_state:execute()    if ret == -1 thenreturnendsc_yield()endend
end

trace = {
owner = 0,
StateMachine = 0,
start_pos = 0
}function trace:init(owner,statemachine,start_pos)self.owner = ownerself.StateMachine = statemachineself.start_pos = start_posreturn self
end --追击
function trace:execute()if self.StateMachine.target == nil then--判断离出生点的距离，太远了就回出生点local dis2begpos = calDistance(self.start_pos.x,self.start_pos.y,self.StateMachine.cur_pos.x,self.StateMachine.cur_pos.y)if dis2begpos >= 500 thenreturn 0,self.StateMachine.state_gobackelse--没有目标，巡逻return 0,self.StateMachine.state_partolendelselocal dis2begpos = calDistance(self.start_pos.x,self.start_pos.y,self.StateMachine.cur_pos.x,self.StateMachine.cur_pos.y)if dis2begpos >= 4000 thenreturn 0,self.StateMachine.state_gobackelse--取得目标当前点            local target_pos ={}target_pos.x,target_pos.y,target_pos.z = getpos(self.StateMachine.target)local dis = calDistance(self.StateMachine.cur_pos.x,self.StateMachine.cur_pos.y,target_pos.x,target_pos.y)    if dis <= 200 then--print("选择攻击点")--选择攻击点--if cur_pos.x ~= self.cur_pos and cur_pos.y ~= self.cur_pos.y thenlocal d_x,d_y = gen_pos_circle(target_pos.x,target_pos.y,200)if -1 == mov(self.owner,d_x,d_y,target_pos.z,804,1000) thenreturn -1,nilend--面向目标turnface(self.owner,self.StateMachine.target)--切换到攻击态--endreturn 0,self.StateMachine.state_attackelse--在目标半径2米内随机选择一个点,作为目标点local d_x,d_y = gen_pos_line(self.StateMachine.cur_pos.x,self.StateMachine.cur_pos.y,target_pos.x,target_pos.y,200,100)if dis <= 300 then--离目标点小于3米直接过去if -1 == mov(self.owner,d_x,d_y,target_pos.z,804,1000) thenreturn -1,nilendelse                            local ttx,tty = forword(self.owner,d_x,d_y,300)if -1 == mov(self.owner,ttx,tty,target_pos.z,804,1000) thenreturn -1,nilendendendendendreturn 0,self.StateMachine.state_trace
endfunction trace:new(o)o = o or {}   setmetatable(o, self)self.__index = selfreturn o
end