异步IO aio_error失败

sophistcxf

我写了两段代码如下，两段代码只有注释掉的两行代码的区别，一个在aio_error返回0是调用了aio_return，另一个没有调用。执行的结果是调用aio_return的aio_error就会返回错误码22，没调用aio_return的sleep一次后aio_error返回0。为什么“aio_return这一句还没有执行到的代码会对aio_error的返回值造成影响呢？或者说为什么还没有调用aio_return，就会影响异步IO的操作呢？”，请了解的人帮忙，多谢。
第一段

1. int main()
   
2. {
   
3.     struct aiocb aio;
   
4.     int fd = open("text", O_RDONLY);
   
5.     aio.aio_fildes = fd;
   
6.     aio.aio_offset = 0;
   
7.     aio.aio_buf = new char[30];
   
8.     memset((char*)aio.aio_buf, 0, 30);
   
9.     aio.aio_nbytes = 30;
   
10.     aio.aio_reqprio = 0;
    
11.     if (aio_read(&aio) < 0) {
    
12.         printf("read fail.\n");
    
13.     }
    
14.     printf("aio_read end.\n");
    
15.     while (true) {
    
16.         int rlt = aio_error(&aio);
    
17.         if (rlt == 0) {
    
18.             ssize_t s = aio_return(&aio);
    
19.             printf("result:\n%d\n", s);
    
20.             printf("content:\n%s\n", aio.aio_buf);
    
21.             break;
    
22.         }
    
23.         else if (rlt == EINPROGRESS) {
    
24.             printf("read is still awaiting, sleeping for 1s.\n");
    
25.             sleep(1);
    
26.             continue;
    
27.         }
    
28.         else if (rlt == -1) {
    
29.             printf("aio_read error, rlt: -1.\n");
    
30.             break;
    
31.         }
    
32.         else {
    
33.             printf("aio_read error, rlt: %d.\n", rlt);
    
34.             break;
    
35.         }
    
36.     }
    
37.     return 0;
    
38. }

复制代码

第二段

1. int main()
   
2. {
   
3.     struct aiocb aio;
   
4.     int fd = open("text", O_RDONLY);
   
5.     aio.aio_fildes = fd;
   
6.     aio.aio_offset = 0;
   
7.     aio.aio_buf = new char[30];
   
8.     memset((char*)aio.aio_buf, 0, 30);
   
9.     aio.aio_nbytes = 30;
   
10.     aio.aio_reqprio = 0;
    
11.     if (aio_read(&aio) < 0) {
    
12.         printf("read fail.\n");
    
13.     }
    
14.     printf("aio_read end.\n");
    
15.     while (true) {
    
16.         int rlt = aio_error(&aio);
    
17.         if (rlt == 0) {
    
18.             //ssize_t s = aio_return(&aio);
    
19.             //printf("result:\n%d\n", s);
    
20.             printf("content:\n%s\n", aio.aio_buf);
    
21.             break;
    
22.         }
    
23.         else if (rlt == EINPROGRESS) {
    
24.             printf("read is still awaiting, sleeping for 1s.\n");
    
25.             sleep(1);
    
26.             continue;
    
27.         }
    
28.         else if (rlt == -1) {
    
29.             printf("aio_read error, rlt: -1.\n");
    
30.             break;
    
31.         }
    
32.         else {
    
33.             printf("aio_read error, rlt: %d.\n", rlt);
    
34.             break;
    
35.         }
    
36.     }
    
37.     return 0;
    
38. }

复制代码