вспыхивают из гнезда выберите

Question

У меня есть цикл, который в основном вызывает это каждые несколько секунд (после тайм-аута):

while(true){ 

    if(finished) 
     return; 

    switch(select(FD_SETSIZE, &readfds, 0, 0, &tv)){ 
     case SOCKET_ERROR : report bad stuff etc; return; 
     default : break; 
    } 

    // do stuff with the incoming connection 
} 

Так в основном за каждые несколько секунд (что определяется ТВ), он активирует прослушивание ,

Это выполняется на резьбе B (не основной нить). Есть моменты, когда я хочу закончить этот акцепторный цикл сразу из потока A (основной поток), но похоже, что мне нужно подождать, пока промежуток времени не закончится.

Есть ли способ нарушить функцию выбора из другого потока поэтому поток B может немедленно прекратиться?

Answer 1

Самый простой способ - это, вероятно, использовать pipe(2) для создания трубы и добавления считываемого конца в readfds. Когда другой поток хочет прервать select(), просто напишите ему байт, а затем уничтожьте его потом.

Answer 2

Да, вы создаете подключенную пару разъемов. Затем поток B записывает на одну сторону сокета и поток A добавляет другой боковой сокет для выбора. Поэтому, как только B пишет в сокет A, выйдите из выбора, не забудьте прочитать этот байт из сокета.

Это самый стандартный и распространенный способ прерывания выбора.

Примечание:

Под Unix, используйте socketpair для создания пары сокетов, под окнами это немного сложно, но прибегая к помощи Windows, socketpair даст вам образцы кода.

Answer 3

Не можете ли вы просто сделать тайм-аут достаточно коротким (например, 10 мсек?).

Это решение типа «просто создать фиктивное соединение» вроде как взломанное. Я лично считаю, что если приложение хорошо спроектировано, одновременные задачи никогда не должны прерываться принудительно, просто проверка работника достаточно часто (это также является причиной того, что boost.threads не имеет функции завершения).

Редактировать Сделал этот ответ CV. Это плохо, но это может помочь другим понять, почему это плохо, что объясняется в комментариях.

Answer 4

Вы можете использовать вызов выключения (Sock, SHUT_RDWR) из основного потока, чтобы выйти из ожидающего вызова вызова, который также выйдет из другого потока до истечения таймаута, поэтому вам не нужно ждать окончания истечения времени ожидания.

ура. :)