shutdown

paddle.distributed.rpc. shutdown ( ) [源代码]

关闭 RPC 代理和 worker。这将阻塞直到所有本地和远程 RPC 进程都达到此方法并等待所有未完成的工作完成。

参数

返回

代码示例

>>> import paddle.distributed.rpc as rpc

>>> rpc.init_rpc("worker0", rank=0, world_size=1,
...             master_endpoint="127.0.0.1:8004")

>>> rpc.shutdown()