有没有办法动态调整multiprocessing.Pool
尺寸?我正在编写一个简单的服务器进程,它会产生工作人员来处理新任务。使用multiprocessing.Process
对于这种情况可能更适合(因为工作人员的数量不应该是固定的),但我需要在生成的子进程退出后在父进程中执行自定义回调。由于某种原因,仅mulitprocessing.Pool.apply_async
似乎提供了一个回调参数(multiprocessing.Process
才不是)。
Billiard https://pypi.python.org/pypi/billiard处理池允许grow https://github.com/celery/billiard/blob/master/billiard/pool.py#L1255 and shrink https://github.com/celery/billiard/blob/master/billiard/pool.py#L1243池大小。
Pebble https://pypi.python.org/pypi/Pebble/3.1.17允许运行分配一个进程callback http://pythonhosted.org/Pebble/#concurrent一旦完成。
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)