基于linux的异步i/o实现

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <fcntl.h>
#include <unistd.h>
#include <aio.h>

#define BUFFER_SIZE 1024

int main() {
    int fd;
    char buffer[BUFFER_SIZE];
    struct aiocb aio;

    // 打开文件
    fd = open("testfile.txt", O_RDONLY);
    if (fd == -1) {
        perror("open");
        return 1;
    }

    // 初始化aiocb结构体
    memset(&aio, 0, sizeof(struct aiocb));
    aio.aio_fildes = fd;
    aio.aio_buf = buffer;
    aio.aio_nbytes = BUFFER_SIZE;
    aio.aio_offset = 0;

    // 提交异步I/O请求
    if (aio_read(&aio) == -1) {
        perror("aio_read");
        close(fd);
        return 1;
    }

    // 等待I/O操作完成
    while (aio_error(&aio) == EINPROGRESS) {
        // 可以在这里执行其他任务
    }

    // 获取I/O操作的结果
    int ret = aio_return(&aio);
    if (ret > 0) {
        printf("Read %d bytes: %s\n", ret, buffer);
    } else {
        perror("aio_return");
    }

    // 关闭文件
    close(fd);

    return 0;
}