Commit c0778e26 authored by Denis Bilenko's avatar Denis Bilenko

update examples/dns_mass_resolve.py with regard to API change: Pool.spawn now...

update examples/dns_mass_resolve.py with regard to API change: Pool.spawn now blocks if there are not free slots
parent cdccf8a1
...@@ -6,7 +6,7 @@ and yields the control to other greenlets until the result is ready. ...@@ -6,7 +6,7 @@ and yields the control to other greenlets until the result is ready.
This script splits the job between a number of greenlets to get the This script splits the job between a number of greenlets to get the
results faster. results faster.
""" """
import gevent
from gevent import socket from gevent import socket
from gevent.pool import Pool from gevent.pool import Pool
...@@ -28,8 +28,9 @@ def job(url): ...@@ -28,8 +28,9 @@ def job(url):
finally: finally:
finished += 1 finished += 1
for x in xrange(10, N): with gevent.Timeout(2, False):
pool.spawn(job, '%s.com' % x) for x in xrange(10, 10 + N):
pool.spawn(job, '%s.com' % x)
pool.join()
pool.join(timeout=2)
print 'finished within 2 seconds: %s/%s' % (finished, N) print 'finished within 2 seconds: %s/%s' % (finished, N)
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment