在Broken Pipe when Using Python Multiprocessing Managers (BaseManager/SyncManager) to Share Queue with Remote Machines中,建议我们添加: 在重新连接之前删除缓存的连接。将代码添加到引发异常的行上的try except子句中,然后重试。你知道吗
如果我使用pool和pool.apply_async
,我应该怎么做?你知道吗
from multiprocessing.managers import BaseProxy
...
if address in BaseProxy._address_to_local:
del BaseProxy._address_to_local[address][0].connection
目前没有回答
相关问题 更多 >
编程相关推荐