Linux异步IO的简单应用

Linux异步IO的简单应用

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

int falg = 1;
void callBack(sigval_t sig)
{
struct aiocb *my_aiocb = (struct aiocb*)sig.sival_ptr;

if (aio_error(my_aiocb) == 0)
{
int ret = aio_return(my_aiocb);
if (ret > 0){
char *data = (char*)my_aiocb->aio_buf;
data[my_aiocb->aio_nbytes] = '\0';
printf("input:%s\n", data);
flag = 0
}
}
}

int main(void)
{
struct aiocb my_aiocb;

bzero((void*)&my_aiocb, sizeof(struct aiocb));
my_aiocb.aio_buf = malloc(64);                //开辟缓冲区
my_aiocb.aio_nbytes = 64;                     //设置缓冲区大小
my_aiocb.aio_offset = 0;                      //偏移量
my_aiocb.aio_fildes = 0;                      //文件标识，0表示标准输出

my_aiocb.aio_sigevent.sigev_notify_function = callBack;    //设置回调函数
my_aiocb.aio_sigevent.sigev_notify_attributes = NULL;     //属性
my_aiocb.aio_sigevent.sigev_notify = SIGEV_THREAD;      //选择回调函数的方式而不是信号
my_aiocb.aio_sigevent.sigev_value.sival_ptr = (void*)&my_aiocb;

printf("请输入\n");

aio_read(&my_aiocb);

while(flag)
{
printf("你爱输不输\n");
sleep(2);
}
}

gcc main.c -o main -lrt