libco
libco copied to clipboard
Tencent
epoll_wait 返回的时间不是固定1ms,有几率出现1-4秒的情况？
在某个携程里用了poll(NULL, 0, msleep);来做定时，结果发现定时不准。msleep=10000的情况下有时候会出现12秒的延迟执行。最后定位到co_epoll_wait，好像不是固定阻塞1毫秒，有时候会阻塞1-4秒。整个测试代码就一个协程，内容仅仅是打印时间在屏幕，不会出现执行忙的情况。
基本没什么功能了，就留了最简单的测试代码。 void DataCore::runServer() { stCoRoutine_t *db_co = nullptr; co_create(&db_co, nullptr, dealDBServer, 0); co_resume(db_co); co_eventloop(co_get_epoll_ct(), 0, 0);
} //定时调用的函数最后是在这里 void DataCore::onDealDBServer(void *arg) { co_enable_hook_sys(); //this->initDB();
while (true)
{
fflush(stdout);
fflush(stderr);
int msleep = 10000;
int tick = ServerDelegate::getInstance()->getServerTick();
//int ret = getDB("server")->sql_fetch_cell_int("select UNIX_TIMESTAMP()");
int ret = 9;
fprintf(stderr, "get db query:%d,%d,%d,%d,%d\n", ret, ServerDelegate::getInstance()->getServerTime(), ServerDelegate::getInstance()->getServerTick() - tick, ServerDelegate::getInstance()->getLocalServerTime(),(int)time(nullptr));
msleep -= ServerDelegate::getInstance()->getServerTick() - tick;
fprintf(stderr, "%d\n", msleep);
poll(NULL, 0, msleep);
}
return;
}
//改了co_eventloop配合打印日志。没修改其他任何代码。 void co_eventloop( stCoEpoll_t *ctx,pfn_co_eventloop_t pfn,void *arg ) { if( !ctx->result ) { ctx->result = co_epoll_res_alloc( stCoEpoll_t::_EPOLL_SIZE ); } co_epoll_res *result = ctx->result;
unsigned long long lastupdate = GetTickMS();
for (;;)
{
unsigned long long lastupdate2 = GetTickMS();
if (lastupdate2 - lastupdate >= 200)
fprintf(stderr, "slow...........: %d\n", int(lastupdate2 - lastupdate));
lastupdate = lastupdate2;
int ret = co_epoll_wait(ctx->iEpollFd, result, stCoEpoll_t::_EPOLL_SIZE, 1);
//usleep(1000);
int debug = int(GetTickMS() - lastupdate2);
if (debug >= 200)
{
fprintf(stderr, "slow0...........: %d\n", debug);
}
"slow0...........: 开始正常，大概跑个1分钟就开始有200多毫秒的结果出来了，然后偶尔会有秒级别的出现。
void DataCore::runServer() { //stCoRoutine_t *db_co = nullptr; //co_create(&db_co, nullptr, dealDBServer, 0); //co_resume(db_co); co_eventloop(co_get_epoll_ct(), 0, 0);
} 这样？什么都不做，然后就等，，，，简单了吧？
不是，我意思是你写一个小程序，不用链接libco，直接调用系统函数 epoll_wait fd = epoll_create(..);
for(;;) { struct epoll_event result;.. start = tick(); epoll_wait( .. 1 ); if( tick() - start > xx ) print ... }
