Pythonで複数I/Oの同時待機にselectを使う

import select

# ポーリングオブジェクト生成
poll = select.poll()
# ソケットを登録
poll.register(sock, select.POLLIN | select.POLLRDHUP)

fin = False
while True:
    # イベント発生まで待つ
    rdy = poll.poll();

    if not rdy:
        break

    for fno, ev in rdy:


        if fno == sock.fileno():
            if ev == select.POLLIN:
                data = sock.recv(SOCK_BUFSIZE)
                   : (受け取ったデータの処理)
            else:
                # 接続が切れたか、エラーの時
                fin = True

    if fin:
        # whileループから抜ける
        break

# 登録解除
poll.unregister(sock);

from socketserver import BaseRequestHandler, TCPServer
from select import poll, POLLIN, POLLRDHUP
from shlex import split
from subprocess import Popen, PIPE
from os import write

SOCK_BUFSIZE = 256
STREAM_BUFSIZE = 1024

class CmdHandler(BaseRequestHandler):

    def handle(self):
        # クライアントから送られてくるコマンド文字列を取得
        cmdline = self.request.recv(SOCK_BUFSIZE).strip().decode('utf-8')
        cmd = split(cmdline)
        print("Received command: [{}] ...".format(cmdline))

        # サブプロセスを生成
        pipe = Popen(cmd, stdout=PIPE, stderr=PIPE, stdin=PIPE)

        # ポーリングオブジェクトの設定
        pol = poll()
        pol.register(self.request, POLLIN | POLLRDHUP)
        pol.register(pipe.stdout, POLLIN)
        pol.register(pipe.stderr, POLLIN)

        fin = False
        while True:
            rdy = pol.poll();

            if not rdy:
                break

            for fno, ev in rdy:
                # サブプロセス標準出力の処理
                if fno == pipe.stdout.fileno():
                    if ev == POLLIN:
                        data = pipe.stdout.read1(STREAM_BUFSIZE)
                        self.request.send(data)
                    else:
                        # サブプロセスが終了した時
                        pol.unregister(pipe.stdout)
                        pol.unregister(pipe.stderr)
                        fin = True
                        print("Subprocess terminated.")

                # サブプロセス標準エラー出力の処理
                if fno == pipe.stderr.fileno():
                    if ev == POLLIN:
                        data = pipe.stderr.read1(STREAM_BUFSIZE)
                        self.request.send(data)

                # クライアントからのデータ取得
                if fno == self.request.fileno():
                    if ev == POLLIN:
                        data = self.request.recv(SOCK_BUFSIZE)
                        # バッファリングさせないようにos.write()を使う
                        write(pipe.stdin.fileno(), data)
                        print("Received string: " + data.strip().decode('utf-8'))
                    else:
                        # 接続が切れたか、エラー時はunregisterする
                        pol.unregister(self.request);
                        # サブプロセスを終了させる
                        pipe.terminate()
                        print("Client connection closed.")
            if fin:
                # サブプロセス終了→ループから抜ける
                break

        print("Terminating handler for [{}].".format(cmdline))

if __name__ == "__main__":
    SVHOST, SVPORT = "0.0.0.0", 12345

    with TCPServer((SVHOST, SVPORT), CmdHandler) as server:
        server.serve_forever()

$ telnet localhost 12345
Trying 127.0.0.1...
Connected to localhost.
Escape character is '^]'.
ls -F
cmdServer.py*
cmdServer.py~*
Connection closed by foreign host.

$ python3 cmdServer.py
Received command: [ls -F] ...
Subprocess terminated.
Terminating handler for [ls -F].