使用 gevent 调用 recv

Question

我不得不同时执行多个函数调用

gevent.spawn(recv) 

因此，如果在一个 recv(spawn) 中，一个函数正在等待响应，则另一个 recv spawn 线程启动但使其在执行第二个函数时阻塞

def recv(*args, **kwargs):                                             
    while 1:                                                           
        try:                                                           
                return client_socket_fd.recv((args[0]))                
       except Exception, e:                                           
                err = e.args[0]                                        
                if err == errno.EAGAIN or err == errno.EWOULDBLOCK:    
                            sleep(1)                                   
                            print 'No data available'                  
                            continue                                   
                else:                                                  

                            break    

我们该如何进行呢？

Answer 1

协程（gevent 使用协程而不是线程）将在各种调用中“让步”给另一个协程。这包括调用函数的gevent 版本，例如sleep、recv。

为了调用正常的socket/IO/timing 代码并让gevent正常工作，你需要monkey_patch这个代码。这意味着调用一个 gevent 函数，它用自己的版本替换内置的 Python 模块。通常，您想要运行

from gevent import monkey; monkey.patch_all()

在代码的最开始。这避免了一些代码已经开始使用原始套接字或文件代码，然后在操作完成之前代码更改的奇怪错误。