[issue43805] multiprocessing.Queue hangs when process on other side dies

Thomas Kluyver added the comment: It's not my decision, so I can't really say. But the Queue API is pretty stable, and exists 3 times over in Python (the queue module for use with threads, in multiprocessing and in asyncio). So I'd guess that anyone wanting to add to that API would need to m

[issue43805] multiprocessing.Queue hangs when process on other side dies

Marko added the comment: Yes, something like that would indeed be really helpful. How likely is that something like that gets implemented? -- ___ Python tracker ___ __

[issue43805] multiprocessing.Queue hangs when process on other side dies

Thomas Kluyver added the comment: I think this is expected. The queue itself doesn't know that one particular process is meant to put data into it. It just knows that there's no data to get, so .get() blocks as the docs say it should. This doesn't apply to issue22393, because the pool knows

[issue43805] multiprocessing.Queue hangs when process on other side dies

Change by Myles Steinhauser : -- nosy: +myles.steinhauser ___ Python tracker ___ ___ Python-bugs-list mailing list Unsubscribe: htt

[issue43805] multiprocessing.Queue hangs when process on other side dies

Change by Jon Clucas : -- nosy: +shnizzedy ___ Python tracker ___ ___ Python-bugs-list mailing list Unsubscribe: https://mail.pytho

[issue43805] multiprocessing.Queue hangs when process on other side dies

Change by Terry J. Reedy : -- nosy: +davin, pitrou ___ Python tracker ___ ___ Python-bugs-list mailing list Unsubscribe: https://ma

[issue43805] multiprocessing.Queue hangs when process on other side dies

Marko added the comment: Somewhat related issue43806 with asyncio.StreamReader -- ___ Python tracker ___ ___ Python-bugs-list maili

[issue43805] multiprocessing.Queue hangs when process on other side dies

Marko added the comment: Possible duplicate of issue22393 -- ___ Python tracker ___ ___ Python-bugs-list mailing list Unsubscribe:

[issue43805] multiprocessing.Queue hangs when process on other side dies

New submission from Marko : When child process dies unexpectedly Queue.get waits indefinitely. Here is example: import os import signal import multiprocessing def child_func(qa, qb): input = qa.get() print('Child received: ', input) os.kill(os.getpid(), signal.SIGTERM) qb.put(