- 论坛徽章:
- 11
|
有个需求又要连服务器开连接, 然后读啊写啊的, 但实在不想开 thread 了, 想了半天, 觉得异步io可能会帮助
但信号肯定不行, 万恶的 protobuf 在它的代码里到处是不可重入的 new 之类的东西;
然后注意到 aio 系列, 居然有一个回调函数触发通知的机制; 搜了一段代码来问问:
void setup_io(..)
{
...//同上
//连接AIO请求和线程回调函数
my_aiocb.aio_sigevent.sigev_notify = SIGEV_THREAD;
my_aiocb.aio_sigevent.notify_function = aio_completion_handler;
//设置回调函数
my_aiocb.aio_sigevent.notify_attributes = NULL;
my_aiocb.aio_sigevent.sigev_value.sival_ptr = &my_aiocb;
...
ret = aio_read(&my_aiocb);
}
那么下面这个函数是在哪个上下文中执行的呢?
void aio_completion_handler(int signo, siginfo_t *info, void *context)
{
struct aiocb *req;
req = (struct aiocb *)sigval.sival_ptr; //获得aiocb;
//请求的操作是否完成
if(aio_error(req) ==0 )
{
ret = aio_return(req);
}
return ;
} |
|