GPT答: |
7i24.cn
|
//{
// RT_COMMON_ThreadSet(RunOnThread, this);
// RT_COMMON_Printf("线程启动中,请继续\n");
//}
//else //暂停
//{
// runningCore_.pause();
// RT_COMMON_Printf("线程暂停中,请继续\n");
// RT_COMMON_ThreadSet(RunOnThread, this);
//}
//runningCore_.resume();
}
if (Exit_e == runTask_item.task_type_)
{
exit(0);
}
runningCore_.coreTaskBegin(runTask_);
runningCore_.coreRunTaskBegin(runTask_item);
runningCore_.coreListenerBegin(runTask_listener);
MsgType type = runTask_item.task_type_;
switch (type)
{
case MsgType_e::Connect_e:
{
connect_(runTask_item, runTask_listener);
break;
}
case MsgType_e::Listen_e:
{
listen_(runTask_item);
break;
}
case MsgType_e::Send_e:
{
send_(runTask_item);
break;
}
case MsgType_e::Recv_e:
{
recv_(runTask_item, runTask_listener);
break;
}
case MsgType_e::Check_e:
{
check_(runTask_item);
break;
}
case MsgType_e::Close_e:
{
//FdCatch * fd_catch = dynamic_cast<FdCatch *>(runTask_.data_);
//if (fd_catch)
//{
// FdRemover fd_remover(fd_catch);
// fd_remover.exec();
//}
break;
}
case MsgType_e::UdpSend_e:
{
udpSend_(runTask_item);
break;
}
case MsgType_e::UdpRecv_e:
{
udpRecv_(runTask_item, runTask_listener);
break;
}
default:
break;
}
runningCore_.coreListenerFinished(runTask_listener);
run..
|