蟒蛇异步Socket编程

Question

现在我有两个线程，线程1是主线程和线程2是thread.I需要线程2做的所有网络问题的任务，所以我把所有的插座中的线程2，并将其设置为无堵塞。线程1用于将请求推送到线程2来完成这项工作。

起初，我写的是这样的：

request_queue = Queue.Queue() 
tasks = [] 
sockets = [] 

**thread 1:** 

while True: 

    get_user_input() 
    #... 
    request_queue.put(request_task) 

**thread 2:** 

while True: 

    if have_requests(request_queue): 

     t = create_task() 

     tasks.append(t) 

     sockets.append(t.socket()) 

    select(sockets,timeout=0) #no blocking select 

    update_tasks() 
    #... 

显然，当没有请求和任务，线程2会浪费cpu.I不想使用睡眠（），因为当线程2睡觉，它无法处理请求在time.Then我想，也许我应该request_queue更改为本地主机插座，这样的：

request_queue = sock.sock() 
request_queue.bind(local_host,some_port) 
request_queue.listen() 

**thread 1** 

while True: 

    get_user_input() 

    request_queue.send(new_request) 


**thread 2** 

while True: 

    select(sockets) # blocking select 

    if request_queue is active: 
     t = request_queue.recv() 
     t = create_task(t) 
     tasks.append(t) 
     sockets.append(t.socket()) 

    #check other sockets 
    #update tasks... 

但这样子有点棘手，我不知道是否这是一个好方法。我想要的是线程2可以及时处理请求，不要浪费CPU时间并在同一时间处理套接字事件。任何人都可以帮忙

Answer 1

对于异步网络，请参阅Tornado，Twisted或Gevent。也this article可能是有用的为您服务。 实例与GEVENT：

def handle_socket(sock): 
    sock.sendall("payload") 
    sock.close() 

server = socket.socket() 
server.bind(('0.0.0.0', 9999)) 
server.listen(500) # max connections 
while True: 
    try: 
     new_sock, address = server.accept() 
    except KeyboardInterrupt: 
     break 
    # handle every new connection with a new handler 
    gevent.spawn(handle_socket, new_sock) 

而且Celery是最合适的后台作业执行。