带有回调函数的c-AIO异步I/O--寻找最佳方式

Question

我正在尝试学习POSIX异步I/O。下面是我对别人的插图代码进行的编辑。我正在努力理解一些事情。

首先，我在接近尾声时有一个繁忙的等待循环，它关闭了intread_complete。这是一个"；"可接受"；(安全的，不管怎样……(aio_error()返回值的键控替代方案？此外，我在想，作为繁忙等待循环的替代方案，有一种方法可以让主线程进入睡眠状态，并让回调函数发送某种信号来唤醒它。但如果可以的话，我不知道该怎么做。

最后，我试图弄清楚如何向回调函数i_am_done中获取更多信息。例如，假设我想把输入数据塞进一个缓冲区，或者在缓冲区之间分割，主线程稍后可以使用，如果我有多个读取要做，每个调用的缓冲区可能会不同。我怎么能让i_am_done知道缓冲区是什么？

#include <stdio.h>
#include <stdlib.h>
#include <strings.h>
#include <aio.h>
//#include <bits/stdc++.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <fcntl.h>
#include <unistd.h>
#include <signal.h>
#include <errno.h>
const int BUFSIZE = 1024;
int read_complete = 0;

void i_am_done(sigval_t sigval)
{
struct aiocb *req;
req = (struct aiocb *)sigval.sival_ptr; //Pay attention here.
/*Check again if the asynchrony is complete?*/
if (aio_error(req) == 0)
{
read_complete = 1;
}
close(req->aio_fildes);

}

int main(void)
{
struct aiocb my_aiocb;
struct timeval t0, t1;

int fd = open("file.txt", O_RDONLY);
if (fd < 0)
perror("open");
bzero((char *)&my_aiocb, sizeof(my_aiocb));
my_aiocb.aio_buf = malloc(BUFSIZE);
if (!my_aiocb.aio_buf)
perror("my_aiocb.aio_buf");
my_aiocb.aio_fildes = fd;
my_aiocb.aio_nbytes = BUFSIZE;
my_aiocb.aio_offset = 0;
//Fill in callback information
/*
Using SIGEV_THREAD to request a thread callback function as a notification method
*/
my_aiocb.aio_sigevent.sigev_notify = SIGEV_THREAD;
my_aiocb.aio_sigevent.sigev_notify_function = i_am_done;
my_aiocb.aio_sigevent.sigev_notify_attributes = NULL;
my_aiocb.aio_sigevent.sigev_value.sival_ptr = &my_aiocb;
int ret = aio_read(&my_aiocb);

if (ret < 0)
perror("aio_read");
//The calling process continues to execute
while (read_complete != 1) {}
printf("main thread %sn", (char*)my_aiocb.aio_buf);
return 0;
}

Answer 1

在回答问题#2时，只需定义一个数据结构，在其中存储所需的附加数据，并将sival_ptr设置为该结构。例如：

struct my_data {
struct aiocb cb;
// For demonstration's sake:
int foo;
char *bar;
size_t quux;
}
// ...
struct my_data data;
data.cb.aio_sigevent.sigev_value.sival_ptr = &data; 
// Setup the rest of the struct and execute the read.

在回调中，您现在可以访问my_data结构。