Как подождать 2 типа событий в цикле (C)?

Question

Я пытаюсь подождать waitpid() и read() в цикле while-true. В частности, я жду одного из этих двух событий, а затем обработаю его на каждой итерации цикла. В настоящее время у меня есть следующая реализация (чего я не хочу).

while (true) { 
    pid_t pid = waitpid(...); 
    process_waitpid_event(...); 

    ssize_t sz = read(socket, ....); 
    process_read_event(...); 
} 

Проблема с этой реализацией заключается в том, что обработка второго события зависит от завершения первого события. Вместо того, чтобы обрабатывать эти два события последовательно, я хочу обработать любое событие, которое будет первым в каждой итерации цикла. Как мне это сделать?

Answer 1

Если вы не хотите, чтобы коснуться нарезание резьбы, вы можете включить его в настройках вызова waitpid:

pid_t pid = waitpid(pid, &status, WNOHANG); 

Как от страницы руководства для waitpid:

WNOHANG - возвращение немедленно, если ребенок не вышел.

Как таковой, если waitpid не готов, он не будет блокироваться, и программа будет просто продолжать переход к следующей строке.

Что касается read, если это блокировка, вы можете взглянуть на poll(2). Вы можете по существу проверить, готов ли ваш сокет к каждому установленному интервалу, например. 250 мс, а затем позвоните по телефону read. Это позволит ему не блокировать.

Ваш код может выглядеть немного так:

// Creating the struct for file descriptors to be polled. 
struct pollfd poll_list[1]; 
poll_list[0].fd = socket_fd; 
poll_list[0].events = POLLIN|POLLPRI; 
// POLLIN There is data to be read 
// POLLPRI There is urgent data to be read 

/* poll_res > 0: Something ready to be read on the target fd/socket. 
** poll_res == 0: Nothing ready to be read on the target fd/socket. 
** poll_res < 0: An error occurred. */ 
poll_res = poll(poll_list, 1, POLL_INTERVAL); 

Это только при условии, что вы read ИНГ из сокета, судя по именам переменных в вашем коде. Как говорили другие, ваша проблема может потребовать чего-то более тяжелого режима, такого как резьба.

Answer 2

Ответ @DanielPorteous должен работать, если вы не хотите использовать поток в своей программе.

Идея проста, не сохраняя функции waitpid и read, чтобы ждать, если они не потратят некоторое время на выполнение своей работы. Идея заключается в том, чтобы сохранить механизм тайм-аута, чтобы, если waitpid не имеет ничего, чтобы создать воздействие на всю операцию, он немедленно вернется, и то же самое произойдет и для операции чтения.

Если функция read занимает очень много времени, чтобы прочитать весь буфер, вы можете ограничить чтение вручную из функции read, чтобы она не читала целое сразу, а читала ее в течение 2 миллисекунд, а затем передавала цикл до функции waitpid для выполнения.

Но его безопасно использовать резьбу для вашей цели и ее довольно легко реализовать. Here's a nice guideline о том, как вы можете реализовать потоки.

В вашем случае вам нужно объявить два потока.

pthread_t readThread; 
pthread_t waitpidThread; 

Теперь вам нужно создать поток и передать определенную функцию в качестве параметра.

pthread_create(&(waitpidThread), NULL, &waitpidFunc, NULL); 
pthread_create(&(readThread), NULL, &readFunc, NULL); 

Теперь вы, возможно, придется написать waitpidFunc и readFunc функцию. Они могут выглядеть так.

void* waitpidFunc(void *arg) 
{ 
    while(true) { 
     pid_t pid = waitpid(...); 

     // This is to put an exit condition somewhere. 
     // So that you can finish the thread 
     int exit = process_waitpid_event(...); 

     if(exit == 0) break; 
    } 

    return NULL; 
} 

Answer 3

Я думаю, что правильный инструмент в этой ситуации select или poll. Оба выполняют практически ту же работу. Они позволяют выбирать те дескрипторы, в которых доступен вход. Следовательно, вы можете подождать одновременно на двух сокетах, например. Однако он не может использоваться непосредственно в вашем случае, так как вы хотите дождаться процесса и сокета. Решением будет создание трубы, которая будет получать что-то, когда заканчивается waitpid.

Вы можете запустить новую резьбу и подключить ее к оригинальной трубе. Новый поток будет вызывать waitpid, и когда он закончит, он напишет свой результат на трубу. Основной поток будет ждать либо для сокета, либо для канала, используя select.