Внедрение неблокирующего сервера TCP

Question

Я пытаюсь реализовать TCP-сервер, который не будет вешать (потенциально) навсегда во время операции recv или sendall.

Я думал, что это будет достаточно, чтобы задать тайм-аут для активного сокета, но это, кажется, не так: see here

Итак, как я мог бы расширить свой код, чтобы убедиться, что:

• RECV не будет висеть в любом случае
• SendAll не будет висеть в любом случае (ну, я не уверен, что если SendAll может повесить на всех)

Любые предложения приветствуются.

Answer 1

Что вам нужно, это функция select. Требуется 3 аргумента; список чтения, список записи, список ошибок. И затем он возвращает три значения, каждый из которых является списком сокета, который вы ввели, которые готовы либо быть записаны, либо прочитаны. (Или была ошибка, если вы хотите, чтобы проверить это.)

rl , wl , el = select([ serversocket , clientsocket ] , [] , []); 
for e in rl: 
    if e == serversocket: 
    acceptConnection(serversocket); 
    else: 
    readFromClient(clientsocket);