Communicator¶

class paddle.fluid.communicator. Communicator ( mode, kwargs=None, envs=None ) [source]

start ( ) start¶

Start communicator. Should call before training process.

Examples

             import paddle.fluid as fluid

prog = fluid.Program()
comm = fluid.communicator.Communicator(prog)
comm.start()
comm.stop()

            

stop ( ) stop¶

Stop communicator. Should call after training process.

Examples

             import paddle.fluid as fluid

prog = fluid.Program()
comm = fluid.communicator.Communicator(prog)
comm.start()
comm.stop()

            

is_running ( ) is_running¶

Get communicator is running or stop.

Examples

             import paddle.fluid as fluid

prog = fluid.Program()
comm = fluid.communicator.Communicator(prog)
comm.is_running()