python select

py_select.py

from select import select
import socket
import Queue

server = socket.socket()

server.bind(('127.0.0.1', 8888))
server.listen(5)
server.setblocking(0)
input_list = [server, ]
output_list = []
num = 0

while True:
    print("waiting for next event...")
    readable, writeable, std_err = select(input_list, output_list, input_list)

    for sock in readable:
        if sock == server:
            conn, addr = server.accept()
            conn.setblocking(0)
            input_list.append(conn)
        else:
            try:
                msg = sock.recv(1)
                print 'get msg:', msg.decode()
                if msg:
                    if sock not in output_list:
                        output_list.append(sock)
                else:
                    input_list.remove(sock)
                    sock.close()
            except socket.error, e:
                if sock in output_list:
                    output_list.remove(sock)
                input_list.remove(sock)

    for sock in writeable:
        sock.send('get')
        output_list.remove(sock)

server.close