Jonas Brunsgaard added the comment:
You are right that get_nowait() is the correct api for my use case, using
get_nowait() nothing is pushed to the internal _getters deque. The reason for
my us of get() is that job futures are created one place in the code and then
thrown in a processing
Jonas Brunsgaard added the comment:
Okay I thoroughly read the code again. Can you describe the architectural
changes to the code regarding a patch, I will do a proposal. But I have to know
we are on the same page, so I do not waste my and your time
Jonas Brunsgaard added the comment:
In my particular case, I developed an application close to beanstalkd, but with
redis as "engine". I did create a callbackback reader class for users to
subclass, the callbackreader is checking every second, on every
tube(queue.Object). If ne
New submission from Jonas Brunsgaard:
When making repeated calls to queue.get, memory is building up and is not freed
until queue.push is called.
I wrote this little program to show my findings. The program will perform a lot
of calls to queue.get and once every 60 seconds a queue.push
