擅长:python、mysql、java
<p>在“常规”Python中,这非常简单。你知道吗</p>
<pre><code>from multiprocessing.pool import ThreadPool
import requests
responses = ThreadPool(10).map(requests.get, urls)
</code></pre>
<p>将10替换为#个线程,以产生最佳结果。你知道吗</p>
<p>但是,您指定了对派生线程/进程有限制的GAE及其自己的异步方法,该方法包括使用<a href="https://cloud.google.com/appengine/docs/python/issue-requests#issuing_an_http_request" rel="nofollow">URL Fetch service</a>中的异步函数,如下所示(未测试):</p>
<pre><code>rpcs = [urlfetch.create_rpc() for url in urls]
for (rpc, url) in zip(rpcs, urls):
urlfetch.make_fetch_call(rpc, url)
results = [rpc.get_result() for rpc in rpcs]
</code></pre>
<p>您需要添加错误处理。。。你知道吗</p>