Message367509
I noticed the bug is reproducible even if the child process does not put object in the queue:
import multiprocessing
import threading
import time
if __name__ == "__main__":
queue = multiprocessing.SimpleQueue()
def consume(queue):
while True:
print("Consumed:", queue.get())
thread = threading.Thread(target=consume, args=(queue,))
thread.start()
for i in range(10000):
queue.put(i)
p = multiprocessing.Process(target=lambda: None)
p.start()
p.join()
print("Not hanging yet", i) |
|
Date |
User |
Action |
Args |
2020-04-28 08:33:23 | Delgan | set | recipients:
+ Delgan |
2020-04-28 08:33:23 | Delgan | set | messageid: <1588062803.12.0.525075528099.issue40399@roundup.psfhosted.org> |
2020-04-28 08:33:23 | Delgan | link | issue40399 messages |
2020-04-28 08:33:22 | Delgan | create | |
|