Skip to content Skip to sidebar Skip to footer
Showing posts with the label Queue
Python Queue Get()/task_done() Issue

Python Queue Get()/task_done() Issue

Post a Comment
My consumer side of the queue: m = queue.get() queue.task_done() Questions: Does task_done() ef… Read more Python Queue Get()/task_done() Issue
Sharing Queue Between Threads Running In Different Modules

Sharing Queue Between Threads Running In Different Modules

Post a Comment
I have some modules in different packages for my project. This project requires several threads whi… Read more Sharing Queue Between Threads Running In Different Modules
Python Threads - Always Have X Active Threads When Iterating Over N Tasks

Python Threads - Always Have X Active Threads When Iterating Over N Tasks

Post a Comment
What I basically want to do is the following: import threading import Queue def test_thread(elem, … Read more Python Threads - Always Have X Active Threads When Iterating Over N Tasks
How To Run A Thread More Than Once In Python

How To Run A Thread More Than Once In Python

Post a Comment
I am trying to run a thread more than once and keep getting an error: RuntimeError: threads can onl… Read more How To Run A Thread More Than Once In Python
Python Redis Subscribe Can Not Get All Datas?

Python Redis Subscribe Can Not Get All Datas?

Post a Comment
I am using python to get datas from redis and then parser it to kafka. It works well in most situat… Read more Python Redis Subscribe Can Not Get All Datas?
Maximum Size For Multiprocessing.queue Item?

Maximum Size For Multiprocessing.queue Item?

Post a Comment
I'm working on a fairly large project in Python that requires one of the compute-intensive back… Read more Maximum Size For Multiprocessing.queue Item?