recherche

Maison  >  Questions et réponses  >  le corps du texte

gevent-socketio - Python gevent和Queue的问题

访问6个URL,怎么样才能开启两个gevent,当访问结束后,继续访问剩下的4个URL。
下面这段代码,访问两个URL后程序就结束了。

代码

# coding=utf-8

from gevent import monkey; monkey.patch_socket()
import gevent
import requests
import queue

q = queue.Queue()

def get_data(url):
    print('GET: %s' %url)
    resp = requests.get(url)
    data = resp.text
    print('%d bytes received from %s.' %(len(data), url))

q.put('http://www.baidu.com')
q.put('http://www.163.com')
q.put('http://www.sougou.com')
q.put('http://www.bing.com')
q.put('http://www.tudou.com')
q.put('http://www.v2ex.com')

gevent_list = []

for i in range(2):
    gevent_list.append(
        gevent.spawn(get_data, q.get_nowait())
    )

gevent.joinall(gevent_list)
PHP中文网PHP中文网2817 Il y a quelques jours365

répondre à tous(1)je répondrai

  • 黄舟

    黄舟2017-04-18 09:14:55

    Je l'ai résolu moi-même, je devrais le récupérer dans la file d'attente dans la méthode get_data

    def get_data():
        while not q.empty():
            url = q.get_nowait()
            print('GET: %s' %url)
            resp = requests.get(url)
            data = resp.text
            print('%d bytes received from %s.' %(len(data), url))

    Il n'est pas nécessaire de transmettre des paramètres lors du frai ci-dessous.

    répondre
    0
  • Annulerrépondre