2014-07-22 1:19 GMT+03:00 Yaşar Arabacı <yasar11...@gmail.com>:
> This program is supposed to give me status codes for web pages that
> are found on my sitemap.xml file. But program hangs as Tasks wait for
> getting something out of the Queue. I think it has something to do
> with how I am using asyncio.Queue, but I couldn't figure out what am I
> doing wrong here. Can anyone help me with that?
Ok, I figured out what was wrong with my code.
Since asyncio.Queue.put() is a coroutine, I should have wrapped those
with asyncio.Task in order for them to start executing.
Therefore, this works;
q = asyncio.Queue()
loop = asyncio.get_event_loop()
for i in range(num_coroutines): # start 10 tasks
tasks.append(asyncio.Task(print_status_code(q)))
for loc in soup.find_all('loc'):
asyncio.Task(q.put(loc.string))
for i in range(num_coroutines): # Put poison pil.
asyncio.Task(q.put(None))
print("%i items in queue" % q.qsize())
loop.run_until_complete(asyncio.wait(tasks))
--
http://ysar.net/
--
https://mail.python.org/mailman/listinfo/python-list
