Gevent hub raises exception on pool

Question

Running gevent pool gives me the following exception on join:

return greenlet.switch(self)

gevent.hub.LoopExit: ('This operation would block forever', Hub at 0x105cbd190 select default pending=0 ref=0)

Code is:

    queue = gevent.queue.Queue(items=range(5))
    pool = gevent.pool.Pool(3)
    pool.map(self.foo_index, queue)
    pool.join(raise_error=True)

The error seems to occur before join is called during map. Oh no wait, an exception is raised immediately which must come from join: this is confusing.

Pant Pant · Accepted Answer · 2016-07-19T15:38:01

Using map_async on your sample code did resolved the issue on my side. I hope this is what you are looking for.

Gevent hub raises exception on pool

2 Answers