Message382945
As best I can tell, sometimes when a Listener or Connection is not properly initialised, the Client fails to communicate properly with it. Instead of raising an exception, the Client hangs.
receiver.py:
from multiprocessing.connection import Listener
while True:
with Listener(("localhost", 10000), authkey=b"test") as listener:
with listener.accept() as connection:
print(connection.recv())
client.py (intended as a stress test):
from multiprocessing.connection import Client
for i in range(1000):
successfully_sent = False
while not successfully_sent:
try:
with Client(("localhost", 10000), authkey=b"test") as client:
client.send(i)
except (ConnectionRefusedError, ConnectionResetError):
continue
successfully_sent = True
Also noteworthy: I posted on StackExchange (https://stackoverflow.com/questions/65276145/multiprocessing-receive-all-messages-from-multiple-runtimes) and it seems that the code there (only 1000 messages) took around an hour to run for a Windows user, whereas it would take less than a second to successfully run on Linux. |
|
Date |
User |
Action |
Args |
2020-12-13 23:37:58 | to7m | set | recipients:
+ to7m |
2020-12-13 23:37:58 | to7m | set | messageid: <1607902678.82.0.104927232585.issue42631@roundup.psfhosted.org> |
2020-12-13 23:37:58 | to7m | link | issue42631 messages |
2020-12-13 23:37:58 | to7m | create | |
|