Skip to content
Advertisement

Tag: queue

Python: will a thread ever unblock while hanging on a `Queue.get(block=True)` call if the queue is suddenly destroyed from another thread/process?

TLDR: Would a blocking get be unblocked by a queue that would be terminated in some way? Long question: Okay, so I know that the thread will hang if the queue (multiprocessing.Queue) remains empty forever while trying to fetch something from it with a blocking get. But suppose now that in another thread or process, I close the queue with

FilterStore queue

I have a FilterStore and during my simulation there is a queue for the FilterStore.Get event at some times. Now I have two questions: Is there a way to see the actual elements in the queue, not just the object number? With FilterStore.get_queue I get this output: [FilterStoreGet() object at 0x221a47c6080, FilterStoreGet() object at 0x221a47c6eb8]. But I would like a

How to create a delayed queue in RabbitMQ?

What is the easiest way to create a delay (or parking) queue with Python, Pika and RabbitMQ? I have seen an similar questions, but none for Python. I find this an useful idea when designing applications, as it allows us to throttle messages that needs to be re-queued again. There are always the possibility that you will receive more messages

Advertisement