myhttp.py 文件源码

def process(self, prio, obj):
    self.pause.wait()
    c = obj.to_http_object(self.freelist.get())
    if self._proxies: c = self._set_proxy(c, obj)

    c.response_queue = ((StringIO(), StringIO(), obj))
    c.setopt(pycurl.WRITEFUNCTION, c.response_queue[0].write)
    c.setopt(pycurl.HEADERFUNCTION, c.response_queue[1].write)

    with self.mutex_multi:
        self.m.add_handle(c)