Блог

Я пытаюсь изучить POSIX асинхронный ввод-вывод. Ниже приведена правка, которую я внес в чужой код иллюстрации. Я пытаюсь понять несколько вещей.

Во-первых, у меня есть цикл ожидания занятости ближе к концу, который завершает int read_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 *)amp;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 = amp;my_aiocb;

    int ret = aio_read(amp;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;
}
 

Отвечая на вопрос № 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 = amp;data; 
// Setup the rest of the struct and execute the read.
 

При обратном вызове теперь у вас есть доступ к структуре my_data.